C#操作RabbitMQ的完整实例
一、下载RabbitMQ
二、下载OTP
三、安装OTP、RabbitMQ
四、配置RabbitMQ
找到bat的目录
执行相关命令
1.添加用户密码 rabbitmqctl add_user wenli wenli
2.设置wenli为管理员rabbitmqctl set_user_tags wenli administrator
3.启动RabbitMQ的web管理rabbitmq-plugins enable rabbitmq_management
4.创建virtual host
5.设置用户权限
点击用户名进行设置
将virtual hosts 权限赋给用户wenli
6.创建Exchanges
五.创建C# console
1.下载RabbitMQ驱动
2.添加引用
3.添加配置
4.测试代码:
using System;
using System.Text;
using System.Threading;
using System.Threading.Tasks;
namespace Wenli.Data.RabbitMQ.Console
{
using Console = System.Console;
class Program
{
static void Main(string[] args)
{
Console.Title = "Wenli.Data.RabbitMQ.Console";
Console.WriteLine("正连接到mq");
try
{
Test();
}
catch (Exception ex)
{
Console.WriteLine("err:" + ex.Message + ex.Source + ex.StackTrace);
}
Console.Read();
}
static void Test()
{
var topic = "testtopic";
var cnn = RabbitMQBuilder.Get(MQConfig.Default).GetConnection();
var operation = cnn.GetOperation(topic);
Console.WriteLine("正连接到订阅【" + topic + "】");
operation.Subscribe();
Console.WriteLine("正在入队");
Task.Factory.StartNew(() =>
{
while (true)
{
operation.Enqueue(Encoding.UTF8.GetBytes(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + " hello!"));
Thread.Sleep(1);
}
});
Console.WriteLine("正在出队");
Task.Factory.StartNew(() =>
{
while (true)
{
var result = operation.Dnqueue();
if (result == null)
{
Thread.Sleep(1);
}
else
{
Console.WriteLine(Encoding.UTF8.GetString(result));
}
}
});
Console.ReadLine();
Console.WriteLine("正在取消订阅");
operation.UnSubscribe();
Console.WriteLine("测试完成");
}
}
}
5.运行结果:
至此C# 成功操作Rabbitmq完成。
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持无名。
同类资源
- c#调用dll,dll加载epk
易语言c#调用dll,dll加载epk例子源代码,通过c#调用dll,易语言写dll调用epk。...
- C#版的模块中所有的api和相关的结构体的声明
C#版的模块中所有的api和相关的结构体的声明例子源代码,直接用易语言封装成dll调用。...
- c#版写的重命名工具
c#版写的重命名工具绿色版,之前记得有个跟这个界面类似的重命名,后来一直找不到了,下载转存太麻烦了就自己弄...
- C#开源利用OpenCV找图经典例子
C#开源利用OpenCV找图经典例子绿色版,没有使用最新本版是因为该本版.NET4.0就能跑。...
- 把其它应用嵌入到C#窗口源代码
把其它应用嵌入到C#窗口源代码本文件感兴趣的可以参考一下,把一个现有的窗体应用程序界面嵌入到自己开发的...
- C#H264格式视频解码
C#H264格式视频解码本文件感兴趣的可以参考一下,使用FFMPEG解码为H264视频文件。...
- C# WinCE播放器WinCE_PlayMusic
C#WinCE播放器本文件感兴趣的可以参考一下,可播放*.wav,*.mp3等语音文件。...
- C#自动远程时间同步助手
C#自动远程时间同步助手本文件感兴趣的可以参考一下,时间服务器的ntp服务开启状态。...
- C#文件加密解密完整项目
C#文件加密解密完整项目本文件感兴趣的可以参考一下,实现C#加密各种文件和解密加密后的文件。...
- C#基于UDP的呼叫应答系统
C#基于UDP的呼叫应答系统本文件感兴趣的可以参考一下,一个简单的基于UDP的呼叫应答及时提醒系统。...
- C#商品销售管理系统
C#商品销售管理系统本文件感兴趣的可以参考一下,数据库课程设计做的,用到了SQLServer数据库。...
- C#指纹机考勤查询系统
C#指纹机考勤查询系统本文件感兴趣的可以参考一下,必到点考勤查询系统,可以根据日期查询签到信息。...