activemq最简单的例子

缺乏、安全感 2022-04-16 05:29 247阅读 0赞

import org.apache.activemq.ActiveMQConnectionFactory;  
import javax.jms.\*;  
//生产者  
public class Producer \{  
private static final String URL = “tcp://0.0.0.0:61616”;  
private static final String SUBJECT = “myqueue”;  
public static void main(String\[\] args) \{  
ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(URL);  
Connection connection = null;  
try \{  
connection = connectionFactory.createConnection();  
connection.start();  
//创建Session，此方法第一个参数表示会话是否在事务中执行，第二个参数设定会话的应答模式  
Session session = connection.createSession(true, Session.AUTO\_ACKNOWLEDGE);  
Destination dest = session.createQueue(SUBJECT);

//通过session可以创建消息的生产者
            MessageProducer producer = session.createProducer(dest);
            //初始化一个mq消息
            TextMessage message = session.createTextMessage("hello active mq 中文kkkk" );
            //发送消息
            producer.send(message);
            System.out.println("send message {}....");
            session.commit();
            session.close();
        } catch (JMSException e) {
            e.printStackTrace();
        }finally {
            if(connection!=null){
                try {
                    connection.close();
                } catch (JMSException e) {
                    e.printStackTrace();
                }
            }
        }
    }

--------------------

//消费者  
import org.apache.activemq.ActiveMQConnectionFactory;  
import javax.jms.\*;  
//消费者  
public class Consumer \{  
private static final String URL = “tcp://0.0.0.0:61616”;  
private static final String SUBJECT = “myqueue”;  
// private static Logger logger = LoggerFactory.getLogger(MqServer.class);  
public static void main(String\[\] args) \{  
ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(URL);  
try \{  
Connection connection = connectionFactory.createConnection();  
connection.start();  
//创建Session，此方法第一个参数表示会话是否在事务中执行，第二个参数设定会话的应答模式  
Session session = connection.createSession(true, Session.AUTO\_ACKNOWLEDGE);  
Destination dest = session.createQueue(SUBJECT);  
//通过session可以创建消息的生产者  
MessageConsumer messageConsumer = session.createConsumer(dest);  
//接收 消息  
TextMessage message = (TextMessage) messageConsumer.receive();  
System.out.println(("condsumer message \{\} "+message.getText()));  
\} catch (JMSException e) \{  
e.printStackTrace();  
\}  
\}  
\}