我想得到ActiveMq的登录用户列表,和离线信息,有没有办法,我在ActiveMq的bat运行服务器中看到了用户离线消息,我怎么通过ActiveMq的DLL监听他们的这些离线信息。
我用IConnection中的ExceptionListener事件不好用,什么也接不到也不触发,不知道这兄弟是做什么的。
C# 怎么监听ActiveMq连接异常?
- 写回答
- 好问题 0 提建议
- 追加酬金
- 关注问题
- 邀请回答
-
1条回答
- ChatGPTᴼᴾᴱᴺᴬᴵ 2023-02-27 20:36关注
该回答引用ChatGPT
您可以使用NMS API来监听ActiveMQ连接异常和获取登录用户列表等信息。
以下是一个示例代码片段,演示如何使用NMS API来监听连接异常:
using Apache.NMS; using Apache.NMS.ActiveMQ; IConnectionFactory factory = new ConnectionFactory("tcp://localhost:61616"); IConnection connection = factory.CreateConnection(); connection.ExceptionListener += new ExceptionListener(OnException); private void OnException(Exception ex) { Console.WriteLine("Exception occurred: " + ex.Message); }
在这个示例中,我们首先使用NMS API创建了一个连接工厂对象,并将其传递给ConnectionFacotry构造函数中,指定了ActiveMQ Broker的地址。然后我们使用连接工厂对象创建了一个连接对象,并通过连接对象的ExceptionListener事件注册了一个异常监听器。
如果连接出现任何异常,OnException方法将被调用,并将异常对象作为参数传递。您可以在这个方法中执行任何您需要的操作,例如记录异常信息或者尝试重新连接等。
要获取登录用户列表,您可以使用ActiveMQ的JMX管理API。您需要在ActiveMQ Broker中启用JMX,并使用JMX API连接到Broker并查询相关信息。以下是一个示例代码片段,演示如何使用JMX API获取登录用户列表:
using System; using Apache.NMS.ActiveMQ; using Apache.NMS.ActiveMQ.Transport; using Apache.NMS.ActiveMQ.Transport.Tcp; using Apache.NMS.Util; using Apache.NMS.ActiveMQ.Transport.Transport; Uri jmxUri = new Uri("service:jmx:rmi:///jndi/rmi://localhost:1099/jmxrmi"); TransportConnection transport = new TcpTransportFactory().CreateTransport(jmxUri) as TransportConnection; transport.Start(); IMBeanServerConnection connection = new MBeanServerConnectionFactory(jmxUri).CreateMBeanServerConnection(); ObjectName[] consumers = connection.QueryNames(new ObjectName("org.apache.activemq:type=Broker,brokerName=localhost,connector=clientConnectors,connectorName=openwire"), null); foreach (ObjectName consumer in consumers) { ObjectName[] subscriptions = connection.QueryNames(new ObjectName(consumer.CanonicalName + ",destinationType=Queue,destinationName=*"), null); foreach (ObjectName subscription in subscriptions) { string user = (string)connection.GetAttribute(subscription, "UserName"); Console.WriteLine("User: " + user); } }
在这个示例中,我们首先构造了一个JMX URI对象,指定了JMX服务的地址和端口号。然后我们使用TcpTransportFactory类创建了一个TCP传输对象,将JMX URI作为参数传递给构造函数中,并启动了传输对象。
接着,我们使用MBeanServerConnectionFactory类创建了一个MBeanServerConnection对象,并将JMX URI作为参数传递给构造函数中,从而连接到ActiveMQ Broker的JMX管理服务。
最后,我们使用MBeanServerConnection对象的QueryNames方法,查询了当前连接到Broker的所有消费者对象,并循环遍历了每个消费者对象,并查询了与该消费者相关的所有订阅对象。然后,我们使用MBeanServerConnection对象的GetAttribute方法,获取了每个订阅对象的UserName属性值,并将其输出到控制台。
解决 无用评论 打赏 举报
悬赏问题
- ¥50 有数据,怎么建立模型求影响全要素生产率的因素
- ¥50 有数据,怎么用matlab求全要素生产率
- ¥15 TI的insta-spin例程
- ¥15 完成下列问题完成下列问题
- ¥15 C#算法问题, 不知道怎么处理这个数据的转换
- ¥15 YoloV5 第三方库的版本对照问题
- ¥15 请完成下列相关问题!
- ¥15 drone 推送镜像时候 purge: true 推送完毕后没有删除对应的镜像,手动拷贝到服务器执行结果正确在样才能让指令自动执行成功删除对应镜像,如何解决?
- ¥15 求daily translation(DT)偏差订正方法的代码
- ¥15 js调用html页面需要隐藏某个按钮