首页 > 其他分享 > FolkMQ v1.5.1 发布(“新式” 国产消息中间件)

FolkMQ v1.5.1 发布(“新式” 国产消息中间件)

时间:2024-05-28 09:04:18浏览次数:29  
标签:demo MqMessage FolkMQ topic client v1.5 消息 消息中间件 folkmq

FolkMQ 是个“新式”的消息中间件。强调:“小而巧”、“简而强”。

功能简表

角色 功能
生产者(客户端) 发布普通消息、Qos0消息、定时消息、顺序消息、可过期消息、事务消息、广播消息
消费者(客户端) 订阅、取消订阅。消费-ACK(自动、手动)
服务端 发布-Confirm、订阅-Confirm、取消订阅-Confirm、派发-Retry、派发-Delayed

客户端语言支持

Java、Python、JavaScript(支持 node.js 后端,web 前端)

传输协议支持

tcp、udp、websocket、kcp

部署支持

可内嵌(依赖包为 200Kb+),可单机,可集群(部署包为 10Mb)。

本次更新

  • 新增 广播消息(给生产者添加广播模式)
  • 添加 控制台“强制清空”消息的操作
  • 添加 "fokmq:ws" 适配 websocket 子协议验证(避免乱连)
  • 添加 "server-broker" 控制台的集群节点面板添加“内存用率”查看
  • 优化 异步消息生产端的内存控制
  • 优化 客户端锁处理,默认无锁改为顺序锁
  • sokcet.d 升为 2.5.1

面向简单编程

1) 启动服务

docker run -p 18602:18602 -p 8602:8602 noearorg/folkmq-server:1.5.1

2) 编写程序

  • 引入一个小依赖
<dependency>
    <groupId>org.noear</groupId>
    <artifactId>folkmq-transport-netty</artifactId>
    <version>1.5.1</version>
</dependency>
  • 写程序喽
public class ClientDemo {
    public static void main(String[] args) throws Exception {
        //创建客户端,并连接
        MqClient client = FolkMQ.createClient("folkmq://127.0.0.1:18602")
                                .nameAs("demoapp")
                                .connect();

        //订阅主题
        client.subscribe("demo.topic", message -> {
            System.out.println(message);
        });

        //发布普通消息
        client.publish("demo.topic", new MqMessage("helloworld!"));
        //发布Qos0消息
        client.publish("demo.topic", new MqMessage("helloworld!").qos(0));
        //发布顺序消息
        client.publish("demo.topic", new MqMessage("helloworld!").sequence(true));
        //发布广播消息
        client.publish("demo.topic", new MqMessage("helloworld!").broadcast(true));
        //发布定时消息(或延时消息)
        client.publish("demo.topic", new MqMessage("helloworld!").scheduled(Datetime.Now().addDay(10)));
        //......等
    }
}

代码仓库

官网

标签:demo,MqMessage,FolkMQ,topic,client,v1.5,消息,消息中间件,folkmq
From: https://www.cnblogs.com/noear/p/18217025

相关文章

  • PC方格音乐v1.5.4无损音乐播放 – 一款免费无损音乐播放器
    软件介绍方格音乐(魔音Morin电脑版)是一款免费无损音乐播放器及付费歌曲无损音乐免费下载软件.方格音乐播放器采用简洁的风格设计,可以免费在线试听及下载付费歌曲,版权音乐,无损音质歌曲.方格音乐电脑版免费听歌神器支持歌曲解析功能,第三方歌单导入,歌词频谱功能,下载音乐时......
  • FolkMq v1.4.6 发布(可以内嵌的消息中间件)
    功能简表角色功能生产者(客户端)发布消息、定时消息(或叫延时)、顺序消息、可过期消息、事务消息。支持Qos0、Qos1消费者(客户端)订阅、取消订阅。消费-ACK(自动、手动)服务端发布-Confirm、订阅-Confirm、取消订阅-Confirm、派发-Retry、派发-Delayed客......
  • 一个简单的开源消息中间件 FolkMQ v1.4.2 发布
    功能简表角色功能生产者(客户端)发布消息、定时消息(或叫延时)、顺序消息、可过期消息、事务消息。支持Qos0、Qos1消费者(客户端)订阅、取消订阅。消费-ACK(自动、手动)服务端发布-Confirm、订阅-Confirm、取消订阅-Confirm、派发-Retry、派发-Delayed本......
  • 消息中间件RabbitMQ_RabbitMQ集群搭建8
    一、集群搭建概述摘要:实际生产应用中都会采用消息队列的集群方案,如果选择RabbitMQ那么有必要了解下它的集群方案原理一般来说,如果只是为了学习RabbitMQ或者验证业务工程的正确性那么在本地环境或者测试环境上使用其单实例部署就可以了,但是出于MQ中间件本身的可靠性、并发性......
  • 消息中间件RabbitMQ_RabbitMQ应用问题7
    一、RabbitMQ应用问题1、消息可靠性保障消息补偿机制2、消息幂等性保障乐观锁解决方案 二、消息可靠性保障需求: 100%确保消息发送成功 消息补偿:三、消息幂等性保障幂等性指一次和多次请求某一个资源,对于资源本身应该具有同样的结果。也就是说,其......
  • 消息中间件RabbitMQ_RabbitMQ高级特性6
    一、RabbitMQ高级特性消息可靠性投递ConsumerACK消费端限流TTL死信队列延迟队列日志与监控消息可靠性分析与追踪管理二、消息的可靠投递1、模式在使用RabbitMQ的时候,作为消息发送方希望杜绝任何消息丢失或者投递失败场景。RabbitMQ为我们提供了两种方式......
  • 消息中间件RabbitMQ_RabbitMQ的工作模式4
    一、Workqueues工作队列模式1、模式说明WorkQueues:与入门程序的简单模式相比,多了一个或一些消费端,多个消费端共同消费同一个队列中的消息。应用场景:对于任务过重或任务较多情况使用工作队列可以提高任务处理的速度。2、代码编写WorkQueues与入门程序的简......
  • 消息中间件RabbitMQ_RabbitMQ快速入门3
    一、入门程序需求:使用简单模式完成消息传递步骤:1.创建工程(生成者、消费者)2.分别添加依赖3.编写生产者发送消息4.编写消费者接收消息 二、小结上述的入门案例中其实使用的是如下的简单模式:在上图的模型中,有以下概念:P:生产者,也就是要发送消......
  • 消息中间件RabbitMQ_RabbitMQ的安装和配置2
    RabbitMQ官方地址:http://www.rabbitmq.com/安装文档:资料/软件/安装RabbitMQ.md注意:请使用资料里提供的CentOS-7-x86_64-DVD-1810.iso安装虚拟机. 一、安装依赖环境在线安装依赖环境:yuminstallbuild-essentialopensslopenssl-develunixODBCunixODBC-develmake......
  • 聊聊消息中间件
    消息中间件,广泛应用于分布式系统的架构设计之中。一提到业务解耦、流量削峰的技术选型,很容易就想到,是时候该消息中间件上场了。我想聊聊两个问题。消息中间件从设计来讲,应该有哪些组件?消息中间件的使用中,常碰到的问题有哪些?又该如何解决?消息中间件的设计架构消息中间件的架构......