spring webflux自定义netty 参数解析

目录

• 自定义 webflux 容器配置
• 解决方案
• 初识Spring WebFlux
  • Spring Web新的改变
  • Spring WebFlux的特性
    • 1.异步非阻塞
    • 2.响应式（reactive）编程
    • 3.适配多种web容器
  • Spring WebFlux简单实践
    • 1.工程创建
    • 2.Controller中与SpringMVC的对比
    • 3.异步非阻塞的体现
    • 4.添加数据库支持
    • 5.Dao的编写
    • 6.Controller的编写
    • 7.响应式编程Handler的编写
    • 8.响应式编程Route的编写

@Component
public class ContainerConfig extends ReactiveWebServerFactoryCustomizer {
    public ContainerConfig(ServerProperties serverProperties) {
        super(serverProperties);
    }
    @Override
    public void customize(ConfigurableReactiveWebServerFactory factory) {
        super.customize(factory);
        NettyReactiveWebServerFactory nettyFactory = (NettyReactiveWebServerFactory) factory;
        nettyFactory.setResourceFactory(null);
        nettyFactory.addServerCustomizers(server ->
                server.tcpConfiguration(tcpServer ->
                        tcpServer.runOn(LoopResources.create("mfilesvc", Runtime.getRuntime().availableProcessors() * 4, Runtime.getRuntime().availableProcessors() * 8, true))
                                .selectorOption(CONNECT_TIMEOUT_MILLIS, 200)
                ).channelGroup(new ChannelGroup())
        );     
    }
    @Override
    public int getOrder() {
        return -10;
    }
}

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-webflux</artifactId>
</dependency>

@RestController
@Slf4j
public class UserController {
    @RequestMapping("/index")
    public String index(){
        log.info("springmvc index begin");
        String result="cc666";
        log.info("springmvc index end");
        return result;
    }
    @RequestMapping("/index2")
    public Mono<String> index2(){
        log.info("webflux index begin");
        Mono<String> result=Mono.just("666cc");
        log.info("webflux index end");
        return result;
    }
}

@RestController
@Slf4j
@AllArgsConstructor
public class UserController {
    /**
     *  模拟耗时查询操作
     */
    public String createStr(){
        try {
            Thread.sleep(3000L);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        return "cc666cc";
    }
    @RequestMapping("/index")
    public String index(){
        log.info("springmvc index begin");
        String result=this.createStr();
        log.info("springmvc index end");
        return result;
    }
    @RequestMapping("/index2")
    public Mono<String> index2(){
        log.info("webflux index begin");
        Mono<String> result=Mono.fromSupplier(()->this.createStr());
        log.info("webflux index end");
        return result;
    }
}

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-data-r2dbc</artifactId>
</dependency>
<dependency>
    <groupId>com.github.jasync-sql</groupId>
    <artifactId>jasync-r2dbc-mysql</artifactId>
    <version>1.1.3</version>
</dependency>

spring:
  r2dbc:
    url: r2dbc:mysql://127.0.0.1:3306/study
    username: xxx
    password: xxx

@Table("user")
@Data
@AllArgsConstructor
@NoArgsConstructor
public class User {
    @Id
    private Long id;
    private String username;
    private String password;
}

public interface UserDao extends ReactiveCrudRepository<User,Long> {
}

@RestController
@AllArgsConstructor
public class UserController {
    private final UserDao userDao;
    @GetMapping("/findAll")
    public Flux<User> findAll(){
        return userDao.findAll();
    }
    @PostMapping("/save")
    public Mono save(@RequestBody User user){
        return this.userDao.save(user);
    }
    @DeleteMapping("/delete/{id}")
    public Mono delete(@PathVariable Long id){
        return this.userDao.deleteById(id);
    }
    @GetMapping("/get/{id}")
    public Mono get(@PathVariable Long id){
        return this.userDao.findById(id);
    }
}

@Component
@AllArgsConstructor
public class UserHandler {
    private final UserDao userDao;
    public Mono<ServerResponse> saveUser(ServerRequest request){
        Mono<User> mono=request.bodyToMono(User.class);
        User user = mono.block();
        return ServerResponse.ok().build(this.userDao.save(user).then());
    }
    public Mono<ServerResponse> deleteById(ServerRequest request){
        Long id=Long.parseLong(request.pathVariable("id"));
        return ServerResponse.ok().build(this.userDao.deleteById(id).then());
    }
    public Mono<ServerResponse> getByid(ServerRequest request){
        Long id=Long.parseLong(request.pathVariable("id"));
        Mono<User> mono = this.userDao.findById(id);
        return ServerResponse.ok().contentType(MediaType.APPLICATION_JSON).body(mono,User.class);
    }
    public Mono<ServerResponse> findAll(ServerRequest request){
        Flux<User> all = this.userDao.findAll();
        return ServerResponse.ok().contentType(MediaType.APPLICATION_JSON).body(all,User.class);
    }
}

@Configuration
public class UserRoute {
    @Bean
    public RouterFunction<ServerResponse> routeUser(UserHandler userHandler){
        return RouterFunctions
                .route(RequestPredicates.GET("findAll2")
                        .and(RequestPredicates.accept(MediaType.APPLICATION_JSON)),userHandler::findAll)
                .andRoute(RequestPredicates.GET("/get2/{id}")
                        .and(RequestPredicates.accept(MediaType.APPLICATION_JSON)),userHandler::getByid)
                .andRoute(RequestPredicates.DELETE("/delete2/{id}")
                        .and(RequestPredicates.accept(MediaType.APPLICATION_JSON)),userHandler::deleteById)
                .andRoute(RequestPredicates.POST("/save2")
                        .and(RequestPredicates.accept(MediaType.APPLICATION_JSON)),userHandler::saveUser);
    }
}