rabbitmq 一个生产者多个消费者_RabbitMQ入门学习系列(二),单生产者消费者
友情提示
我对我的文章负责,发现好多网上的文章 没有实践,都发出来的,让人走很多弯路,如果你在我的文章中遇到无法实现,或者无法走通的问题。可以直接在公众号《爱码农爱生活 》留言。必定会再次复查原因。让每一篇 文章都能顺利实现。道理讲明白 。原理讲清楚。代码必实现
快速阅读
安装好Rabbitmq-server,Erlang后,在vs中添加 Rabbitmq.client.建立两个控制台应用,实现单生产者单消费者的模式。
友情提示
我对我的文章负责,发现好多网上的文章 没有实践,都发出来的,让人走很多弯路,如果你在我的文章中遇到无法实现,或者无法走通的。可以直接公众号:爱码农爱生活 留言。必定会再次复查原因。让每一篇 文章的流程都能顺利实现。
1.安装rabittmq
提示没有安装elang,要先下载安装erlang
2.下载安装erlang
会自动打开Erlang的下载链接 地址。我的是win7 64位系统,所以我选择下面红框里的这个
3.Erlang和RabbitMq的下载地址备份
今天终于下载下来了。 为了避免以后因为网络问题下不下来,直接备份到百度云
- rabbitmq-server-3.7.15.exe 下载地址
链接:https://pan.baidu.com/s/1aTEtVwNvSV58gzbmLncQlA 提取码:3b1x
- otp_win64_22.0 -erlang 下载地址
链接:https://pan.baidu.com/s/1DF_KDKxTAHRGHZj6LYKdaA
提取码:9oy8
4.OTP是啥
Open Telecom Platform的缩写,简单理解就是一个框架 ,主要是把通用部分代码和业务代码进行分离。具体想多了解的可以参考:https://www.cnblogs.com/john-d/archive/2010/04/16/1711276.html
5.OTP22的安装
安装OTP22 ,直接打开,安装到自己的程序目录就行。 一直next到结束 。
6.安装RabbitMq-server
直接打开,安装到自己的程序目录就行。 一直next到结束
7.官方的入门教程代码下载
https://github.com/rabbitmq/rabbitmq-tutorials
8.RabbitMQ 入门代码 Hello world
Rabbitmq是一个消息中间件,生产者生产消息放入队列中,消费者从队列中拿消息进行消费。
分别给两个项目安装RabbitMQ.client依赖包。 如果用这种方式安装的话,产生的项目是netcore的
好了,vs打开启动项目
不过遇到vs不能调试的错误了。,记得以前也遇到过这个问题,网上好多人说是把msvsmon.exe从别的地方复制一份就可以了,但是我的不行,最后是通过添加删除程序解决的。
感觉这个错误,好像会出现在多个vs版本的时候会容易出现混乱。
但是发现新建的程序台程序是可以使用的。
这个先不用管了直接转为传统的方式,vs打开项目,Nuget添加RabbitMq.client进行测试
重新在console控制台里操作吧。
9.vs中创建生产者
先安装RabbitMQ.Client
生产者代码:
注意:创建的链接如果是远程服务器,要换成远程服务器的IP地址,我们是用localhost在本地测试
创建完链接以后,再创建信道。大多数的api调用都是在信道中完成的。
最后声明一个队列,把我们要发送的消息发送出去。
消息的内容在队列中存的是了一个字节数组 ,我们一般用Encoding.UTF8.GetBytes
static void Main(string[] args){var factory = new ConnectionFactory() { HostName = "localhost" };using (var connection = factory.CreateConnection()){using (var channel = connection.CreateModel()){channel.QueueDeclare(queue: "hello",durable: false, exclusive: false, autoDelete: false, arguments: null);string message = "hello world";var body = Encoding.UTF8.GetBytes(message);channel.BasicPublish(exchange: "", routingKey: "hello", basicProperties: null, body: body);Console.WriteLine("[x] sent {0}", message);}}Console.WriteLine("");Console.ReadLine();}
10.消费者
消费者从消息队列中监听消息 ,要保持持续连接
代码:
注意:
1. Console.ReadLine();的位置,要放在channel代码块中。
- 流程还是建立连接-》创建信道-》定义队列=》
- 因为可能先启动消费者,所以队列也需要进行声明 一下。
- 在使用队列时,要保证队列必须存在。
static void Main(string[] args)
{var factory = new ConnectionFactory() { HostName = "localhost" };using (var connection = factory.CreateConnection()){using (var channel = connection.CreateModel()){channel.QueueDeclare(queue: "hello",durable: false, exclusive: false, autoDelete: false, arguments: null);//以下是区别生产者的var consumer = new EventingBasicConsumer(channel);consumer.Received += (sender, e) =>{var body = e.Body;var message = Encoding.UTF8.GetString(body);Console.WriteLine("Received {0}", message);};channel.BasicConsume(queue: "hello", autoAck: true, consumer: consumer);Console.WriteLine("");Console.ReadLine();}}}
运行效果
代码下载:
链接:https://pan.baidu.com/s/1ETUFWm2ilTY4eONkSqaz-A 提取码:bims
rabbitmq 一个生产者多个消费者_RabbitMQ入门学习系列(二),单生产者消费者相关推荐
- RabbitMQ入门学习系列(二),单生产者消费者
友情提示 我对我的文章负责,发现好多网上的文章 没有实践,都发出来的,让人走很多弯路,如果你在我的文章中遇到无法实现,或者无法走通的问题.可以直接在公众号<爱码农爱生活 >留言.必定会再次 ...
- Asp.Net MVC5入门学习系列⑤
Asp.Net MVC5入门学习系列⑤ 原文:Asp.Net MVC5入门学习系列⑤ 检查VS生产的编辑方法和编辑窗体 前面我们一步使用强类型,然后创建Controller(控制器)的时候,VS默认已 ...
- Asp.Net MVC5入门学习系列⑥
Asp.Net MVC5入门学习系列⑥ 原文:Asp.Net MVC5入门学习系列⑥ 接着上次的篇幅,我们这篇手动来写一个查询的流程代码! 搜索/查询 流程功能的实现 那现在要做搜索(查询)功能我们第 ...
- android 原生开发 3d地图 下载_arcgis api 3.x for js 入门开发系列二不同地图服务展示(附源码下载)...
前言 关于本篇功能实现用到的 api 涉及类看不懂的,请参照 esri 官网的 arcgis api 3.x for js:esri 官网 api,里面详细的介绍 arcgis api 3.x 各个类 ...
- TIA博途SCL入门学习(二)常用基本控制语句用法和举例
TIA博途SCL入门学习(二)常用基本控制语句用法和举例 FOR循环语句 FOR循环可以指定循环的次数,在使用这种循环的时候需要先定义一个INT型变量,并指定计数范围,即循环次数,直到循环次数到达设定 ...
- ajax入门学习(二)小案例Demo1
(尊重劳动成果,转载请注明出处:http://blog.csdn.net/qq_25827845/article/details/55823800冷血之心的博客) ajax入门学习(一) ajax入门 ...
- HFSS入门学习(二)
HFSS入门学习(二) 本文是在前一篇文章:HFSS入门学习(一)链接:https://blog.csdn.net/and_future/article/details/108930315 的基础之上 ...
- WPF入门学习----系列基础教程
WPF入门教程系列目录 WPF入门教程系列二--Application介绍 WPF入门教程系列三--Application介绍(续) WPF入门教程系列四--Dispatcher介绍 WPF入门教程系 ...
- RabbitMQ入门学习系列(三).消息发送接收
快速阅读 用Rabitmq的队列管理,以及如何保证消息在队列中不丢失.通过ack的消息确认和持久化进行操作.以及Rabbit中如何用Web面板进行管理队列.消费者如何处理耗时的任务 生产者代码创建链接 ...
- RabbitMQ入门学习系列(五) Exchange的Direct类型
快速阅读 利用Exchange的Direct类型,实现对队列的过滤,消费者启动以后,输入相应的key值,攻取该key值对应的在队列中的消息 . 从一节知道Exchange有四种类型 Direct,To ...
最新文章
- linux安装grub
- 纹理与表面细节添加方法---小结
- 键盘输入Scanner类方法属性使用
- 树莓派移植SX1278 LoRa通信--使用wiringPiSPI移植SPI通信接口
- C#设计模式之0-简单工厂模式
- 实现两个Mysql数据库同步
- 【笔记】具有O-DU和O-RU的eNB / gNB架构
- 4.2第一个窗口程序
- wxpython制作表格界面_Python wxPython库使用wx.ListBox创建列表框示例
- Guacamole之本地安装Guacamole(二)
- HTML5的WebGL实现的3D和2D拓扑树
- 安卓模拟定位mockLocation,闪退?
- 【译】Jep 文档(2)——基本用法(Basic Usage)
- 手机计算机键盘技巧,【盲打计算器】看似简单,你不一定会的小技巧
- python概述ppt_江红-第1章-Python概述ppt
- 新产品开发过程基本原则
- NW.js之基础篇(2)
- 2023年4月动漫新番最新资讯已公布52部!
- 虞美人盛开的山坡片尾曲_さよならの夏_离别的夏天_歌词_带假名及翻译
- H3C 物联网路由器4G配置