请例举比较好用的MQ中间件

时间: 2023-05-23 16:04:59 浏览: 119

MQ连接例子

根据提供的文件信息，本文将详细解释MQ通道连接方式以及如何使用Java进行MQ消息队列的发送与接收。MQ（Message Queue）是一种应用程序间通过读写队列传递消息来进行通信的方法，广泛应用于分布式系统中实现异步处理、负载均衡等功能。 ### MQ通道连接方式 MQ通道是MQ中的一个重要组成部分，它负责在不同的队列管理器之间传输消息。在配置MQ通道时，需要指定通道类型（如Server Connection Channel、Client Connection Channel等），并设置相应的属性，例如源队列管理器和目标队列管理器的信息。 #### Java连接MQ的例子在提供的代码示例中，通过Java实现了与MQ服务器的连接，并完成消息的发送与接收功能。下面将详细介绍这段代码的关键部分： 1. **初始化日志记录器**： ```java private static Logger logger = Logger.getLogger(MessageQueueService.class); ``` 使用Apache Log4j库来记录日志，便于后续跟踪问题。 2. **定义MQ环境参数**： ```java private String hostname = "192.168.0.117"; private String channel = "CHL.SVRCONN"; private String queueManager = "QM_SERVER"; private String sendQueue = "OMP.QRMT"; private String recvQueue = "OMP.QLCA"; private int port = 24100; private int ccsid = 1381; private int failedCount = 5; private int intervalTime = 1000; ``` - `hostname`：MQ服务器的IP地址。 - `channel`：使用的通道名称。 - `queueManager`：队列管理器名称。 - `sendQueue` 和 `recvQueue`：分别表示发送和接收队列的名称。 - `port`：MQ服务器的端口号。 - `ccsid`：字符集标识符。 - `failedCount` 和 `intervalTime`：重试机制的相关参数。 3. **构造函数**：在构造函数中设置了MQ环境变量： ```java public MessageQueueService() { MQEnvironment.hostname = hostname; MQEnvironment.channel = channel; MQEnvironment.CCSID = ccsid; MQEnvironment.port = port; } ``` 4. **发送消息**： ```java public String send(String sendMsg) throws Exception { // 创建队列管理器对象 MQQueueManager qManager = new MQQueueManager(queueManager); // 打开发送队列 MQQueue sQueue = qManager.accessQueue(sendQueue, openOptions); // 设置发送消息选项 MQPutMessageOptions pmo = new MQPutMessageOptions(); // 创建并写入消息 MQMessage send = new MQMessage(); send.write(sendMsg.getBytes()); // 发送消息 sQueue.put(send, pmo); // 关闭队列 sQueue.close(); } ``` - `openOptions` 表示打开队列的方式，包括输出模式和失败时的行为。 - `put` 方法用于发送消息。 5. **接收消息**： ```java // 打开接收队列 openOptions = MQC.MQOO_INQUIRE + MQC.MQOO_FAIL_IF_QUIESCING + MQC.MQOO_INPUT_SHARED; MQQueue rQueue = qManager.accessQueue(recvQueue, openOptions); // 设置接收消息选项 MQGetMessageOptions getOptions = new MQGetMessageOptions(); getOptions.options = MQC.MQGMO_WAIT; getOptions.waitInterval = intervalTime; // 创建接收消息对象 MQMessage recvMsg = new MQMessage(); recvMsg.messageId = send.messageId; // 清除发送消息 send.clearMessage(); // 接收消息 boolean received = false; int fetchCount = 0; while (!received) { try { fetchCount++; rQueue.get(recvMsg, getOptions); //logger.debug("the " + fetchCount + " time fetch message!"); } catch (MQException e) { if (e.completionCode == MQC.MQCC_FAILED && e.reason == MQC.MQRC_NO_MSG_AVAILABLE) { // 没有可用消息时等待重试 Thread.sleep(intervalTime); } else { throw e; } } } ``` - `get` 方法用于接收消息，其中`MQGMO_WAIT`表示如果当前没有消息，则等待直到消息到达或超时。 - 使用`messageId`匹配发送和接收的消息。通过上述分析可以看出，该Java程序实现了基本的MQ消息发送和接收功能。需要注意的是，实际应用中可能还需要处理更多的异常情况，并进行更加完善的错误处理和日志记录。此外，还可以考虑添加消息确认机制以确保消息被正确处理。

A：以下是一些比较好用的MQ中间件： - Apache Kafka：具有高吞吐量、低延迟、可伸缩性和容错性等特点，在处理大规模数据流时表现突出。 - RabbitMQ：基于AMQP协议，可以处理大量的消息和交换机类型，还支持插件和多种客户端语言。 - ActiveMQ：支持JMS协议和多种传输协议，如TCP、SSL、NIO和UDP等，是一个开源的分布式消息中间件。 - RocketMQ：阿里巴巴开源的分布式消息中间件，能够满足海量数据的高效传输和可靠消费，具有容错性和高可用性。 - Redis消息队列：基于Redis内存数据库开发的消息中间件，具有高速、高效、消息持久化等特点，适合数据量不是很大的场景。

阅读全文

请例举比较好用的MQ中间件

相关推荐

MQ中间件学习

微软MSMQ中间件示例程序

IBM MQ中间件

IBM MQ中间件培训教材

Rocket MQ 消息中间件

mq消息中间件.rar

MQ消息中间件介绍.emmx

MQ消息中间件教程pdf新手

Java监控WebSphere MQ 7.5中间件信息

MQ消息中间件个人总结面试题集

关于IBM MQ商业消息中间件

ActivityMQ消息中间件的入门Demo.zip

一个基于IPFS的全球分布式文件系统，也是一个简单的MQ中间件，可用于直播本地推流，全球实时同步，多区域内网融合等

WebSphere_MQ消息中间件故障定位分析和排除

Java 消息中间件MQ面试题

MQ 介绍 消息队列 消息中间件

消息中间件及WebSphere MQ入门

MQ——从队列到消息中间件

MQ消息中间件之RabbitMQ以及整合SpringBoot2.x实战教程

最新推荐

AutoSAR规范中通信中间件服务软件规格说明书，详细介绍基于SOMEIP，DDS等通信中间件符合AutoSAR规范的基本需求

常用中间件安装部署手册

史上最全数据库中间件详解

操作系统&中间件故障处理指导手册

ASP.NET Core自定义中间件如何读取Request.Body与Response.Body的内容详解

黑板风格计算机毕业答辩PPT模板下载

管理建模和仿真的文件

提升点阵式液晶显示屏效率技术

在SoC芯片的射频测试中，ATE设备通常如何执行系统级测试以保证芯片量产的质量和性能一致？

CodeSandbox实现ListView快速创建指南

MQ 介绍消息队列消息中间件