rabbitmq

术语

RabbitMQ：实现了消息队列协议（AMQP）的开源消息代理软件及面向消息的中间件。RabbitMQ服务器是用Erlang语言编写的。

AMQP ：一个提供统一消息服务的应用层标准高级消息队列协议，是应用层协议的一个开放标准，为面向消息的中间件设计。消息中间件主要用于组件之间的解耦，消息的发送者无需知道消息使用者的存在，反之亦然。

生产者：投递消息的一方，生产者创建消息，然后发布到rabbitmq中。

消费者，就是接收消息的一方。消费者连接到 RabbitMQ 服务器，并订阅到队列上。消费者也不需要知道谁是生产者。

队列：队列就像一个超市或者流水线，在RabbitMQ中，生产者创建消息，来到RabbitMQ的队列，消费者可以从队列中取出消息进行消费。所有信息可以只存储在一个队列中。队列可以存储很多的消息，因为它基本上是一个无限制的缓冲区，前提是你的机器有足够的存储空间。多个生产者可以将消息发送到同一个队列中，多个消费者也可以只从同一个队列接收数据。这就是队列的特性。

代码

使用工具是eclipse，创建maven项目，可以引入依赖

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

demo目录

生产者：

package com.ll.mq.hellomq;import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;/*** * @author ll 生产者**/
public class Producer {public final static String QUENE_NAME = "hello";// 定义队列名称public static void main(String[] args) {try {// 创建连接工厂ConnectionFactory factory = new ConnectionFactory();// RabbitMQ地址factory.setHost("127.0.0.1");factory.setPort(5672);factory.setUsername("kysc");factory.setPassword("123456");// 创建一个连接Connection connection = factory.newConnection();// 创建一个频道Channel channel = connection.createChannel();// 声明一个队列  在RabbitMQ中，队列声明是幂等性的（一个幂等操作的特点是其任意多次执行所产生的影响均与一次执行的影响相同），也就是说，如果不存在，就创建，如果存在，不会对已经存在的队列产生任何影响。channel.queueDeclare(QUENE_NAME, false, false, false, null);String message = "HELLO MQ!";// 发送消息到队列中channel.basicPublish("", QUENE_NAME, null, message.getBytes("UTF-8"));System.out.println("Producer [x] Send '" + message + "'");// 关闭频道和连接channel.close();connection.close();} catch (Exception e) {e.printStackTrace();} }}

消费者

package com.ll.mq.hellomq;import java.io.IOException;import com.rabbitmq.client.AMQP;
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;
import com.rabbitmq.client.DefaultConsumer;
import com.rabbitmq.client.Envelope;
/*** * @author ll Consumer **/
public class Consumer {private final static String QUEUE_NAME = "hello";public static void main(String[] argv) throws Exception {// 创建连接工厂ConnectionFactory factory = new ConnectionFactory();
//      设置RabbitMQ地址factory.setHost("127.0.0.1");factory.setPort(5672);factory.setUsername("kysc");factory.setPassword("123456");
//      创建一个连接Connection connection = factory.newConnection();
//      创建一个频道Channel channel = connection.createChannel();
//      声明要关注的队列 -- 在RabbitMQ中，队列声明是幂等性的（一个幂等操作的特点是其任意多次执行所产生的影响均与一次执行的影响相同），也就是说，如果不存在，就创建，如果存在，不会对已经存在的队列产生任何影响。channel.queueDeclare(QUEUE_NAME, false, false, false, null);System.out.println("C [*] Waiting for messages. To exit press CTRL+C");
//      DefaultConsumer类实现了Consumer接口，通过传入一个频道，告诉服务器我们需要那个频道的消息，如果频道中有消息，就会执行回调函数handleDeliveryDefaultConsumer consumer = new DefaultConsumer(channel) {@Overridepublic void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body) throws IOException {String message = new String(body, "UTF-8");System.out.println("C [x] Received '" + message + "'");}};
//      自动回复队列应答 -- RabbitMQ中的消息确认机制，后面章节会详细讲解channel.basicConsume(QUEUE_NAME, true, consumer);}
}

接受结果：C [*] Waiting for messages. To exit press CTRL+C
C [x] Received 'HELLO MQ!'

概念

ConnectionFactory(连接工厂): 生产Connection的的工厂

Connection(连接):是RabbitMQ的socket的长链接，它封装了socket协议相关部分逻辑

Channel(频道|信道): 是建立在Connection连接之上的一种轻量级的连接，我们大部分的业务操作是在Channel这个接口中完成的，包括定义队列的声明queueDeclare、交换机的声明exchangeDeclare、队列的绑定queueBind、发布消息basicPublish、消费消息basicConsume等。

public Queue.DeclareOk queueDeclare(String queue, boolean durable, boolean exclusive,
boolean autoDelete, Map<String, Object> arguments)

queue: 队列名称

durable：是否持久化, 队列的声明默认是存放到内存中的，如果rabbitmq重启会丢失，如果想重启之后还存在就要使队列持久化，保存到Erlang自带的Mnesia数据库中，当rabbitmq重启之后会读取该数据库

exclusive：是否排外

1 当exclusive = true则设置队列为排他的。如果一个队列被声明为排他队列，该队列仅对首次声明它的连接（Connection）可见，是该Connection私有的，类似于加锁，并在连接断开connection.close()时自动删除；
2 exclusive = false则设置队列为非排他的，此时不同连接（Connection）的管道Channel可以使用该队列；
"首次" 是指如果某个连接（Connection）已经声明了排他队列，其他连接是不允许建立同名的排他队列的。这个与普通队列不同：即使该队列是持久化的(durable = true)，一旦连接关闭或者客户端退出，该排他队列都会被自动删除，这种队列适用于一个客户端同时发送和读取消息的应用场景。
4. autoDelete：是否自动删除；如果autoDelete = true，当所有消费者都与这个队列断开连接时，这个队列会自动删除。注意：不是说该队列没有消费者连接时该队列就会自动删除，因为当生产者声明了该队列且没有消费者连接消费时，该队列是不会自动删除的。

5. arguments：设置队列的其他一些参数，如 x-rnessage-ttl 、x-expires 、x-rnax-length 、x-rnax-length-bytes、 x-dead-letter-exchange、 x-deadletter-routing-key 、 x-rnax-priority 。

参考：https://blog.csdn.net/AwayFuture/article/details/103405335?depth_1-utm_source=distribute.pc_relevant.none-task&utm_source=distribute.pc_relevant.none-task

下一篇https://blog.csdn.net/lilongwangyamin/article/details/105098011 rabbitmq 队列

整体代码：https://download.csdn.net/download/lilongwangyamin/12272687

RabbitMQ基础介绍相关推荐

RabbitMQ基础知识介绍、RabbitMQ的安装
RabbitMQ基础知识介绍官方解释:MQ全称为Message Queue, 消息队列(MQ)是一种应用程序对应用程序的通信方法.应用程序通过读写出入队列的消息 ...
RabbitMQ基础知识详解
RabbitMQ基础知识详解 2017年08月28日 20:42:57 dreamchasering 阅读数:41890 标签: RabbitMQ 什么是MQ? MQ全称为Message Queue, ...
Ruby使用RabbitMQ(基础)
Ruby使用RabbitMQ(基础) RabbitMQ documentation rabbitmq-tutorials rabbitmq-configure bunny 前提最近刚刚接触到mq, ...
rabbitmq基础1——消息中间件概念、Rabbitmq的发展起源和基本组件的作用流程
文章目录一.消息中间件 1.1 概念 1.2 作用 1.2.1 消息队列持久化 1.2.2 消息队列分发策略 1.2.3 消息队列的高可用和高可靠 1.2.3.1 一主多从共享集群 1.2.3.2 ...
rabbitmq基础2——rabbitmq二进制安装和docker安装、基础命令
文章目录一.RabbitMQ安装 1.1 二进制安装 1.2 rabbitmqctl工具 1.3 docker安装二.rabbitmq基础命令 2.1 多租户与权限类 2.1.1 创建虚拟主机 2 ...
(2)RabbitMQ基础概念及工作流程详解
上一节中我们对MQ做了一个概要介绍,这一节开始我们选取RabbitMQ开始进行学习,本节将会RabbitMQ做个简单介绍,并且会对其常见的基础概念做个讲解,最后会简单介绍一下RabbitMQ的工作流程 ...
[喵咪MQ(1)]RabbitMQ简单介绍准备工作
[喵咪MQ(1)]RabbitMQ简单介绍准备工作前言哈喽大家好呀! 看标题就知道我们这次要讲MQ,之前博客中有提到的KafKa理论上来说也是一个优秀的MQ队列软件,比较知名的MQ有:Go语言编写 ...
转 RabbitMQ 基础概念及 Spring 的配置和使用推荐好文举例讲解
从不知道到了解-RabbitMQ 基础概念及 Spring 的配置和使用转: sumile.cn » 从不知道到了解-RabbitMQ 基础概念及 Spring 的配置和使用序言你在系统中是 ...
day23:shell基础介绍 alias及重定向
2019独角兽企业重金招聘Python工程师标准>>> 1.shell基础介绍: shell是一个命令解释器,用于用户与机器的交互: 也支持特定的语法(逻辑判断,循环): 每个用户都 ...

RabbitMQ基础介绍

rabbitmq

术语

代码

概念

RabbitMQ基础介绍相关推荐

最新文章

热门文章