主要观点总结
本文主要介绍了FolkMQ作为一个“纯血国产”消息中间件的特点和优势,包括其多种部署方式、内嵌版的好处、如何集成到不同项目中,以及具体的配置和使用方法。文章还提供了示例代码和配置文件,以帮助读者更好地理解和使用FolkMQ。
关键观点总结
关键观点1: FolkMQ是一个消息中间件,支持多种部署方式
FolkMQ提供了内嵌、单机、集群等多种部署方式,适应不同项目需求。
关键观点2: 内嵌版 FolkMQ 带来了方便
内嵌版FolkMQ相当于H2或SQLite数据库,为小项目或特殊需求提供了方便。它与单机版或集群版功能一致,但体积只有7Mb,非常小巧。
关键观点3: 如何集成 FolkMQ 到项目中
集成FolkMQ到项目中需要引入两个包,添加一个配置类和一个配置文件。通过简单的步骤,就可以实现消息中间件的功能。
关键观点4: FolkMQ的使用效果
通过示例代码和配置文件的说明,读者可以了解如何在项目中实际使用FolkMQ,包括启动、配置、测试等步骤。
正文
<dependency>
<groupId>org.noeargroupId>
<artifactId>solon.web.servlet.jakartaartifactId>
<version>2.8.3version>
dependency>
<dependency>
<groupId>org.noeargroupId>
<artifactId>folkmq-broker-embeddedartifactId>
<version>1.7.1version>
dependency>
b) 添加一个配置类 FolkMqConfig,就集成好了
专门安排它一个包名“folkmq”,可以缩小 solon 的扫描范围。因为 solon 也是个容器型的框架嘛(只是比较小巧)。
package demoapp.folkmq;
@Configuration
publicclass 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