Springboot 整合 webflux

1.pom.xml 写入 webflux 与 mongodb-reactive的坐标

	<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-webflux</artifactId>
	</dependency>

2.Application.properties 写入 monogdb的配置

spring.data.mongodb.host=localhost
spring.data.mongodb.database=jjj
spring.data.mongodb.port=27017
spring.data.mongodb.username=iii
spring.data.mongodb.password=xxx

3.Model

@Document
@Date
	public class Apple implements Serializable {
   	 	@Id
    	private String id;
    	private String name;
}

4.持久层继承 ReactiveMongoRepository

@Repository
public interface AppleRepository extends ReactiveMongoRepository<Apple,String> {
}

5.本教程舍去了逻辑业务层，直接在控制层使用

@RestController
@RequestMapping("apple")
public class AppleController {
    @Autowired
    AppleRepository appleRepository;

    @PostMapping
    public Mono<Apple>  save(@RequestBody Apple  apple){
        Mono<Apple> save = appleRepository.save(apple);
        return save;
    };

    @GetMapping
    public Mono<Apple>  getById(@RequestParam String  id){
        Mono<Apple> byId = appleRepository.findById(id);
        return byId;
    };
}

6.启动