Créer un cas Hello World simple

1. Créez un simple cas Hello World

Vous devez d'abord importer le package activemq-all-5.14.5.jar et écrire la fin de la production :

package com.ietree.mq.helloworld;import javax.jms.Connection;import javax.jms.ConnectionFactory;import javax.jms.DeliveryMode;import javax.jms.Destination;import javax.jms.MessageProducer;import javax.jms.Session;import javax.jms.TextMessage;import org.apache.activemq.ActiveMQConnectionFactory;public class Sender {public static void main(String[] args) throws Exception {// 第一步：建立ConnectionFactory工厂对象，需要填入用户名、密码、以及要连接的地址，均使用默认即可，默认端口为：tcp://localhost:61616ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(ActiveMQConnectionFactory.DEFAULT_USER,
                ActiveMQConnectionFactory.DEFAULT_PASSWORD, "tcp://localhost:61616");// 第二步：通过ConnectionFactory工厂对象我们创建一个Connection链接，并且调用ConnectionFactory的start方法开启链接，Connection默认是关闭的Connection connection = connectionFactory.createConnection();
        connection.start();// 第三步：通过Connection对象创建Session会话（上下文环境对象），用于接收消息，参数配置1为是否启用事务，参数配置2为签收模式，一般我们设置为自动签收Session session = connection.createSession(Boolean.FALSE, Session.AUTO_ACKNOWLEDGE);// 第四步：通过Session创建Destination对象，指的是一个客户端用来指定生产消息目标和消费信息来源的对象，在PTP模式中，Destination被称作Queue即队列；在Pub/Sub模式，Destination被称作Topic即主题。在程序中可以使用多个Queue和Topic。Destination destination = session.createQueue("queue1");// 第五步：我们需要通过Session对象创建消息的发送和接收对象（生产者和消费者）MessageProducer/MessageConsumer。MessageProducer messageProducer = session.createProducer(destination);// 第六步：我们可以使用MessageProducer的setDeliveryMode方法为其设置持久化特性和非持久化特性（DeliveryMode）        messageProducer.setDeliveryMode(DeliveryMode.NON_PERSISTENT);// 第七步：最后我们使用JMS规范的TextMessage形式创建数据（通过Session对象），并用MessageProducer的send方法发送数据。同理，客户端使用receive方法进行接收数据，最后需要关闭Connection连接。for (int i = 0; i < 5; i++) {
            TextMessage textMessage = session.createTextMessage();
            textMessage.setText("我是消息内容......" + i);
            messageProducer.send(textMessage);
            System.out.println("生产者：" + textMessage.getText());
        }if (connection != null) {
            connection.close();
        }
    }
}

Écrivez du côté consommateur :

package com.ietree.mq.helloworld;import javax.jms.Connection;import javax.jms.ConnectionFactory;import javax.jms.Destination;import javax.jms.MessageConsumer;import javax.jms.Session;import javax.jms.TextMessage;import org.apache.activemq.ActiveMQConnectionFactory;public class Receiver {public static void main(String[] args) throws Exception {// 第一步：建立ConnectionFactory工厂对象，需要填入用户名、密码、以及要连接的地址，均使用默认即可，默认端口为：tcp://localhost:61616ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(ActiveMQConnectionFactory.DEFAULT_USER,
                ActiveMQConnectionFactory.DEFAULT_PASSWORD, "tcp://localhost:61616");// 第二步：通过ConnectionFactory工厂对象我们创建一个Connection链接，并且调用ConnectionFactory的start方法开启链接，Connection默认是关闭的Connection connection = connectionFactory.createConnection();
        connection.start();// 第三步：通过Connection对象创建Session会话（上下文环境对象），用于接收消息，参数配置1为是否启用事务，参数配置2为签收模式，一般我们设置为自动签收Session session = connection.createSession(Boolean.FALSE, Session.AUTO_ACKNOWLEDGE);// 第四步：通过Session创建Destination对象，指的是一个客户端用来指定生产消息目标和消费信息来源的对象，在PTP模式中，Destination被称作Queue即队列；在Pub/Sub模式，Destination被称作Topic即主题。在程序中可以使用多个Queue和Topic。Destination destination = session.createQueue("queue1");// 第五步：我们需要通过Session对象创建消息的发送和接收对象（生产者和消费者）MessageProducer/MessageConsumer。MessageConsumer messageConsumer = session.createConsumer(destination);        while (true) {
            TextMessage msg = (TextMessage) messageConsumer.receive();if(msg == null){break;
            }
            System.out.println("接收到的内容：" + msg.getText());
        }if (connection != null) {
            connection.close();
        }
    }
}

Affichez la consommation des messages via le chemin http://localhost:8161/admin/queues.jsp.

2. Mécanisme de sécurité ActiveMQ

Interface de gestion Web d'activeMQ : http://127.0.0.1:8161/admin
La console de gestion ActiveMQ est déployée à l'aide de Jetty, donc si vous devez changer le mot de passe, vous devez accéder au fichier de configuration correspondant : apache-activemq-5.14.5confjetty-realm.properties
activeMQ doit être configuré avec un mécanisme de sécurité. Seuls les utilisateurs qui répondent à l'authentification peuvent envoyer et obtenir des messages, donc. nous pouvons également ajouter de la sécurité dans activemq.xml. Vérifiez la configuration, apache-activemq-5.14.5confjetty-realm.propertiesactivemq.xml, ajoutez simplement une configuration de plug-in après la ligne 123.

Ajouter des utilisateurs administratifs dans activemq.xml :

<!-- destroy the spring context on shutdown to stop jetty --><shutdownHooks><bean xmlns="http://www.springframework.org/schema/beans" class="org.apache.activemq.hooks.SpringContextHook" /></shutdownHooks><plugins>
            <simpleAuthenticationPlugin>
                <users>
                    <authenticationUser username="root" password="root" groups="users,admins"/>
                </users>
            </simpleAuthenticationPlugin>
        </plugins></broker>

De cette façon, vous ne pouvez vous connecter que via les informations du compte root.

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!