.Net RabbitMQ（消息队列）

文章目录

  • 一.RabbitMQ 介绍以及工作模式
    • 1.RabbitMQ的介绍：
    • 2.RabbitMQ的工作模式：
  • 二.RabbitMQ安装
    • 1.安装Erlang语言环境
    • 2.安装RabbitMQ
  • 三.在.Net中使用RabbitMQ
    • 1.HelloWorld模式
    • 2.工作队列模式
    • 3.发布订阅模式
    • 4.Routing路由模式和Topics通配符模式

一.RabbitMQ 介绍以及工作模式

1.RabbitMQ的介绍：

RabbitMQ 是一个开源的消息代理软件，它实现了高级消息队列协议（AMQP）的标准，同时也支持其他消息协议，如 MQTT。它最初由 Rabbit Technologies 公司开发，后来成为了 Pivotal Software 的一部分，现在则是由 VMware 管理。

以下是 RabbitMQ 的一些关键特点和功能：

消息队列： RabbitMQ 允许应用程序之间通过发送和接收消息进行通信。它作为一个中间件，负责接收、存储和路由消息，以确保消息能够可靠地传递到目标应用程序。

灵活的消息路由： RabbitMQ 支持不同类型的交换机（exchange），如 direct、topic、fanout 和 headers，每种类型的交换机都有不同的消息路由方式，使得消息的分发更加灵活高效。

持久化： RabbitMQ 支持将消息持久化到磁盘，以确保即使在代理重启后，消息也不会丢失。它还允许将队列和交换机设置为持久化，以提高系统的可靠性。

集群和高可用性： RabbitMQ 支持构建具有高可用性和可伸缩性的集群。通过将多个 RabbitMQ 节点组成集群，可以实现消息的负载均衡和故障转移，从而提高系统的可靠性和性能。

消息确认机制： RabbitMQ 支持消息确认机制，即生产者可以选择在消息发送到队列后等待消费者对消息的确认，以确保消息被成功处理。这种机制可以保证消息不会丢失，并且可以防止消息重复处理。

插件系统： RabbitMQ 提供了丰富的插件系统，可以通过插件扩展其功能，如集成其他消息协议、实现认证和授权、监控和管理等。

多语言客户端： RabbitMQ 提供了多种编程语言的客户端库，如 Java、Python、Ruby、C# 等，使得开发者可以方便地与 RabbitMQ 进行交互。

总的来说，RabbitMQ 是一个功能强大、可靠性高的消息代理软件，广泛应用于各种分布式系统和应用场景，如微服务架构、实时数据处理、任务调度等。

2.RabbitMQ的工作模式：

RabbitMQ 的工作模式主要涉及以下几个关键组件：生产者、交换机（Exchange）、队列（Queue）和消费者。通过这些组件，RabbitMQ 实现了消息的传输和路由。

生产者（Producer）： 生产者是消息的发送者，它负责将消息发送到 RabbitMQ 中。生产者通常将消息发送到一个特定的交换机，然后由交换机将消息路由到一个或多个队列中。

交换机（Exchange）： 交换机是消息的路由中心，负责接收从生产者发送的消息，并根据指定的路由规则将消息路由到一个或多个队列中。RabbitMQ 提供了不同类型的交换机，如 direct、topic、fanout 和 headers，每种类型的交换机都有不同的路由规则。

队列（Queue）： 队列是消息的存储容器，它负责存储从交换机接收到的消息，以便消费者可以按顺序处理消息。每个队列都有一个唯一的名称，并且可以有多个消费者订阅同一个队列。

消费者（Consumer）： 消费者是消息的接收者，它负责从队列中获取消息并进行处理。消费者通常会订阅一个或多个队列，并在收到消息后执行相应的业务逻辑。

RabbitMQ 的工作流程可以简单描述为：

生产者将消息发送到一个特定的交换机。
交换机根据指定的路由规则将消息路由到一个或多个队列中。
消费者从队列中获取消息并进行处理。
在这个过程中，RabbitMQ 提供了丰富的路由和消息确认机制，以确保消息能够可靠地传递和处理。

二.RabbitMQ安装

bilibili三分钟RabbitMQ安装教程，亲测有效

1.安装Erlang语言环境

a.RabbitMQ是Erlang语言开发的，所以我们首先去Erlang官网下载Erlang环境

在这里插入图片描述

b.下载完成后，我们直接根据默认的情况安装到电脑上，然后进入windows的“高级系统设置”，设置Erlang环境变量

