JAVA对接MSMQ消息队列服务,现在官网已经无法下载jar文件和dll文件,资源哪里还可以下载
5条回答 默认 最新
关注 引自免费微信小程序:皆我百晓生
由于Microsoft官方不再提供Java与MSMQ的消息队列连接器(JMS Provider)的下载,你可以尝试从第三方库或者历史版本中获取所需的资源。一个常用的替代方案是Apache Qpid JMS,它支持与MSMQ进行交互。
首先,你需要在项目中添加Apache Qpid JMS的依赖。如果你使用的是Maven,可以在pom.xml文件中添加以下依赖:
<dependencies> <dependency> <groupId>org.apache.qpid</groupId> <artifactId>qpid-jms-client</artifactId> <version>1.34.0</version> </dependency> </dependencies>
这个版本号可能会有更新,确保检查最新的版本信息。
接着,你可以按照以下步骤配置并使用Apache Qpid JMS连接到MSMQ:
-
创建一个连接工厂:
import org.apache.qpid.jms.JmsConnectionFactory; String connectionURI = "amqp://localhost:5672"; JmsConnectionFactory factory = new JmsConnectionFactory(connectionURI);
-
创建连接:
Connection connection = factory.createConnection(); connection.start();
-
创建会话:
Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
-
创建目的地(queue或topic):
Destination destination = session.createQueue("your_queue_name");
-
创建生产者和消费者:
MessageProducer producer = session.createProducer(destination); MessageConsumer consumer = session.createConsumer(destination);
-
发送消息:
TextMessage message = session.createTextMessage("Hello, MSMQ!"); producer.send(message);
-
接收消息:
Message receivedMessage = consumer.receive(5000); // 等待5秒后返回消息,若无消息则返回null if (receivedMessage instanceof TextMessage) { System.out.println(((TextMessage) receivedMessage).getText()); }
-
关闭资源:
consumer.close(); session.close(); connection.close();
注意:上述代码示例中的
connectionURI
应该指向你的MSMQ服务器地址。由于MSMQ通常不直接通过AMQP协议通信,所以这里的URI实际上是一个错误的引导,但Apache Qpid JMS可以处理这种情况,并将请求转发到正确的MSMQ服务。如果你仍然需要原始的MSMQ Java连接器,可能需要寻找一些旧版的软件包或者在互联网上搜索其他用户的分享。然而,强烈建议使用像Apache Qpid JMS这样的现代、活跃维护的库来替换对MSMQ的支持。
解决 无用评论 打赏 举报 编辑记录-
悬赏问题
- ¥15 软件供应链安全是跟可靠性有关还是跟安全性有关?
- ¥15 电脑蓝屏logfilessrtsrttrail问题
- ¥20 关于wordpress建站遇到的问题!(语言-php)(相关搜索:云服务器)
- ¥15 【求职】怎么找到一个周围人素质都很高不会欺负他人,并且未来月薪能够达到一万以上(技术岗)的工作?希望可以收到写有具体,可靠,已经实践过了的路径的回答?
- ¥15 Java+vue部署版本反编译
- ¥100 对反编译和ai熟悉的开发者。
- ¥15 带序列特征的多输出预测模型
- ¥15 Python 如何安装 distutils模块
- ¥15 关于#网络#的问题:网络是从楼上引一根网线下来,接了2台傻瓜交换机,也更换了ip还是不行
- ¥15 资源泄露软件闪退怎么解决?