Activemq 接受消息慢

问题描述

问题描述：发送十万条消息对activemq队列中，其中每个五百条发送一条带有selector消息。创建一个同样selector的消费者，发现接受消息很慢。具体代码如下：for(inti=0;i<50000;i++){ITextMessagemessage;if(i%1000==0){message=session.CreateTextMessage(msg);message.Properties.SetString("JMXGroupID","A");}else{message=session.CreateTextMessage(msg);}producer.Send(message,MsgDeliveryMode.Persistent,MsgPriority.Normal,TimeSpan.MinValue);}

接受核心代码：IDestinationdestination=SessionUtil.GetDestination(session,"testing");IMessageConsumerconsumer=session.CreateConsumer(destination,"JMXGroupID='A'",false);for(inti=0;i<50;i++){IMessageiMsg=consumer.Receive();ITextMessagemsg=(ITextMessage)iMsg;Console.WriteLine(msg.Text);count++;}

解决方案

解决方案二：
那你没隔100条试试看。