WebFlux

落日映苍穹つ 2024-04-19 08:47 62阅读 0赞

### WebFlux ###

*  依赖
 *  Repository
 *  DO
 *  Service
 *  RestController
 *  Application
 *  Main
 *  FluxWebClient
 *  gtihub

Flux是Spring开发的一个非阻塞响应框架，能真正让多核处理器发挥优势。

# 依赖 #

<dependency>
    	<groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-webflux</artifactId>
    </dependency>
    <dependency>
    	<groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-data-mongodb-reactive</artifactId>
    </dependency>
    <dependency>
    	<groupId>org.springframework.boot</groupId>
    	<artifactId>spring-boot-starter-data-jpa</artifactId>
    </dependency>

利用ReactiveMongoRepository访问mongoDB

# Repository #

@Repository
    public interface UserRepository extends ReactiveMongoRepository<User, Long> { 
    
    }

@Document标识这个类是一个mongo实体，@Id指定唯一标识

# DO #

@Document
    public class User implements Serializable { 
        private static final long serialVersionUID = -1928606958770613929L;
        @Id
        private Long id;
        @Field("name")
        private String name;
    
        public User() { 
        }
    
        public User(Long id, String name) { 
            this.id = id;
            this.name = name;
        }
            public Long getId() { 
            return id;
        }
    
        public void setId(Long id) { 
            this.id = id;
        }
    
        public String getName() { 
            return name;
        }
    
        public void setName(String name) { 
            this.name = name;
        }
    }

# Service #

@Service
    public class UserServiceImpl implements UserService { 
        @Autowired
        private UserRepository userRepository;
    
        @Override
        public Mono<User> save(User user) { 
            return userRepository.save(user);
        }
    
        @Override
        public Flux<User> findUsers() { 
            return userRepository.findAll();
        }
    }

访问层和以前mvc一样

# RestController #

@RestController
    @RequestMapping("/user")
    public class UserController { 
        @Autowired
        private UserService userService;
    
        @PostMapping(produces = MediaType.APPLICATION_STREAM_JSON_VALUE)
        public Mono<User> save() { 
            return userService.save(new User(1L, "fee"));
        }
    
        @GetMapping(produces = MediaType.APPLICATION_STREAM_JSON_VALUE)
        public Flux<User> findUsers() { 
            return userService.findUsers();
        }
    }

对mongoDB的连接配置

# Application #

spring.data.mongodb.host=172.17.0.3
    spring.data.mongodb.port=27017
    spring.data.mongodb.username=root
    spring.data.mongodb.password=123456
    spring.data.mongodb.database=test
    spring.data.mongodb.authentication-database=admin

> 注意：Spring boot连接和操作mongoDB使用yaml文件配置会无法读取正确的配置参数，报错非法字符

java.lang.IllegalArgumentException: Prohibited character at position 0

# Main #

需要排除Spring对数据源的自动配置，使用Mongo JPA访问数据。

@SpringBootApplication(exclude = DataSourceAutoConfiguration.class)
    @EnableReactiveMongoRepositories(basePackages = "com.foo.webflux.repository")
    public class Application { 
        public static void main(String[] args) { 
            SpringApplication.run(Application.class, args);
        }
    }

# FluxWebClient #

public class FluxClient { 
        public static void main(String[] args) { 
            WebClient client = WebClient.create("http://localhost:8080");
            Flux<User> userFlux = client.get().uri("/user")
                    .accept(MediaType.APPLICATION_STREAM_JSON)
                    .retrieve()
                    .bodyToFlux(User.class);
            userFlux.toStream()
                    .forEach(System.out::println);
        }
    }

# gtihub #

github：[webflux][]

[webflux]: https://github.com/arunachi/webflux.git