C# 连接ActiveMQ(避坑指南)

  • Post author:
  • Post category:其他


最近公司的一个项目要使用ActiveMQ,客户端使用C#,.NET Framework4.7.2。

在网上找了教程,引入了两个包分别是:Apache.NMS(v2.0.0) 和 Apache.NMS.ActiveMQ(v1.8.0)

连接ActiveMQ的代码片段如下:

using System;
using Apache.NMS;
using Apache.NMS.ActiveMQ;
using Apache.NMS.Util;
....  
Uri connecturi = new Uri("activemq:tcp://192.168.1.139:31616");
IConnectionFactory factory = new ConnectionFactory(connecturi);
using (IConnection connection = factory.CreateConnection())

运行时就报错:

System.TypeLoadException: ‘Method ‘CreateConnectionAsync’ in type ‘Apache.NMS.ActiveMQ.ConnectionFactory’ from assembly ‘Apache.NMS.ActiveMQ, Version=1.8.0.0, Culture=neutral, PublicKeyToken=82756feee3957618′ does not have an implementation.’

在网上找了很多资料都没有解决,后来偶然试了一下,不引入上述两个包,引入Apache.NMS.ActiveMQ.NetCore,程序执行OK了。

又试着建立了一个.NET 5.0的项目,这里只要引入Apache.NMS.ActiveMQ(v1.8.0)即可,不需要引入Apache.NMS(v2.0.0)。

希望对大家有帮助



版权声明:本文为weixin_39796553原创文章,遵循 CC 4.0 BY-SA 版权协议,转载请附上原文出处链接和本声明。