diff --git a/src/main/java/ink/wgink/gateway/WgGatewayApplication.java b/src/main/java/ink/wgink/gateway/WgGatewayApplication.java index c0f41ef..50774e8 100644 --- a/src/main/java/ink/wgink/gateway/WgGatewayApplication.java +++ b/src/main/java/ink/wgink/gateway/WgGatewayApplication.java @@ -6,10 +6,11 @@ import org.springframework.boot.context.properties.EnableConfigurationProperties import org.springframework.cloud.gateway.route.RouteLocator; import org.springframework.cloud.gateway.route.builder.RouteLocatorBuilder; import org.springframework.context.annotation.Bean; +import org.springframework.web.reactive.config.EnableWebFlux; import org.yaml.snakeyaml.util.UriEncoder; @EnableConfigurationProperties -@SpringBootApplication +@SpringBootApplication(scanBasePackages = {"ink.wgink"}) public class WgGatewayApplication { public static void main(String[] args) { diff --git a/src/main/java/ink/wgink/gateway/config/WebFluxFilterConfig.java b/src/main/java/ink/wgink/gateway/config/WebFluxFilterConfig.java new file mode 100644 index 0000000..255c99f --- /dev/null +++ b/src/main/java/ink/wgink/gateway/config/WebFluxFilterConfig.java @@ -0,0 +1,40 @@ +package ink.wgink.gateway.config; + +import org.springframework.context.annotation.Configuration; +import org.springframework.web.server.ServerWebExchange; +import org.springframework.web.server.WebFilter; +import org.springframework.web.server.WebFilterChain; +import reactor.core.publisher.Flux; +import reactor.core.publisher.Mono; + +/** + * When you feel like quitting. Think about why you started + * 当你想要放弃的时候，想想当初你为何开始 + * + * @ClassName: WebFluxConfig + * @Description: + * @Author: wanggeng + * @Date: 2021/4/14 2:42 下午 + * @Version: 1.0 + */ +@Configuration +public class WebFluxFilterConfig implements WebFilter { + + @Override + public Mono filter(ServerWebExchange serverWebExchange, WebFilterChain webFilterChain) { + serverWebExchange.getRequest().getHeaders().forEach((k, list) -> { + System.out.println(k); + list.forEach(System.out::println); + }); + + return webFilterChain.filter(serverWebExchange); + } + + public static void main(String[] args) { + Flux.just("你好1", "你好2").subscribe(c -> { + System.out.println(c); + }); + + Mono.just("1").subscribe(System.out::println); + } +} diff --git a/src/main/resources/application.yml b/src/main/resources/application.yml index cff7fdc..a2227cd 100644 --- a/src/main/resources/application.yml +++ b/src/main/resources/application.yml @@ -10,5 +10,5 @@ spring: logging: level: - org: debug + org.springframework: debug ink.wgink: debug \ No newline at end of file diff --git a/src/test/java/ink/wgink/gateway/LambdaTest.java b/src/test/java/ink/wgink/gateway/LambdaTest.java new file mode 100644 index 0000000..6d75a3a --- /dev/null +++ b/src/test/java/ink/wgink/gateway/LambdaTest.java @@ -0,0 +1,73 @@ +package ink.wgink.gateway; + +import java.util.function.*; + +/** + * When you feel like quitting. Think about why you started + * 当你想要放弃的时候，想想当初你为何开始 + * + * @ClassName: LambdaTest + * @Description: + * @Author: wanggeng + * @Date: 2021/4/16 10:05 上午 + * @Version: 1.0 + */ +public class LambdaTest { + + public static class Dog { + private String name = "单身狗"; + private int food = 10; + + public Dog() { + } + + public Dog(String name) { + this.name = name; + } + + public static void bark(Dog dog) { + System.out.println(dog + "叫了"); + } + + public int eat(int num) { + System.out.println(this.name + "吃了" + num + "斤"); + this.food -= num; + return this.food; + } + + @Override + public String toString() { + return this.name; + } + } + + public static void main(String[] args) { + Dog dog = new Dog(); + + // 静态方法 + Consumer consume = Dog::bark; + consume.accept(dog); + + // 通过实例得到方法的引用 + Function function = dog::eat; + System.out.println("还剩下" + function.apply(2) + "斤"); + + UnaryOperator unaryOperator = dog::eat; + IntUnaryOperator intUnaryOperator = dog::eat; + + System.out.println("还剩下" + intUnaryOperator.applyAsInt(2) + "斤"); + + // 使用类名得到非静态方法的引用，输入两个值，输出一个值 + BiFunction biFunction = Dog::eat; + System.out.println("还剩下" + biFunction.apply(dog, 1) + "斤"); + + // 得到没有构造参数的引用 + Supplier supplierDog = Dog::new; + System.out.println("还剩下" + supplierDog.get().eat(1) + "斤"); + + // 得到一个参数的 + Function functionDog = Dog::new; + System.out.println("还剩下" + functionDog.apply("李四").eat(1) + "斤"); + } + +} diff --git a/src/test/java/ink/wgink/gateway/LambdaTest2.java b/src/test/java/ink/wgink/gateway/LambdaTest2.java new file mode 100644 index 0000000..3b73318 --- /dev/null +++ b/src/test/java/ink/wgink/gateway/LambdaTest2.java @@ -0,0 +1,38 @@ +package ink.wgink.gateway; + +import java.util.function.*; + +/** + * When you feel like quitting. Think about why you started + * 当你想要放弃的时候，想想当初你为何开始 + * + * @ClassName: LambdaTest + * @Description: + * @Author: wanggeng + * @Date: 2021/4/16 10:05 上午 + * @Version: 1.0 + */ +public class LambdaTest2 { + + public static void main(String[] args) { + Function result = x -> x; + System.out.println(result.apply(1)); + + Function> result2 = x -> y -> x + y; + System.out.println(result2.apply(2).apply(2.2)); + + Function>> result3 = x -> y -> z -> x + y + z; + System.out.println("结果:"+ result3.apply(1).apply(2).apply(3)); + int[] nums = {1, 2, 3}; + Function f = result3; + for(int i = 0; i < nums.length; i++) { + Object n = f.apply(nums[i]); + if(n instanceof Function) { + f = (Function) n; + } else { + System.out.println("循环结果:" + n); + } + } + } + +}