可以把 FolkMQ 内嵌到 SpringBoot3 项目里(可内嵌的消息中间件,纯血国产)

folkmq,springboot3 · 浏览次数 : 0

小编点评

## SpringBoot3FolkMQ:纯血国产消息中间件 ### 1. 介绍 **SpringBoot3FolkMQ** 是一个 **纯血国产** 的消息中间件,支持内嵌、单机、集群、多重集群等多种部署方式。相较于 FolkMQ 原生版,它更加轻量级,体积仅为 7Mb。 ### 2. 内嵌版与单机版对比 * 内嵌版类似于 H2 或 SQLite 数据库,体积增加 7Mb,即可附加完整消息中间件的能力。 * 单机版与大项目都可以使用,体积不会过大。 ### 3. 集成步骤 #### a. 引入依赖 引入以下两个依赖: ```xml org.noear solon.web.servlet.jakarta 2.8.3 org.noear folkmq-embedded 1.7.1 ``` #### b. 添加配置类 创建一个名为 `FolkMqConfig` 的配置类,专门用于集成 FolkMQ 内嵌版: ```java @Configuration public class FolkMqConfig { @PostConstruct public void start() { // 启动 Solon Solon.start(FolkMqConfig.class, new String[]{}); } @PreDestroy public void stop() { if (Solon.app() != null) { // 停止 Solon(根据配置,可支持两段式安全停止) Solon.stopBlock(false, Solon.cfg().stopDelay()); } } @Bean public FilterRegistrationBean folkmqAdmin() { // 通过 Servlet Filter 实现 http 能力对接 FilterRegistrationBean filter = new FilterRegistrationBean<>(); filter.setName("SolonFilter"); filter.addUrlPatterns("/folkmq/*"); filter.setFilter(new SolonServletFilter()); return filter; } } ``` #### c. 配置文件 添加一个名为 `folkmq.yml` 的配置文件,用于控制 FolkMQ 的更多配置: ```yaml server: port: 8080 server: session: state: jwt: name: FOLKMQ-TOKEN topic: - demo.topic message: - name: demo.message value: "hello" properties: from: "demoapp" publish: - name: demo.publisher address: "folkmq://localhost:18080/demotopic" key: "FOLKMQ-TOKEN" ``` ### 4. 内嵌效果与测试 项目运行后,可以通过 `/folkmq/` 访问控制台。测试时,发送 10 条普通消息: ```java 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)); } } } ``` 测试结果: ``` hello0 hello1 hello2 hello3 hello4 hello5 hello6 hello7 hello8 hello9 ``` ### 5. 完整示例代码 查看 [GitHub](https://gitee.com/noear/folkmq-embedded-examples/tree/main/folkmq-embedded-springboot3) 获取完整的示例代码。 通过集成 SpringBoot3FolkMQ,你可以轻松地将消息中间件内嵌到项目中,满足不同规模项目的需求。

正文

之前发了《把 FolkMQ 内嵌到 SpringBoot2 项目里(比如 “诺依” 啊)》。有人说都淘态了,有什么好内嵌的。。。所以再发个 SpringBoot3


FolkMQ 是一个 “纯血国产” 的消息中间件。支持内嵌、单机、集群、多重集群等多种部署方式。

  • 内嵌版,就相当于 H2 或 SQLite 数据库一样。给一些小项目(或者特别需求)带来了方便。
  • 大项目,则可以使用独立部署的 “单机版” 或 “集群版”

内嵌个消息中间件,体积会不会太大啦?!!不会,才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.jakarta</artifactId>
    <version>2.8.3</version>
</dependency>

<dependency>
    <groupId>org.noear</groupId>
    <artifactId>folkmq-broker-embedded</artifactId>
    <version>1.7.1</version>
</dependency>
  • b) 添加一个配置类 FolkMqConfig,就集成好了

专门安排它一个包名“folkmq”,可以缩小 solon 的扫描范围。因为 solon 也是个容器型的框架嘛(只是比较小巧)。

package demoapp.folkmq;

