activemq编程式客户端

　　

<>强依赖

& lt; dependency> 　　,,,& lt; groupId> org.apache.activemq 　　,,,& lt; artifactId> activemq-client 　　,,,& lt; version> $ {activemq.version} & lt;/version> 　　& lt;/dependency> 　　& lt; dependency> 　　,,,& lt; groupId> org.apache.activemq 　　,,,& lt; artifactId> activemq-spring 　　,,,& lt; version> $ {activemq.version} & lt;/version> 　　& lt;/dependency>

<强> ActivemqProducerTest

public  class  ActivemqProducerTest  { 　　 　　,,,private  static  final  String  producer_broker_url =,“故障转移:(tcp://localhost: 61617, tcp://localhost: 61618年,tcp://localhost: 61619)“; 　　,,,private  static  final  String  username =,“admin"; 　　,,,private  static  final  String  password =,“admin123"; 　　,,,private  static  final  String  destination_queue =,“queue.test01"; 　　,,,private  static  final  String  destination_topic =,“topic.test01"; 　　 　　,,,public  static  void  main (String [], args), throws  JMSException  { 　　,,,,,,,produceInQueue (); 　　,,,,,,,produceInTopic (); 　　,,,} 　　 　　,,,private  static  void  produceInQueue (), throws  JMSException  { 　　,,,,,,,//,activeMQ  connection 工厂 　　,,,,,,,ActiveMQConnectionFactory  ActiveMQConnectionFactory =, new  ActiveMQConnectionFactory (); 　　,,,,,,,activeMQConnectionFactory.setBrokerURL (producer_broker_url); 　　,,,,,,,activeMQConnectionFactory.setUserName(用户名); 　　,,,,,,,activeMQConnectionFactory.setPassword(密码); 　　 　　,,,,,,,Connection  Connection =, activeMQConnectionFactory.createConnection (); 　　,,,,,,,connection.start (); 　　 　　,,,,,,,Session  Session =, connection.createSession(假,,Session.AUTO_ACKNOWLEDGE); 　　,,,,,,,ActiveMQQueue  dest =, new  ActiveMQQueue (destination_queue); 　　 　　,,,,,,,TextMessage  TextMessage =, session.createTextMessage (); 　　,,,,,,,textMessage.setText(“却;能够is  a 测试…“); 　　 　　,,,,,,,MessageProducer  producer =, session.createProducer(桌子); 　　,,,,,,,producer.setDeliveryMode (DeliveryMode.PERSISTENT); 　　,,,,,,,producer.send (textMessage); 　　 　　,,,,,,,connection.close (); 　　,,,} 　　 　　,,,private  static  void  produceInTopic (), throws  JMSException  { 　　,,,,,,,ActiveMQConnectionFactory  ActiveMQConnectionFactory =, new  ActiveMQConnectionFactory (); 　　,,,,,,,activeMQConnectionFactory.setBrokerURL (producer_broker_url); 　　,,,,,,,activeMQConnectionFactory.setUserName(用户名); 　　,,,,,,,activeMQConnectionFactory.setPassword(密码); 　　 　　,,,,,,,Connection  Connection =, activeMQConnectionFactory.createConnection (); 　　,,,,,,,connection.start (); 　　 　　,,,,,,,Session  Session =, connection.createSession(假,,Session.AUTO_ACKNOWLEDGE); 　　,,,,,,,ActiveMQTopic  dest =, new  ActiveMQTopic (destination_topic); 　　 　　,,,,,,,MapMessage  MapMessage =, session.createMapMessage (); 　　,,,,,,,mapMessage.setString (“key01",“val01"); 　　,,,,,,,mapMessage.setInt (“key02",, 2); 　　 　　,,,,,,,MessageProducer  producer =, session.createProducer(桌子); 　　,,,,,,,producer.setDeliveryMode (DeliveryMode.PERSISTENT); 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null 　　null

activemq编程式客户端