{"id":3996,"date":"2019-03-14T15:48:04","date_gmt":"2019-03-14T07:48:04","guid":{"rendered":"http:\/\/www.xttblog.com\/?p=3996"},"modified":"2019-03-14T15:48:04","modified_gmt":"2019-03-14T07:48:04","slug":"webflux-mongo-%e8%bf%9b%e8%a1%8c%e9%a1%b9%e7%9b%ae%e6%95%b4%e5%90%88%e5%bc%80%e5%8f%91","status":"publish","type":"post","link":"https:\/\/www.xttblog.com\/?p=3996","title":{"rendered":"WebFlux + Mongo \u8fdb\u884c\u9879\u76ee\u6574\u5408\u5f00\u53d1"},"content":{"rendered":"

\n\t\u4e0d\u77e5\u4e0d\u89c9\uff0c\u9646\u9646\u7eed\u7eed\u5df2\u7ecf\u5199\u8fc7\u5f88\u591a\u5173\u4e8e WebFlux \u6559\u7a0b\u4e86\u3002\u4e0d\u6765\u4e0d\u7740\u6025\u8fd9\u5199\u8fd9\u4e00\u5f20\u7684\u3002\u4f46\u662f\u6700\u8fd1\u6709\u4e00\u4e2a\u7f51\u53cb\u52a0\u4e86\u6211\u7684\u5fae\u4fe1\uff0c\u53cd\u9988\u4fe1\u606f\uff0c\u95ee\u6211\uff1a“\u5982\u679c\u8fdb\u884c WebFlux + Mongo \u7684\u6574\u5408\uff1f”\n<\/p>\n

\n\t\u4e8e\u662f\uff0c\u6211\u5c31\u7ed9\u4ed6\u5199\u4e86\u4e00\u4e2a demo\u3002\u4eca\u5929\u62bd\u4e2a\u65f6\u95f4\uff0c\u628a\u8fd9\u4e2a demo \u53d1\u51fa\u6765\uff0c\u5e0c\u671b\u80fd\u591f\u5e2e\u52a9\u5230\u66f4\u591a\u4eba\u3002\n<\/p>\n

\n\t\u9996\u5148\uff0c\u6211\u4eec\u53ef\u4ee5\u521b\u5efa\u4e00\u4e2a Maven \u9879\u76ee\uff0c\u5982\uff1awebflux-mongo\u3002\n<\/p>\n

\n\t\u7136\u540e\uff0cpom.xml \u914d\u7f6e\u6587\u4ef6\u7684\u5185\u5bb9\u5982\u4e0b\uff1a\n<\/p>\n

\r\n<properties>\r\n    <project.build.sourceEncoding>UTF-8<\/project.build.sourceEncoding>\r\n    <project.reporting.outputEncoding>UTF-8<\/project.reporting.outputEncoding>\r\n    <java.version>1.8<\/java.version>\r\n<\/properties>\r\n<dependencies>\r\n    <dependency>\r\n        <groupId>org.springframework.boot<\/groupId>\r\n        <artifactId>spring-boot-starter-webflux<\/artifactId>\r\n    <\/dependency>\r\n    <!-- Spring Boot \u54cd\u5e94\u5f0f MongoDB \u4f9d\u8d56 -->\r\n    <dependency>\r\n        <groupId>org.springframework.boot<\/groupId>\r\n        <artifactId>spring-boot-starter-data-mongodb-reactive<\/artifactId>\r\n    <\/dependency>\r\n<\/dependencies>\r\n<build>\r\n    <plugins>\r\n        <plugin>\r\n            <groupId>org.springframework.boot<\/groupId>\r\n            <artifactId>spring-boot-maven-plugin<\/artifactId>\r\n        <\/plugin>\r\n    <\/plugins>\r\n<\/build><\/pre>\n
\n\t\u7136\u540e\uff0c\u5728 application.yml \u914d\u7f6e Mongo \u7684\u8fde\u63a5\u4fe1\u606f\u3002\n<\/p>\n
\r\n#mongodb\u7684\u914d\u7f6e\r\nspring:\r\n  data:\r\n    mongodb:\r\n      host: 127.0.01\r\n      database: xttblog\r\n      port: 27017\r\n      username: xttblog\r\n      password: xttblog<\/pre>\n
\n\t\u7136\u540e\u662f\u4e00\u4e2a\u6587\u6863\u7c7b\uff1aXttblog\u3002\n<\/p>\n
\r\npublic class Xttblog implements Serializable {\r\n    private Long id;\r\n    private String url;\r\n    private String title;\r\n    private String author;\r\n    private String text;\r\n\/\/...\u7701\u7565get\/set\r\n}<\/pre>\n
\n\t\u7136\u540e\u662f XttblogRepository \u7c7b\u3002\n<\/p>\n
\r\n@Repository\r\npublic interface XttblogRepository extends \r\nReactiveMongoRepository<Xttblog, Long> {\r\n}<\/pre>\n
\n\t\u4e1a\u52a1 XttblogHandler \u7c7b\u3002\n<\/p>\n
\r\n@Component\r\npublic class XttblogHandler {\r\n    @Autowired\r\n    private XttblogRepository xttblogRepository;\r\n    public Mono<Xttblog> save(Xttblog xttblog) {\r\n        return xttblogRepository.save(xttblog);\r\n    }\r\n    public Flux<Xttblog> findAllXttblog() {\r\n        return xttblogRepository.findAll().cache();\r\n    }\r\n    public Mono<Xttblog> modifyXttblog(Xttblog xttblog) {\r\n        Mono<Xttblog> resultMono = xttblogRepository.save(xttblog);\r\n        return resultMono;\r\n    }\r\n    public Mono<Long> deleteXttblog(Long id) {\r\n        xttblogRepository.deleteById(id);\r\n        return Mono.create(monoSink -> monoSink.success(id));\r\n    }\r\n    public Mono<Xttblog> findXttblogById(Long id) {\r\n        \/\/ \u4ece MongoDB \u4e2d\u83b7\u53d6\u57ce\u5e02\u4fe1\u606f\r\n        Mono<Xttblog> xttblogMono = xttblogRepository.findById(id);\r\n        return xttblogMono;\r\n    }\r\n}<\/pre>\n
\n\t\u6700\u540e\u662f MongoController \u7c7b\u3002\n<\/p>\n
\r\npublic class MongoController {\r\n    @Autowired\r\n    private XttblogHandler xttblogHandler;\r\n    @GetMapping(value = "\/{id}")\r\n    public Mono<Xttblog> findXttblogById(@PathVariable("id") Long id) {\r\n        return xttblogHandler.findXttblogById(id);\r\n    }\r\n    @GetMapping()\r\n    public Flux<Xttblog> findAllXttblog() {\r\n        return xttblogHandler.findAllXttblog();\r\n    }\r\n    @PostMapping()\r\n    public Mono<Xttblog> saveXttblog(@RequestBody Xttblog xttblog) {\r\n        return xttblogHandler.save(xttblog);\r\n    }\r\n    @PutMapping()\r\n    public Mono<Xttblog> modifyXttblog(@RequestBody Xttblog city) {\r\n        return xttblogHandler.modifyXttblog(city);\r\n    }\r\n    @DeleteMapping(value = "\/{id}")\r\n    public Mono<Long> deleteXttblog(@PathVariable("id") Long id) {\r\n        return xttblogHandler.deleteXttblog(id);\r\n    }\r\n}<\/pre>\n
\n\t\u8fd0\u884c MongoAppliction\uff0c\u4ee3\u7801\u5982\u4e0b\uff1a\n<\/p>\n
\r\n@SpringBootApplication\r\npublic class MongoAppliction {\r\n    public static void main(String[] args) {\r\n        SpringApplication.run(MongoAppliction.class, args);\r\n    }\r\n}<\/pre>\n
\n\t\u81f3\u4e8e\uff0c\u8fd0\u884c\u6548\u679c\uff0c\u6211\u5c31\u4e0d\u8d34\u4e86\u3002\n<\/p>\n
\n\t\"WebFlux\n<\/p>\n
\n\t\u66f4\u591a\u5173\u4e8e WebFlux \u7684\u6559\u7a0b\u5185\u5bb9\uff0c\u8bf7\u9605\u8bfb\uff1aWebFlux \u6559\u7a0b<\/a>\u3002<\/p>\n
\"\u4e1a\u4f59\u8349\u516c\u4f17\u53f7\"\/<\/p>
\u6700\u540e\uff0c\u6b22\u8fce\u5173\u6ce8\u6211\u7684\u4e2a\u4eba\u5fae\u4fe1\u516c\u4f17\u53f7\uff1a\u4e1a\u4f59\u8349\uff08yyucao\uff09\uff01\u53ef\u52a0\u4f5c\u8005\u5fae\u4fe1\u53f7\uff1axttblog2<\/font>\u3002\u5907\u6ce8\uff1a\u201c1\u201d\uff0c\u6dfb\u52a0\u535a\u4e3b\u5fae\u4fe1\u62c9\u4f60\u8fdb\u5fae\u4fe1\u7fa4\u3002\u5907\u6ce8\u9519\u8bef\u4e0d\u4f1a\u540c\u610f\u597d\u53cb\u7533\u8bf7\u3002<\/b>\u518d\u6b21\u611f\u8c22\u60a8\u7684\u5173\u6ce8\uff01\u540e\u7eed\u6709\u7cbe\u5f69\u5185\u5bb9\u4f1a\u7b2c\u4e00\u65f6\u95f4\u53d1\u7ed9\u60a8\uff01\u539f\u521b\u6587\u7ae0\u6295\u7a3f\u8bf7\u53d1\u9001\u81f3532009913@qq.com\u90ae\u7bb1\u3002\u5546\u52a1\u5408\u4f5c\u4e5f\u53ef\u6dfb\u52a0\u4f5c\u8005\u5fae\u4fe1\u8fdb\u884c\u8054\u7cfb\uff01<\/p>
\u672c\u6587\u539f\u6587\u51fa\u5904\uff1a\u4e1a\u4f59\u8349<\/a>\uff1a » WebFlux + Mongo \u8fdb\u884c\u9879\u76ee\u6574\u5408\u5f00\u53d1<\/a><\/p>","protected":false},"excerpt":{"rendered":"
\u4e0d\u77e5\u4e0d\u89c9\uff0c\u9646\u9646\u7eed\u7eed\u5df2\u7ecf\u5199\u8fc7\u5f88\u591a\u5173\u4e8e WebFlux \u6559\u7a0b\u4e86\u3002\u4e0d\u6765\u4e0d\u7740\u6025\u8fd9\u5199\u8fd9\u4e00\u5f20\u7684\u3002\u4f46\u662f\u6700\u8fd1\u6709\u4e00\u4e2a\u7f51\u53cb\u52a0\u4e86\u6211\u7684 […]<\/p>\n","protected":false},"author":2,"featured_media":0,"comment_status":"closed","ping_status":"closed","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[5],"tags":[1774,1767,1578,1775,1701],"class_list":["post-3996","post","type-post","status-publish","format-standard","hentry","category-java","tag-mongoclient","tag-mongocollection","tag-mongodb","tag-mongoexception","tag-webflux"],"_links":{"self":[{"href":"https:\/\/www.xttblog.com\/index.php?rest_route=\/wp\/v2\/posts\/3996","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/www.xttblog.com\/index.php?rest_route=\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/www.xttblog.com\/index.php?rest_route=\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/www.xttblog.com\/index.php?rest_route=\/wp\/v2\/users\/2"}],"replies":[{"embeddable":true,"href":"https:\/\/www.xttblog.com\/index.php?rest_route=%2Fwp%2Fv2%2Fcomments&post=3996"}],"version-history":[{"count":1,"href":"https:\/\/www.xttblog.com\/index.php?rest_route=\/wp\/v2\/posts\/3996\/revisions"}],"predecessor-version":[{"id":3997,"href":"https:\/\/www.xttblog.com\/index.php?rest_route=\/wp\/v2\/posts\/3996\/revisions\/3997"}],"wp:attachment":[{"href":"https:\/\/www.xttblog.com\/index.php?rest_route=%2Fwp%2Fv2%2Fmedia&parent=3996"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/www.xttblog.com\/index.php?rest_route=%2Fwp%2Fv2%2Fcategories&post=3996"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/www.xttblog.com\/index.php?rest_route=%2Fwp%2Fv2%2Ftags&post=3996"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}