ActiveMQ中Topic生产者

àì夳堔傛蜴生んèń 2022-05-17 08:45 114阅读 0赞

### Producer ###

生产者，发送消息

### 发送步骤 ###

第一步：创建ConnectionFactory对象，需要指定服务端ip及端口号  
第二步：使用ConnectionFactory对象创建一个Connection对象  
第三步：开启连接，调用Connection对象的start方法  
第四步：使用Connection对象创建一个Session对象  
第五步：使用Session对象创建一个Destination对象（topic、queue），此处创建一个Topic对象  
第六步：使用Session对象创建一个Producer对象  
第七步：创建一个Message对象，创建一个TextMessage对象  
第八步：使用Producer对象发送消息  
第九步：关闭资源

代码

@Test
    public void testTopicProducer() throws Exception {
        //创建一个连接工厂对象
        ConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://192.168.25.168:61616");
        //创建连接
        Connection connection = connectionFactory.createConnection();
        //开启连接
        connection.start();
        //创建Session
        Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
        //创建Destination，应该使用topic
        Topic topic = session.createTopic("test-topic");
        //创建一个Producer对象
        MessageProducer producer = session.createProducer(topic);
        //创建一个TextMessage对象
        TextMessage textMessage = session.createTextMessage("hello activemq topic");
        //发送消息
        producer.send(textMessage);
        //关闭资源
        producer.close();
        session.close();
        connection.close();
    }

发表评论取消回复

表情：

评论列表（有 0 条评论，114人围观）

还没有评论，来说两句吧...

相关阅读

相关 ActiveMQ专题4 ——Java编码实现ActiveMQ通讯（Topic）

说明在上一篇 [ActiveMQ专题3 ——Java编码实现ActiveMQ通讯（Queue）][ActiveMQ_3 _Java_ActiveMQ_Queue]中，关

怼烎@/ 2022年10月23日 11:13/ 0 赞/ 252 阅读

相关 ActiveMQ的简单Topic实现案例

首先我们在这里要说一下消息中间件中有两个角色，生产者Producer与消费者Consumer，简单理解即使发发送消息者与接收消息者，在编写代码之前我们需要将下载到的Active

红太狼/ 2022年09月24日 13:24/ 0 赞/ 143 阅读

相关 ActiveMQ之spring集成Topic

通过Spring对ActiveMQ进行配置开发，发布订阅模式，支持消息的持久化。可以通过配置clientId实现持久化订阅。 1.生产者 spring配置：

太过爱你忘了你带给我的痛/ 2022年08月05日 02:25/ 0 赞/ 132 阅读

相关 ActiveMQ之Topic的持久订阅

非持久化订阅持续到它们订阅对象的生命周期。这意味着，客户端只能在订阅者活动时看到相关主题发布的消息。如果订阅者不活动，它会错过相关主题的消息。如果花费较大的开销，订阅者可以被定

偏执的太偏执、/ 2022年08月05日 02:24/ 0 赞/ 126 阅读

相关 ActiveMQ_topic使用

注意：消息发布后若没有调用者不保存在服务器。有相应持久化方法一、发送： @Test public void addTopic() t

你的名字/ 2022年05月27日 09:15/ 0 赞/ 153 阅读

相关 ActiveMQ中Topic消费者

Consumer 消费者，接收消息接收步骤第一步：创建一个ConnectionFactory对象第二步：从ConnectionFactory对象中获得一

心已赠人/ 2022年05月17日 08:46/ 0 赞/ 139 阅读

相关 ActiveMQ中Topic生产者

Producer 生产者，发送消息发送步骤第一步：创建ConnectionFactory对象，需要指定服务端ip及端口号第二步：使用Connection

àì夳堔傛蜴生んèń/ 2022年05月17日 08:45/ 0 赞/ 115 阅读

相关 ActiveMQ中Queue生产者

Producer 生产者，生产消息，发送端发送步骤第一步：创建ConnectionFactory对象，需要指定服务端ip及端口号第二步：使用Connect

客官°小女子只卖身不卖艺/ 2022年05月17日 08:06/ 0 赞/ 97 阅读

相关 activeMQ Topic方式（发布/订阅）

在发布订阅消息方式中，消息是无状态的，不保证每条消息被消费，只有监听该TOPIC地址才能收到消息并消费，否则该消息将会丢失。一对多的发布接受策略，可以同时消费多个消息。订

Love The Way You Lie/ 2021年09月28日 06:42/ 0 赞/ 312 阅读

相关 ActiveMQ--topic

发布/订阅模式（topic）发布/订阅模式传递域的特点如下：生产者将消息发布到topic中，每个消息可以有多个消费者，属于1：N的关系。生产者和消费者

以你之姓@/ 2021年08月14日 01:41/ 0 赞/ 294 阅读