首页 > 其他分享 >RabbitMQ 入门系列:2、基础含义理解:链接、通道、队列、交换机

RabbitMQ 入门系列:2、基础含义理解:链接、通道、队列、交换机

时间:2022-08-21 14:44:07浏览次数:96  
标签:入门 队列 RabbitMQ 交换机 链接 channel

系列目录

RabbitMQ 入门系列:1、MQ的应用场景的选择与RabbitMQ安装。

RabbitMQ 入门系列:2、基础含义:链接、通道、队列、交换机。

RabbitMQ 入门系列:3、基础含义:持久化、排它性、自动删除、强制性、路由键。

RabbitMQ 入门系列:4、基础编码:官方SDK使用:链接创建、单例改造、发送消息、接收消息。

RabbitMQ 入门系列:5、基础编码:交换机的进阶介绍及编码方式。

RabbitMQ 入门系列:6、保障消息:不丢失:发送方、Rabbit存储端、接收方。

RabbitMQ 入门系列:7、保障消息:不重复消费:产生消息的唯一ID。

RabbitMQ 入门系列:8、扩展内容:接收信息时:可否根据RoutingKey过滤监听信息,答案是不能。

RabbitMQ 入门系列:9、扩展内容:死信队列:真不适合当延时队列。

RabbitMQ 入门系列:10、扩展内容:延时队列:延时队列插件及其有限的适用场景。

前言:

本系列介绍RabbitMQ,介绍RabbitMQ的基础概念的含义。

并扫清网络上的一些错误或容易误导人的内容,帮助网友快速正确理解并掌握RabbitMQ。 

下面开始本篇内容相关介绍。

1、上图管理中心图:

 

从管理中心可以看到,主要有以下几个大菜单:

1、Overview:概述,就是基础监控。

2、Connections:链接

3、Channels:通道

4、Queues:队列

5、Admin:管理 

除去概述和管理,剩下三个是理解RabbitMQ的重要指标。

下面进行基本概念介绍,涉及的代码,下一篇再介绍:

1、链接:

比如用官方的SDK创建一个链接:

using RabbitMQ.Client;

var factory = new ConnectionFactory()
{
    HostName = "127.0.0.1",
    UserName = "guest",
    Password = "guest",
    VirtualHost = "/"
};

var connection = factory.CreateConnection();

即产生一个链接:

 

对于这段代码,如果在一个Web应用程序中不断执行,在大并发请求下会产生大量的链接,这是不可取的。 

如果再加上分布式部署,大量Web应用再加大量并发,链接资源就不够用了。

因此,官网的建议,是用户应该把它做成单例,一个应用尽量使用1个链接。

官方为了让多个线程共享一个链接,又不互相影响,做出了通道的概念。

2、通道:

为了减少链接数,降低资源开销,RabbitMQ设计了通道的概念。

1个链接可以创建无数个通道,然后主要的编码,就是针对通道编码。

using RabbitMQ.Client;
using System.Text;
using RabbitMQ.Client.Events;

var factory = new ConnectionFactory()
{
    HostName = "127.0.0.1",
    UserName = "guest",
    Password = "guest",
    VirtualHost = "/"
};

var connection = factory.CreateConnection();

var channel = connection.CreateModel();

 

 

当然,这样编码在Web应用程序是不可取的,应该把链接那一块的创建整成单例,下面示例中将忽略获取链接这一块。

因此,后续编码都是在获取单例链接,创建通道,然后再进行一步操作。

3、队列:创建队列,发送消息、监听队列,获取消息。

这里先描述队列,交换机这种多出来的概念,放到后面再进行描述:

队列,即数据存档和获取数据的地方。

简单需求下,只需要给把信息发给队列,然后监听队列获取信息就完事了。

发送消息:

...
var channel = connection.CreateModel();

channel.QueueDeclare("FirstQueue", false, false, false);//创建队列
channel.BasicPublish("", "FirstQueue", false, null, Encoding.UTF8.GetBytes("这是要发送的内容"));
channel.Close();

 

 监听队列,并获取信息:

...
var channel = connection.CreateModel();

var consumer = new EventingBasicConsumer(channel);
consumer.Received += (model, ea) =>
{
    var message = Encoding.UTF8.GetString(ea.Body.ToArray());
    Console.WriteLine("收到默认消息 {0}", message);
};
string msg = channel.BasicConsume(queue: "FirstQueue",
                      autoAck: true,
                      consumer: consumer);

 

