ActiveMQ入门案例-生产者代码达成

发布时间：2021-11-13 11:12:53 所属栏目：PHP教程来源：互联网

导读：使用Java程序操作ActiveMQ生产消息，代码的复杂度较高，但也没有默写下来的必要。开发ActiveMQ首先需要导入activemq-all.jar包，如果是maven项目，就需要在pom文件中导入坐标。本例中创建的是一个maven项目，所以在pom文件中引入坐标： dependency groupIdo

使用Java程序操作ActiveMQ生产消息，代码的复杂度较高，但也没有默写下来的必要。

开发ActiveMQ首先需要导入activemq-all.jar包，如果是maven项目，就需要在pom文件中导入坐标。本例中创建的是一个maven项目，所以在pom文件中引入坐标：

<dependency>
    <groupId>org.apache.activemq</groupId>
    <artifactId>activemq-all</artifactId>
    <version>5.14.0</version>
</dependency>

要测试代码就需要引入juint坐标：

<dependency>
    <groupId>junit</groupId>
    <artifactId>junit</artifactId>
    <version>4.12</version>
</dependency>

Java代码操作ActiveMQ生产消息:

public class ActiveMQProducer {
    @Test
    public void testProduceMQ() throws Exception {
        // 连接工厂
        // 使用默认用户名、密码、路径
        // 路径 tcp://host:61616
        ConnectionFactory connectionFactory = new ActiveMQConnectionFactory();
        // 获取一个连接
        Connection connection = connectionFactory.createConnection();
        // 建立会话
        Session session = connection.createSession(true,
                Session.AUTO_ACKNOWLEDGE);
        // 创建队列或者话题对象
        Queue queue = session.createQueue("HelloWorld");
        // 创建生产者或者消费者
        MessageProducer producer = session.createProducer(queue);

        // 发送消息
        for (int i = 0; i < 10; i++) {
            producer.send(session.createTextMessage("你好，activeMQ:" + i));
        }
        // 提交操作
        session.commit();

    }
}

（编辑：应用网_丽江站长网）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!

php读取大文件最好的实	php无限遍历文件夹示例
php中实现过滤UBB代码	Laravel模板引擎Blade