工具使用篇——java操作activemq
97 浏览量
2020-12-21
23:53:10
上传
评论
收藏 27KB PDF 举报
工具使用篇工具使用篇——java操作操作activemq
准备准备
不管是本地还是云端，要先有一个activemq
安装过程安装过程
生产者
Publiser.java
package example;
import org.apache.activemq.ActiveMQConnectionFactory;
import org.apache.activemq.command.ActiveMQQueue;
import org.apache.activemq.command.ActiveMQTempQueue;
import org.apache.activemq.command.ActiveMQTopic;
import javax.jms.*;
class Publisher {
public static void main(String []args) throws JMSException {
String user = "admin";
String password = "admin";
String host = "127.0.0.1";
int port = Integer.parseInt("61616");
String destination = "flight_tag";
int messages = 100;
ActiveMQConnectionFactory factory = new ActiveMQConnectionFactory("tcp://" + host + ":" + port);
Connection connection = factory.createConnection(user, password);
connection.start();
Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
// Destination dest = new ActiveMQTopic(destination);
Destination dest= new ActiveMQQueue(destination);
MessageProducer producer = session.createProducer(dest);
producer.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
for( int i=1; i <= messages; i ++) {
TextMessage msg = session.createTextMessage(String.valueOf(i));
msg.setIntProperty("id", i);
producer.send(msg);
if( (i % 100) == 0) {
System.out.println(String.format("Sent %d messages", i));
}
}
// producer.send(session.createTextMessage("SHUTDOWN"));
connection.close();
}
private static String env(String key, String defaultValue) {
String rc = System.getenv(key);
if( rc== null )
return defaultValue;
return rc;
}
private static String arg(String []args, int index, String defaultValue) {
if( index < args.length )
return args[index];
else
return defaultValue;
}
}
消费者
listener.java
package example;
import org.apache.activemq.ActiveMQConnectionFactory;
import org.apache.activemq.command.ActiveMQQueue;
资源评论