给他一个变量名称，然后浏览刚才安装的Erlang目录位置，获取变量值

在这里插入图片描述

c.在环境变量的path中，配置刚才配置好的Erlang环境

在这里插入图片描述

2.安装RabbitMQ

a.接着我们进入RabbitMQ官网下载RabbitMQ

在这里插入图片描述
b.RabbitMQ下载安装完毕后，我们进入RabbitMQ的sbin目录中，用cmd终端行打开命令行，分别执行以下命令安装RabbitMQ Cli

a.在cmd中，进入RabbitMQ的sbin目录下，输入 
rabbitmq-plugins enable rabbitmq_management 
命令安装RabbitMQ Ctlb.输入 
rabbitmqctl status 
命令检验是否安装成功

c.进入服务中，先停止RabbitMQ的服务，然后在RabbitMQ的sbin目录中，启动RabbitMQ.Server.bat文件，最后再重启RabbitMQ服务，就可以进入浏览器访问http://localhost:15672/进入RabbitMQ服务端了

1)停止rabbitMQ服务

在这里插入图片描述

2)启动rabbitmq.server.bat文件

在这里插入图片描述

3)重启RabbitMQ服务后，使用浏览器进入http://localhost:15672/
斜体样式
默认的账户名密码都是：guest
在这里插入图片描述

三.在.Net中使用RabbitMQ

bilibili某博主详细解说：RabbitMQ从零到高可用集群

1.HelloWorld模式

HelloWorld模式通常被视为RabbitMQ的点对点模式，生产者将消息放入队列中，消费者直接从队列中读取

a.生产者代码：

