永发信息网

为什么activemq写很慢

答案:2  悬赏:30  手机版
解决时间 2021-03-02 01:39
  • 提问者网友:你给我的爱
  • 2021-03-01 02:32
我发送100条,占用了3.6秒,相当于一秒只发送30条。怎么这么慢啊?是不是默认的配置参数原因?

ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory(
ActiveMQConnectionFactory.DEFAULT_USER,
ActiveMQConnectionFactory.DEFAULT_PASSWORD,
ActiveMQConnectionFactory.DEFAULT_BROKER_URL);
try {

Connection connection = connectionFactory.createConnection();
connection.start();

Session session = connection.createSession(false,
Session.AUTO_ACKNOWLEDGE);

Destination destination = session.createQueue("TEST");

MessageProducer producer = session.createProducer(destination);

TextMessage message = session.createTextMessage();

System.out.println("开始发送。。。");

long start = System.currentTimeMillis();
System.out.println(start);

for (int i = 0; i < 100; i++) {
message.setText("This is message " + (i + 1));
producer.send(message);
}

long end = System.currentTimeMillis();
System.out.println(end);
System.out.println("用时:"+(end-start));

} catch (JMSException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}

}catch(Exception e){
e.printStackTrace();
}
最佳答案
  • 五星知识达人网友:罪歌
  • 2021-03-01 03:13
我也碰到了同样的问题,楼上的明显就是坑爹的,明明是本地的服务器,怎么可能是网络问题,我后来采用的是session为true的方式,你传个两万条,执行完之后来个session.commit()就可以了,这速度相当的快
全部回答
  • 1楼网友:梦中风几里
  • 2021-03-01 03:56
你好! 是不是客户端到服务器的网络问题? 我的回答你还满意吗~~
我要举报
如以上回答内容为低俗、色情、不良、暴力、侵权、涉及违法等信息,可以点下面链接进行举报!
点此我要举报以上问答信息
大家都在看
推荐资讯