2.RabbitMQ的quick start
2024-10-01 23:50:18
1.首先要安装 RabbitMQ Client
2.创建一个控制台项目 取名 Publisher代码如下:
using RabbitMQ.Client;
using System;
using System.Text; namespace Publisher
{
class Program
{
static void Main(string[] args)
{
ConnectionFactory factory = new ConnectionFactory()
{
HostName = "127.0.0.1",
UserName = "mytest",
Password="mytest"
};
//第一步:创建connection
var connection = factory.CreateConnection();
//第二步:创建channel
var channel = connection.CreateModel();
//第三步:申明交换机 //第四步:声明一个队列
channel.QueueDeclare("manQueue", true, false, false, null);
var msg = Encoding.UTF8.GetBytes("希望!");
//第五步:发布消息
channel.BasicPublish(string.Empty, routingKey: "manQueue", basicProperties: null, body: msg); Console.WriteLine("完成");
}
}
}
3.创建一个控制台项目 取名 Consumer代码如下:
using RabbitMQ.Client;
using System;
using System.Text; namespace Consumer
{
class Program
{
static void Main(string[] args)
{
ConnectionFactory factory = new ConnectionFactory()
{
HostName = "127.0.0.1",
UserName = "mytest",
Password = "mytest"
};
//第一步:创建connection
var connection = factory.CreateConnection();
//第二步:创建channel
var channel = connection.CreateModel();
//第三步:申明交换机 //第四步:获取消息
var result = channel.BasicGet("manQueue", true);
var msg = Encoding.UTF8.GetString(result.Body); Console.WriteLine(msg);
}
}
}
最新文章
- MySQL复制-设置延迟复制
- Tomcat内存溢出解决办法
- 一个操作Sql2005数据库的类(备份,还原,分离,附加,添加删除用户等操作)(转载)
- C++14介绍
- virtualbox 虚拟机网络设置
- javascript 检测密码强度
- JavaScript 常见陷阱
- [转]修改hosts文件不起作用
- Struts2入门这一篇就够了
- OpenCV——老照片效果
- javascript预览图片——IT轮子系列(九)
- rem布局原理深度理解(以及em/vw/vh)
- python 库安装方法及常用库
- springboot之异步调用@Async
- ClassNotFoundException和NoClassDefFoundError的解决办法
- java &;&;与||短路的详解
- Java多线程——死锁
- QComboBox 树形视图选择
- [转]google gflags 库完全使用
- ubuntu18.04下搭建深度学习环境anaconda2+ cuda9.0+cudnn7.0.5+tensorflow1.7【原创】【学习笔记】