对于以上的发送到监听,都不涉及到交换机,直接来,直接去即可。

那么,交换机概念的引入,有什么作用呢?

4、交换机:

如果通道的出现,是为了降低链接数,那么交换机的出现,竟然不是为了降低队列数。

示例说明:比如一开始创建了一个用户队列:User :用它发送存储用户的注册信息队列

后面新增需求,发现User要实现很多个分支:

按照常规模式,也能实现,创建多个队列,可以满足需求。

但随着业务和模块分支越来越多,队列可能会太多,不便于管理和维护。 

一开始,以为:通过交换机,引入路由(routekey)后,结构会变化成:

后来,发现理解错了,特别是被网上的教程误导,发现队列是没有子队列或根据routekey过滤拿数据的功能的。

路由真实的效果是:允许发送一次,Copy信息同时发散到多个多队:

 

发送: (可以发送1条,同时到匹配路由的3个队列去)

channel.BasicPublish("User", "#.user", false, null, Encoding.UTF8.GetBytes("这是要发送的内容"));

交换机有好几种路由功能,这些先放到后面,放这里不便于入门理解。

对交换机的功能,理解上面中提到的路由真实的效果那一句话即可。

总结:

本篇介绍RabbitMQ的基础概念的含义,有助于快速理解并掌握RabbitMQ。 

标签:入门,队列,RabbitMQ,交换机,链接,channel
From: https://www.cnblogs.com/cyq1162/p/16602500.html

相关文章

  • h3c s6800交换机probe命令
    <H3C>sysSystemView:returntoUserViewwithCtrl+Z.[H3C]probe[H3C-probe]?Probeviewcommands:INTEGER<0-1>SwitchNObcmBCM[H3C-p......
  • 【队列】力扣239:滑动窗口最大值
    给定一个整数数组和一个滑动窗口大小,求在这个窗口的滑动过程中,每个时刻其包含的最大值。示例:输入:nums=[1,3,-1,-3,5,3,6,7],k=3输出:[3,3,5,5,6,7]解释:滑动窗口......
  • 【队列】力扣218:天际线问题
    给定建筑物的起止位置和高度,返回建筑物轮廓(天际线)的拐点。输入是一个二维整数数组,表示每个建筑物的[左端,右端,高度];输出是一个二维整数数组,表示每个拐点的横纵坐标。......
  • 通过supervisor管理laravel队列任务守护进程
    通过supervisor管理laravel队列任务守护进程背景:laravel队列,在调试使用时可以使用phpartisanqueue:work来启用队列,但是实际项目部署后,需要通过守护进程一直启动队列,在这......
  • RabbitMQ安装及简单使用
    1.rabbitmq启动rabbitmq路径:/usr/local/rabbitmq_server-3.7.8在rabbitmq安装目录下,进入到sbin目录,执行:#启动rabbitmqrabbitmq-server./rabbitmq-server2.rabbitmq......
  • 21. Redis---消息队列
    1.前言RedisStream是Redis5.0版本引入的一种新数据类型,同时它也是Redis中最为复杂的数据结构,本节主要对Stream做相关介绍。2.什么是Stream?Stream实际上是......
  • 优先队列 二叉堆 概念
    1.优先队列相比普通队列,其执行顺序先按优先级再按插入顺序。支持至少两种基本操作插入及删除最小。2.二叉堆优先队列的一种实现,是一颗除最下层外被完全填满的二叉树......
  • 消息队列选型
    消息队列选型  参考资料:带你玩转消息队列和相关选型消息队列原理和选型:Kafka、RocketMQ、RabbitMQ和ActiveMQPulsar与Kafka全方位对比(上篇):功能、性能、用例......
  • 利用傻瓜交换机实现单线复用(单网络,不考虑IPTV)
    前言装修的时候像下图这样从弱电箱到客厅电视柜多穿两根网线就没有下面的烦恼了......
  • leetcode 225. Implement Stack using Queues 用队列实现栈(简单)
    一、题目大意请你仅使用两个队列实现一个后入先出(LIFO)的栈,并支持普通栈的全部四种操作(push、top、pop和empty)。实现MyStack类:voidpush(intx)将元素x压入栈顶。......