本文主要是介绍把 FolkMQ 内嵌到 SpringBoot2 项目里(比如 “诺依” 啊),希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!
FolkMQ (消息中间件)支持内嵌、单机、集群、多重集群等多种部署方式。
- 内嵌版,就相当于 H2 或 SQLite 数据库一样。给一些小项目(或者特别需求)带来了方便。
- 大项目,则可以使用独立部署的 “单机版” 或 “集群版”
内嵌个消息中间件,体积会不会太大啦?!!不会,单机版只有9Mb,内嵌版才7Mb。超级小的啦!
1、了解 FolkMQ 内嵌版
FolkMQ 内嵌版(带 Web 控制台界面的),体积增加 7Mb,就可以附加完整消息中间件的能力喽。比如你在用 “诺依” 开发个小项目,需要消息中间件,但是又不想独立部署。这就很适合呢!
- 内嵌版与单机板,功能一模一样
- 控制台界面是基于 Solon 框架开发的,非常小巧。(可以用宿主项目的端口,也可以独立端口)
- 支持内嵌到 jFinal,Solon,SpringBoot2,SpringBoot3,Vert.X 等框架里
说起来 Solon 真是中间件的控制台良配,又小又强又可以内嵌。太爱了!
2、怎么集成呐?
此例,我们的控制台使用宿主项目的 HTTP 端口。所以需要与 SpringBoot2 的 Servlet 能力对接。
- a) 引入两个包
依赖包 | 说明 |
---|---|
solon.web.servlet | 负责与 SpringBoot2 的 Servlet 能力对接,为控制台提供支持 |
folkmq-embedded | 我们的主角,FolkMQ 内嵌版 |
<dependency><groupId>org.noear</groupId><artifactId>solon.web.servlet</artifactId><version>2.8.3</version>
</dependency><dependency><groupId>org.noear</groupId><artifactId>folkmq-embedded</artifactId><version>1.5.2</version>
</dependency>
- b) 添加一个配置类 FolkMqConfig,就集成好了
专门安排它一个包名“folkmq”,可以缩小 solon 的扫描范围。因为 solon 也是个容器型的框架嘛(只是比较小巧)。
package demoapp.folkmq;@Configuration
public class FolkMqConfig {@PostConstructpublic void start() {//启动 solonSolon.start(FolkMqConfig.class, new String[]{});}@PreDestroypublic void stop() {if (Solon.app() != null) {//停止 solon(根据配置,可支持两段式安全停止)Solon.stopBlock(false, Solon.cfg().stopDelay());}}@Beanpublic FilterRegistrationBean folkmqAdmin(){//通过 Servlet Filter 实现 http 能力对接FilterRegistrationBean<SolonServletFilter> filter = new FilterRegistrationBean<>();filter.setName("SolonFilter");filter.addUrlPatterns("/folkmq/*");filter.setFilter(new SolonServletFilter());return filter;}
}
- c) 然后,再加个配置文件 folkmq.yml 来控制它
更多的配置,可以见官网的:配置参考
# 如果使用 servelt 则需要与 sprongboot 相同的等口
server.port: 8080# 避免与其它 token 冲突(folkmq 控制台的 token)
server.session.state.jwt.name: FOLKMQ-TOKEN#控制台账号密码
folkmq:admin: admin
3、看看内嵌的效果
项目运行后,可以通过 “/folkmq/” 来访问控制台。
4、然后测试下
消息端口,是控制台端口 + 10000。测试,我们就发10条普通消息试试。
public class ClientTest {public static void main(String[] args) throws Exception {MqClient client = FolkMQ.createClient("folkmq://localhost:18080").nameAs("demoapp").connect();//订阅消息client.subscribe("demo.topic", message -> {System.out.println(message);});for (int i = 0; i < 10; i++) {//发布消息client.publish("demo.topic", new MqMessage("hello" + i));}}
}
测试效果:
5、完整的示例代码
https://gitee.com/noear/folkmq-embedded-examples/tree/main/folkmq-embedded-springboot2
这篇关于把 FolkMQ 内嵌到 SpringBoot2 项目里(比如 “诺依” 啊)的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!