@Configuration
public class FolkMqConfig {
    @PostConstruct
    public void start() {
        //启动 solon
        Solon.start(FolkMqConfig.class, new String[]{});
    }

    @PreDestroy
    public void stop() {
        if (Solon.app() != null) {
            //停止 solon(根据配置,可支持两段式安全停止)
            Solon.stopBlock(false, Solon.cfg().stopDelay());
        }
    }

    @Bean
    public 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 冲突
server.session.state.jwt.name: FOLKMQ-TOKEN

# 消息控制台账号密码
folkmq.admin: admin
# 消息传输协议(tcp 或 ws)
folkmq.schema: tcp
# 消息传输端口(默认为 server.port + 10000)
folkmq.transport.port: 0

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-springboot3

与可以把 FolkMQ 内嵌到 SpringBoot3 项目里(可内嵌的消息中间件,纯血国产)相似的内容:

可以把 FolkMQ 内嵌到 SpringBoot3 项目里(可内嵌的消息中间件,纯血国产)

支持Qos0、定时、过期、顺序、广播、事务、二进制等消息特性。有确认、重试、延时等机制。可嵌入、单机、集群等部署。

FolkMq v1.4.6 发布(可以内嵌的消息中间件)

功能简表 角色 功能 生产者(客户端) 发布消息、定时消息(或叫延时)、顺序消息、可过期消息、事务消息。支持 Qos0、Qos1 消费者(客户端) 订阅、取消订阅。消费-ACK(自动、手动) 服务端 发布-Confirm、订阅-Confirm、取消订阅-Confirm、派发-Retry、派发-Del

Axure 单键快捷键

如果怕误操作,可以把它关闭

【Azure Developer】.Net 简单示例 "文字动图显示" Typing to SVG

问题描述 看见一个有趣的页面,可以把输入的文字信息,直接输出SVG图片,还可以实现动图模式。 示例URL: https://readme-typing-svg.demolab.com/?font=Fira+Code&pause=1000&color=F7F7F7&background=233911F

[转帖]使用 Dumpling 导出数据

16 Contributors 使用数据导出工具 Dumpling,你可以把存储在 TiDB 或 MySQL 中的数据导出为 SQL 或 CSV 格式,用于逻辑全量备份。Dumpling 也支持将数据导出到 Amazon S3 中。 要快速了解 Dumpling 的基本功能,建议先观看下面的培训视频

redux原理分享

概述 一个状态管理工具 Store:保存数据的地方,你可以把它看成一个容器,整个应用只能有一个 Store。 State:包含所有数据,如果想得到某个时点的数据,就要对 Store 生成快照,这种时点的数据集合,就叫做 State。 Action:Action 就是 View 发出的通知,表示 St

Arrays.asList():使用指南

Arrays.asList() 是一个 Java 的静态方法,它可以把一个数组或者多个参数转换成一个 List 集合。这个方法可以作为数组和集合之间的桥梁,方便我们使用集合的一些方法和特性。本文将介绍 Arrays.asList() 的语法、应用场景、坑点和总结。 语法 应用场景 坑点 总结 语法

如何正确使用:has和:nth-last-child

我们可以用CSS检查,以了解一组元素的数量是否小于或等于一个数字。例如,一个拥有三个或更多子项的`grid`。你可能会想,为什么需要这样做呢?在某些情况下,一个组件或一个布局可能会根据子元素的数量而改变。 这在CSS中已经存在很多年了,但现在通过CSS `:has`,它变得更加强大。我们可以把`nt

[转帖]reposync

0. 简介 reposync 命令简单来说就是可以把指定外网源(repo id)的包同步到本地文件中 1. 安装 reposync 命令 [root@V10SP1-1 ~]# yum install -y dnf-plugins-core 2. 常用选项以及参数 选项含义 -c [file] 指定配

[转帖]XCopy命令实现增量备份

https://www.cnblogs.com/pachongshangdexuebi/p/5051977.html xcopy XCOPY是COPY的扩展,可以把指定的目录连文件和目录结构一并拷贝,但不能拷贝系统文件;使用时源盘符、源目标路径名、源文件名至少指定一个;选用/S时对源目录下及其子目录