整合消息队列rabbitmq使用protobuff传输结构数据

整合消息队列rabbitmq使用protobuff传输结构数据

1566发表于2017-07-30

消息队列和protobuff的好处这里就不在赘述了。

一、安装并rabbitmq配置

安装并rabbitmq很简单,先安装Erlang(OTP),再安装rabbitmq。

安装完成后添加一个rabbitmq用户并授权

admin

admin

二、定义proto文件

建立一个proto文件lanhu-msg-demo.proto,内容如下:

message ReqRankNum
{
	required string appid = 1;
	required string appkey = 2;
	required string id = 3;
	required string name = 4;
	required string num = 5;
}
message RPCResult
{
	optional string session = 1;
	required bool succ =2;
	optional string message = 3;
}


使用protobuf-net把proto文件生成c#类cs文件。

把文件lanhu-msg-demo.proto方在ProtoGen目录,然后执行如下代码:

-i:是proto文件名,

-o:是生成的c#类文件的文件名,

-ns:是命名空间


三、集成代码

ProtoGen目录生成的LanhuMsgDemo.cs拷贝到项目中。

3.1、rabbitmq配置信息


3.2、创建消息队列


3.3、消费,取消息


3.4、调用方法


本文:源码下载

小编蓝狐