spring-boot对各种插件的支持是非常方便的,对我们的程序开发带来了非常大的便利. 之前整合各种框架,配置文件都得弄老半天,现在只需要引入插件的支持,就可以实现即插即用的效果.
鉴于网上对message的文章已经很多了,这里我就选取kafka来讲述下.
首先我的一贯主张是想要了解一个框架或插件,最直接的方式就是去看官方文档.这样会避免我们走很多弯路.
-
在spring-boot的官方文档中看到kafka的插件依赖,引入到pom文件中
-
在配置文件中增加参数配置
-
编写消息发送代码
-
编写消息接收代码
-
更多关于kafka的配置请参考
下面我就参照官方的例子来搭建环境 由于之前的spring-boot文章是采用1.4.3稳定版本进行编写的,现在官方的稳定版本为1.5.3,故本示例切换到当前的稳定版本进行编写.
本示例代码在my-springboot-1的基础上进行编写
-
引入pom的依赖
-
增加kafka的简单配置
-
编写发送消息代码
-
编写接收消息代码
-
在controller调用
-
启动项目,在浏览器输入 http://127.0.0.1:666/kafka/send?topic=test&msg=%E4%B8%96%E7%95%8C%E4%BD%A0%E5%A5%BD
-
进行消息的多终端接收 将项目 my-springboot-13 拷贝一份 为 my-springboot-13-2 修改配置
(注意修改 spring.kafka.consumer.group-id=myGroup2 这个以后再讲解)
再启动项目 my-springboot-13-2
重复第6步,查看控制台两个项目都收到了消息
项目源代码见 my-springboot-13 和 my-springboot-13-2