RabbitMQ-直连模型

AMQP的架构模型

其中虚拟主机的意思类似于数据库中库的概念，设计者更希望，每一个项目独立使用一个虚拟主机。

入门案例

引入依赖

<dependency><groupId>com.rabbitmq</groupId><artifactId>amqp-client</artifactId><version>5.7.2</version>
</dependency>

先去创建虚拟主机

编写生产者代码并运行

     // 直连模式生产者 ( 生产者直接链接队列，没有交换器参与 )@Testvoid contextLoads() throws IOException, TimeoutException {ConnectionFactory connectionFactory = new ConnectionFactory();connectionFactory.setHost("106.15.73.43");connectionFactory.setVirtualHost("/rabbitmq_zhj");connectionFactory.setPort( 5672 );connectionFactory.setUsername( "admin" );connectionFactory.setPassword( "123" );// 创建连接Connection connection = connectionFactory.newConnection();// 创建信道Channel channel = connection.createChannel();// 参数1：队列名  参数2: 队列是否持久化  参数3:是否独占队列 参数4:是否在消费后自动删除 参数5:其他属性channel.queueDeclare("hello",true,false,false,null );//发布消息 参数1： 交换机名 参数2：队列名 参数3：MessageProperties.PERSISTENT_TEXT_PLAIN(持久化)传递消息的额外设置 参数4：消息的内容(字节)channel.basicPublish("","hello", MessageProperties.PERSISTENT_TEXT_PLAIN, "hello rabbitmq".getBytes() );// 关闭信道channel.close();// 关闭连接connection.close();}

编写消费者代码并运行

主要注意的是消费者端需要一直处于监听运行状态。建议放在main函数中进行运行。

    // 直连模式消费者 ( 生产者直接链接队列，没有交换器参与 )public static void main(String[] args) throws IOException, TimeoutException {ConnectionFactory connectionFactory = new ConnectionFactory();connectionFactory.setHost("106.15.73.43");connectionFactory.setPort( 5672 );connectionFactory.setUsername("admin");connectionFactory.setPassword("123");connectionFactory.setVirtualHost("/rabbitmq_zhj");Connection connection = connectionFactory.newConnection();// 创建信道Channel channel = connection.createChannel();// 参数1：队列名  参数2: 是否持久化  参数3:是否独占队列 参数4:是否在消费后自动删除 参数5:其他属性channel.queueDeclare("hello",true,false,false,null );// 参数1： 队列名 参数2：队列名 参数3：传递消息的额外设置 参数4：消息的内容(字节)channel.basicConsume("hello" ,true , new DefaultConsumer(channel){@Overridepublic void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body) throws IOException {System.out.println(new String(body));}} );}

工具类提取

import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;
import java.io.IOException;
import java.util.concurrent.TimeoutException;public class RabbitMQUtil {private static ConnectionFactory connectionFactory;static {connectionFactory = new ConnectionFactory();connectionFactory.setPort( 5672 );connectionFactory.setHost( "106.15.73.43" );connectionFactory.setPassword( "123" );connectionFactory.setUsername( "admin" );connectionFactory.setVirtualHost( "/rabbitmq_zhj" );}public static Connection getConnection() throws IOException, TimeoutException {try{return connectionFactory.newConnection();}catch (Exception e){e.printStackTrace();return null;}}public static void closeConnectionAndChanel(Channel channel, Connection connection){try{if (channel != null) channel.close();if (connection != null) connection.close();} catch (IOException | TimeoutException e) {e.printStackTrace();}}}

RabbitMQ-直连模型相关推荐

RabbitMQ的架构模型
本章主要讨论RabbitMQ的架构模型,AMQP协议是什么,以及RabbitMQ和AMQP之间的关系,还会讨论消息从生产者发出和送达到消费者这一过程要经历哪些步骤. RabbitMQ整体上是生产者与消 ...
RabbitMQ的消息模型
1.消息队列(MQ,Message Queue) 消息队列里可以存放大量消息,这些消息由生产者生成放到队列里,等待消费者获取并处理.使用消息队列可以提升系统的性能,降低系统耦合性. 比如说,一个发短信 ...
RabbitMQ：订阅模型-消息订阅模式
订阅模型-消息订阅模式,也可以称为广播模式,生产者将消息发送到 Exchange,Exchange 再转发到与之绑定的 Queue中,每个消费者再到自己的 Queue 中取消息. RabbitMQ 单 ...
RabbitMQ第一种消息模型--直连模型
RabbitMQ简单模式–直连,相当于点对点连接一样在上图的模型中,有以下概念: P:生产者,也就是要发送消息的程序 C:消费者:消息的接受者,会一直等待消息到来. queue:消息队列,图中红色部 ...
java实现rabbitmq发布/订阅模型（Publish/Subscribe queues），生产者消费者交换机消息队列
发布/订阅模型又称扇出模型,或者是广播模型,可以有多个消费者,每个消费者有自己的队列,每个队列都要绑定到交换机,生产者发送的消息只需要发送到交换机,再由交换机决定要发送到哪些队列,生产者无法自行决定. ...
RabbitMQ 基本消息模型和消息确认机制
01 前言关于 RabbitMQ 服务器的安装,本章节不做介绍,请培养个人动手能力,自行百度解决.RabbitMQ 成功安装后(win 版),浏览器输入:localhost:15672,则可以进入 ...
RabbitMQ：消息模型
RabbitMQ 提供了 6 种消息模型,分别为:单生产单消费模型(Hello World).消息分发模型(Work queues).Fanout 消息订阅模式(Publish/Subscribe). ...
【分布式】Rabbitmq死信队列模型、实战场景---订单延迟30min支付处理
分布式内容管理死信队列死信队列demo 死信队列消息模型平台订单支付超时 --- 演示业务分析代码实现 RabbitMQ 死信队列/ 延迟队列 - 延迟业务逻辑最近可能分布式进入Redi ...
java实现rabbitmq简单队列模型，生产者消费者消息队列
生产者向队列发送消息,随机消费者从队列中接收消息创建用户和虚拟主机通过rabbitmq提供的用户管理界面可以很轻松的创建用户和虚拟主机,并且需要将用户绑定到对应的虚拟主机.自带有guest用户和/ ...
RabbitMQ第二种模型--workqueue
Work queues,也被称为(Task queues),任务模型.奉行的是平均主义让多个消费者绑定到一个队列,共同消费队列中的消息. 队列中的消息一旦消费,就会消失,因此任务是不会被重复执行的. ...

RabbitMQ-直连模型

AMQP的架构模型

入门案例

引入依赖

先去创建虚拟主机

编写生产者代码并运行

编写消费者代码并运行

工具类提取

RabbitMQ-直连模型相关推荐

最新文章

热门文章