package com.example.spring.webfluxmongo;import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import org.springframework.data.annotation.Id;
import org.springframework.data.mongodb.core.mapping.Document;@Document
@Data
@AllArgsConstructor
@NoArgsConstructor
public class Employee {@Idprivate String id;private String name;
}

package com.example.spring.webfluxmongo;import lombok.AllArgsConstructor;
import org.springframework.web.bind.annotation.*;
import reactor.core.publisher.Flux;
import reactor.core.publisher.Mono;@RestController
@AllArgsConstructor
@RequestMapping("/employee")
public class EmployeeController {private final EmployeeRep employeeRep;@DeleteMapping("/{id}")public Mono delete(@PathVariable String id){return employeeRep.deleteById(id);}@GetMapping("/{id}")public Mono findById(@PathVariable String id){return employeeRep.findById(id);}@PutMappingpublic Mono update(@RequestBody Employee employee){return employeeRep.save(employee);}@PostMappingpublic Mono<Employee> save(@RequestBody Employee employee){return employeeRep.save(employee);}@GetMappingpublic Flux<Employee> findAll(){return employeeRep.findAll();}
}

package com.example.spring.webfluxmongo;import org.springframework.data.repository.reactive.ReactiveCrudRepository;public interface EmployeeRep extends ReactiveCrudRepository<Employee,String> {
}

package com.example.spring.webfluxmongo;import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;@SpringBootApplication
public class WebfluxMongoApplication {public static void main(String[] args) {SpringApplication.run(WebfluxMongoApplication.class, args);}}

spring.data.mongodb.uri=mongodb://localhost:27017/test