var factory = new ConnectionFactory();
factory.HostName = "localhost";
factory.Port = 5672;
factory.UserName = "guest";
factory.Password = "guest";using (var connection = factory.CreateConnection())
{using (var channel = connection.CreateModel()){//创建队列，声明并创建一个队列，如果队列已存在，则使用这个队列//第一个参数：队列名称ID//第二个参数：是否持久化，false对应不持久化数据，MQ停掉数据就会丢失//第三个参数，是否队列私有化，flase达标所有的消费则会都可以访问，true代表只有第一次拥有它的消费者才能一直使用//第四个参数：是否自动删除，false代表链接停掉后不自动删除这个队列channel.QueueDeclare("hello",true,false,false,null);string message = $"Hellow RabbitMQ-{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}";var body = Encoding.UTF8.GetBytes(message);channel.BasicPublish("","hello",null,body);Console.WriteLine($"RabbitMQ生产者已发送{message}");Console.ReadKey();}
}

b.消费者代码：

 var factory = new ConnectionFactory();factory.HostName = "localhost";factory.Port = 5672;factory.UserName = "guest";factory.Password = "guest";using (var connection = factory.CreateConnection()){using (var channel = connection.CreateModel()){//创建一个名为hello的消息队列channel.QueueDeclare("hello",true,false,false,null);var consumer = new EventingBasicConsumer(channel);channel.BasicConsume("hello",false,consumer);consumer.Received += (model, e) =>{var body = e.Body.ToArray();var message = Encoding.UTF8.GetString(body);Console.WriteLine("RabbitMQ消费者接收到消息：" + message);};channel.BasicConsume("hello",false,consumer);Console.WriteLine("Press [Enter] to exit");Console.ReadKey();}}

c.运行结果：

在这里插入图片描述

2.工作队列模式

工作队列模式，也称任务队列模式，生产者将任务传递到队列中，多个消费者竞争消费队列中的消息，一条消息只对应一个消费者

a.生产者代码：

 var factory = new ConnectionFactory();factory.HostName = "localhost";factory.Port = 5672;factory.UserName = "guest";factory.Password = "guest";using (var connection = factory.CreateConnection() ){using (var channel = connection.CreateModel()){channel.QueueDeclare("WorkQueue",true,false,false,null);for (int i = 0; i < 10; i++){var msg = $"消息队列ID10000{i}发送成功，{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss:fff")}";var body = Encoding.UTF8.GetBytes(msg);channel.BasicPublish("","WorkQueue",null,body);Console.WriteLine($"已发送：{msg}");}Console.ReadKey();}}

b.消费者1代码：

 var factory = new ConnectionFactory();factory.HostName = "localhost";factory.Port = 5672;factory.UserName = "guest";factory.Password = "guest";using (var connection = factory.CreateConnection()){using (var channel = connection.CreateModel()){//创建一个名为hello的消息队列channel.QueueDeclare("WorkQueue", true, false, false, null);//basicqos，MQ不再对消费者一次发送多条请求，而是一条处理完毕（确然后）再从队列中获取新的channel.BasicQos(0, 1, false);var consumer = new EventingBasicConsumer(channel);channel.BasicConsume("WorkQueue", false, consumer);consumer.Received += (model, e) =>{var body = e.Body.ToArray();var message = Encoding.UTF8.GetString(body);Thread.Sleep(100);Console.WriteLine("RabbitMQ消费者接收到消息：" + message);//消息确认：一旦消费者成功处理了任务，它会发送确认消息给 RabbitMQ，告知 RabbitMQ 该消息已经被处理并可以从队列中删除。如果消费者在处理任务时发生错误，消息将会被重新放回队列中，以便其他消费者重新尝试处理。channel.BasicAck(e.DeliveryTag,false);};channel.BasicConsume("WorkQueue", false, consumer);Console.WriteLine("Press [Enter] to exit");Console.ReadKey();}}

c.消费者2代码：

与消费者1代码一致

d.运行结果：

在这里插入图片描述

3.发布订阅模式

发布/订阅（Publish/Subscribe）模式是一种消息传递模式，用于将消息广播给多个消费者。在这种模式下，生产者将消息发送到一个交换机（Exchange）中，而不是直接发送到队列中。交换机则将消息广播给与之绑定的多个队列，每个队列都有一个或多个消费者来接收消息。

a.生产者代码：

var factory = new ConnectionFactory();
factory.HostName = "localhost";
factory.Port = 5672;
factory.UserName = "guest";
factory.Password = "guest";using (var connection = factory.CreateConnection())
{using (var channel = connection.CreateModel()){var msg = "20摄氏度";var body = Encoding.UTF8.GetBytes(msg);channel.BasicPublish("aweather","",null,body);Console.WriteLine("天气发送成功："+msg);}
}

b.消费者1代码：

var factory = new ConnectionFactory();
factory.HostName = "localhost";
factory.Port = 5672;
factory.UserName = "guest";
factory.Password = "guest";using (var connection = factory.CreateConnection())
{using (var channel = connection.CreateModel()){channel.ExchangeDeclare("aweather", ExchangeType.Fanout);//声明消息队列channel.QueueDeclare("HuBei", true, false, false, null);channel.QueueBind("HuBei", "aweather", "");var consumer = new EventingBasicConsumer(channel);consumer.Received += (model, e) =>{var msg = Encoding.UTF8.GetString(e.Body.ToArray());Console.WriteLine("湖北收到天气信息：" + msg);channel.BasicAck(e.DeliveryTag, false);};channel.BasicConsume("HuBei", false, consumer);Console.WriteLine("Press [Enter] to exit");Console.ReadKey();}
}

c.消费者2代码：

var factory = new ConnectionFactory();
factory.HostName = "localhost";
factory.Port = 5672;
factory.UserName = "guest";
factory.Password = "guest";using (var connection = factory.CreateConnection())
{using (var channel = connection.CreateModel()){channel.ExchangeDeclare("aweather",ExchangeType.Fanout);//生命消息队列channel.QueueDeclare("HuNan",true,false,false,null);channel.QueueBind("HuNan","aweather","");var consumer = new EventingBasicConsumer(channel);consumer.Received += (model, e) =>{var msg = Encoding.UTF8.GetString(e.Body.ToArray());Console.WriteLine("湖南收到天气信息："+msg);channel.BasicAck(e.DeliveryTag,false);};channel.BasicConsume("HuNan",false,consumer);Console.WriteLine("Press [Enter] to exit");Console.ReadKey();}
}

d.运行结果：

在这里插入图片描述

4.Routing路由模式和Topics通配符模式

Routing路由模式，是发布订阅模式的延伸，在发布订阅模式的基础上，分配
路由键（Routing Key），消费者根据路由键匹配队列中对用的消息

Topics通配符模式，是Routing路由模式的延伸，*用于匹配一个单词，#用于匹配零个或多个单词，用于替换匹配路由键

注意：一个队列只能匹配一个通配符，但是可以匹配多个路由规则，路由模式和通配符模式可以嵌套使用

a.生产者代码：

var dic = new Dictionary<string, string>();
dic.Add("china.hunan.changsha.20240418","中国湖南长沙2024年04月18日天气数据");
dic.Add("china.hubei.wuhan.20240418", "中国湖北武汉2024年04月18日天气数据");
dic.Add("china.beijing.20240418", "中国北京2024年04月18日天气数据");
dic.Add("us.flld.20240418", "美国弗罗里达2024年04月18日天气数据");var factory = new ConnectionFactory();
factory.HostName = "localhost";
factory.Port = 5672;
factory.UserName = "guest";
factory.Password = "guest";using (var connection = factory.CreateConnection())
{using (var channel = connection.CreateModel()){foreach (var item in dic){channel.BasicPublish("weather",item.Key,null,Encoding.UTF8.GetBytes(item.Value));}Console.WriteLine("气象信息发送成功");}
}

b.消费者1代码：

var factory = new ConnectionFactory();
factory.HostName = "localhost";
factory.Port = 5672;
factory.UserName = "guest";
factory.Password = "guest";using (var connection = factory.CreateConnection())
{using (var channel = connection.CreateModel()){channel.ExchangeDeclare("weather",ExchangeType.Direct);channel.QueueDeclare("us",true,false,false,null);//通配符模式channel.QueueBind("us","weather", "us.*.20240418");//路由模式channel.QueueBind("us","weather", "china.beijing.20240418");channel.BasicQos(0, 1, false);var customer = new EventingBasicConsumer(channel);customer.Received += (model, e) =>{var msg = Encoding.UTF8.GetString(e.Body.ToArray());Console.WriteLine("美国收到天气信息："+msg);channel.BasicAck(e.DeliveryTag,false);};channel.BasicConsume("us",false,customer);Console.WriteLine("Press [Enter] to exit");Console.Read();}
}

c.消费者2代码：

var factory = new ConnectionFactory();
factory.HostName = "localhost";
factory.Port = 5672;
factory.UserName = "guest";
factory.Password = "guest";
using (var connection = factory.CreateConnection())
{using (var channel = connection.CreateModel()){channel.ExchangeDeclare("weather",ExchangeType.Direct);channel.QueueDeclare("china",true,false,false,null);//路由模式channel.QueueBind("china","weather", "china.hunan.changsha.20240418");channel.QueueBind("china", "weather", "china.hubei.wuhan.20240418");channel.QueueBind("china", "weather", "china.beijing.20240418");//通配符模式//channel.QueueBind("china", "weather", "china.#");channel.BasicQos(0,1,false);var consumer = new EventingBasicConsumer(channel);consumer.Received += (model, e) =>{var msg = Encoding.UTF8.GetString(e.Body.ToArray());Console.WriteLine("中国收到天气消息："+msg);channel.BasicAck(e.DeliveryTag,false);};channel.BasicConsume("china",false,consumer);Console.WriteLine("Press [Enter] to exit");Console.Read();}
}

d.运行结果：

在这里插入图片描述

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.hqwc.cn/news/630807.html

如若内容造成侵权/违法违规/事实不符，请联系编程知识网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

Html面试题汇总

Html面试题汇总

1. DOCTYPE(⽂档类型) 的作⽤ <!DOCTYPE>文档类型声明&#xff0c;作用就是告诉浏览器使用哪种html版本来显示网页 <!DOCTYPE html> 的作用就是让浏览器进入标准模式&#xff0c;使用最新的 HTML5 标准来解析渲染页面 它是一个文档类型声明标签&#xff0c;不是…
阅读更多...
YoloV8改进策略：注意力改进、Neck层改进|自研全新的Mamba注意力|即插即用，简单易懂|附结构图|检测、分割、关键点均适用（独家原创，全世界首发）

YoloV8改进策略：注意力改进、Neck层改进|自研全新的Mamba注意力|即插即用，简单易懂|附结构图|检测、分割、关键点均适用（独家原创，全世界首发）

摘要 无Mamba不狂欢，本文打造基于Mamba的注意力机制。全世界首发基于Mamba的注意力啊！对Mamba感兴趣的朋友一定不要错过啊！ 基于Mamba的高效注意力代码和结构图 import torch import torch.nn as nn # 导入自定义的Mamba模块 from mamba_ssm import Mamba class Eff…
阅读更多...
EPSON晶振应用到汽车电子产品上的型号有哪些？

EPSON晶振应用到汽车电子产品上的型号有哪些？

EPSON品牌应用在汽车电子产品上的晶振.&#xff0c;当然也少不了晶振可能最熟悉的就是32.768K系列和26MHZGPS晶振用的多。 在汽车里每一个部件都应有的不一样,甚至多次使用到同一尺寸,不同频率的晶振.爱普生品牌晶振型号就有几百种,很容易混淆,要想记住汽车里所应用到的不是件…
阅读更多...
Debian12 中重新安装MSSQL 并指定服务器、数据库、数据表字段的字符排序规则和默认语言等参数

Debian12 中重新安装MSSQL 并指定服务器、数据库、数据表字段的字符排序规则和默认语言等参数

在 Linux 上配置 SQL Server 设置 - SQL Server | Microsoft Learn 零、查看sql server 服务器支持的字符排序规则 SELECT Name from sys.fn_helpcollations() where name Like Chinese% go------ Chinese_PRC_CI_AI Chinese_PRC_CI_AI_WS Chinese_PRC_CI_AI_KS Chinese_PRC_…
阅读更多...
第十四届蓝桥杯Java B组省赛部分题解

第十四届蓝桥杯Java B组省赛部分题解

1、阶乘求和 解析 当n足够大时，阶乘和的后几个数字会趋于稳定，即相等，所以只需要多试几次，找到后9位相同部分。 答案 420940313代码实现 package contest;import java.util.*;public class Main
阅读更多...
数据库--Sqlite3

数据库--Sqlite3

1、思维导图 2sqlite3在linux中是实现数据的增删&#xff0c;改 #include<myhead.h> int main(int argc, const char *argv[]) { //1、定义一个数据库句柄指针 sqlite3* ppDb NULL; //2、创建或打开数据库 if(sqlite3_open("./mydb…
阅读更多...
CSS导读 （CSS的三大特性 上）

CSS导读 （CSS的三大特性 上）

&#xff08;大家好&#xff0c;今天我们将继续来学习CSS的相关知识&#xff0c;大家可以在评论区进行互动答疑哦~加油&#xff01;&#x1f495;&#xff09; 目录 五、CSS的三大特性 5.1 层叠性 5.2 继承性 5.2.1 行高的继承 5.3 优先级 小练习 五、CSS的三大特性 …
阅读更多...
数据赋能（61）——要求：数据管理部门职责

数据赋能（61）——要求：数据管理部门职责

“要求&#xff1a;数据管理部门职责”是作为标准的参考内容编写的。 数据管理部门职责在于以数据资源为核心&#xff0c;将原始数据转化为可被业务部门与数据服务部门有效利用的数据资源&#xff0c;以支持业务赋能的实现。 数据管理要确保数据的完整性、准确性与一致性&…
阅读更多...
管道流设计模式结合业务

管道流设计模式结合业务

文章目录 流程图代码实现pomcontextEventContextBizTypeAbstractEventContext filterEventFilterAbstractEventFilterEventFilterChainFilterChainPipelineDefaultEventFilterChain selectorFilterSelectorDefaultFilterSelector 调用代码PipelineApplicationcontrollerentitys…
阅读更多...
MySql安装（Linux）

MySql安装（Linux）

一、清除原来的mysql环境 在前期建议使用root用户来进行操作&#xff0c;使用 su -来切换成root用户&#xff0c;但是如果老是提示认证失败&#xff0c;那么有可能我们的root密码并没有被设置&#xff0c; 我们可以先设置root的密码 sudo passwd root 然后就可以切换了。 …
阅读更多...
遥感图像分割 | 基于一种类似UNet的Transformer算法实现遥感城市场景图像的语义分割_适用于卫星图像+航空图像+无人机图像

遥感图像分割 | 基于一种类似UNet的Transformer算法实现遥感城市场景图像的语义分割_适用于卫星图像+航空图像+无人机图像

项目应用场景 面向遥感城市场景图像语义分割场景&#xff0c;项目采用类似 UNet 的 Transformer 深度学习算法来实现&#xff0c;项目适用于卫星图像、航空图像、无人机图像等。 项目效果 项目细节 > 具体参见项目 README.md (1) 安装依赖 conda create -n airs python3.8…
阅读更多...
neo4j使用详解（终章、neo4j的java driver使用模板及工具类——＜可用于生产＞）

neo4j使用详解（终章、neo4j的java driver使用模板及工具类——＜可用于生产＞）

Neo4j系列导航： neo4j安装及简单实践 cypher语法基础 cypher插入语法 cypher插入语法 cypher查询语法 cypher通用语法 cypher函数语法 neo4j索引及调优 neo4j java Driver等更多 1. 简介 本文主要是java使用neo4j driver操作neo4j的模板项目及非常有用的工具类，主要包括： 图…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023