activemq

Sender/Producer

public class Sender
{
    public static void main(String[] args)
        throws Exception
    {
        // 1、建立ConnectionFactory连接对象(默认连接方式)
        ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(
            ActiveMQConnectionFactory.DEFAULT_USER, ActiveMQConnectionFactory.DEFAULT_PASSWORD,
            "tcp://localhost:61616");

        // 2、建立ConnectionFactory连接
        Connection connection = connectionFactory.createConnection();
        connection.start();

        // 3、建立session会话 参数：parameter1：是否开启事务。parameter2：签收模式(四种)
        Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);

        // 4、创建Destination，目的地。parameter：目的地名(非常重要)
        Destination destination = session.createQueue("queue1");

        // 5、创建MessageProducer：消息的生产者/消费者
        MessageProducer messageProducer = session.createProducer(destination);

        // 6、设置消息是否持久化
        messageProducer.setDeliveryMode(DeliveryMode.NON_PERSISTENT);

        // 7、创建消息
        TextMessage textMessage = session.createTextMessage();
        textMessage.setText("hello world");
        messageProducer.send(textMessage);// 发送消息
        // 8、关闭连接
        if (connection != null)
        {
            connection.close();
        }
    }
}

 

 

Receiver/Customer

 

public class Receiver
{
    public static void main(String[] args)
        throws Exception
    {
        // 1、建立ConnectionFactory连接对象
        ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(
            ActiveMQConnectionFactory.DEFAULT_USER, ActiveMQConnectionFactory.DEFAULT_PASSWORD,
            "tcp://localhost:61616");

        // 2、建立ConnectionFactory连接
        Connection connection = connectionFactory.createConnection();
        connection.start();

        // 3、建立session会话 参数：parameter1：是否开启事务。parameter2：签收模式(四种)
        Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);

        // 4、创建Destination，目的地。parameter：目的地名
        Destination destination = session.createQueue("queue1");

        // 5、创建MessageConsumer：消息的生产者/消费者
        MessageConsumer messageConsumer = session.createConsumer(destination);

        // 6、接收消息
        while (true)
        {
            TextMessage textMessage = (TextMessage)messageConsumer.receive();
            if(null==textMessage) break;
            System.out.println("message is "+textMessage.getText());
        }
        // 7、关闭连接
        if (connection != null)
        {
            connection.close();
        }
    }
}

在浏览器输入网址：http://localhost:8161/admin/

查看数据