c#操做RabbitMQ使用json格式写入消息队列

发送消息

//rabbitmqctl stop_app 中止服务，会清除queue
    //rabbitmqctl start_app 开启服务
    //rabbitmqctl list_queues 查询当前队列
    //rabbitmqctl purge_queue kibaQueue 清空指定queue队列的数据
    /// <summary>
    /// 发送消息
    /// </summary> 
public class TempSpfxjgLst
        {
            public List<TempSpfxjg> Records { get; set; }
        }

        public class TempSpfxjg
        {
            public string algorithm_types { get; set; }
            public string camera_id { get; set; }
            public string current_time { get; set; }
            public string image_url { get; set; }
            public string stay_time { get; set; }
            public string target_position { get; set; }
            public string target_type { get; set; }
            public string task_id { get; set; }
            public string task_type { get; set; }
        }   
static void Main(string[] args)
        {

            var factory = new ConnectionFactory();
            factory.HostName = "localhost";//主机名，Rabbit会拿这个IP生成一个endpoint，这个很熟悉吧，就是socket绑定的那个终结点。
            factory.UserName = "guest";//默认用户名,用户能够在服务端自定义建立，有相关命令行
            factory.Password = "guest";//默认密码 


            TempSpfxjg tmpJson1 = new TempSpfxjg();
            tmpJson1.algorithm_types = "9";
            tmpJson1.camera_id = "1004";
            tmpJson1.current_time = "2019-05-08 23:29:47";
            tmpJson1.image_url = "http://192.168.31.115/images/1004/20190107T092411_398729662.jpg";
            tmpJson1.stay_time = "0.000000";
            tmpJson1.target_position = "617,81,58,79";
            tmpJson1.target_type = "2";
            tmpJson1.task_id = "123456";
            tmpJson1.task_type = "4";

            TempSpfxjgLst lst = new TempSpfxjgLst();
            lst.Records = new List<TempSpfxjg>();
            lst.Records.Add(tmpJson1);
           string jsontext = JsonConvert.SerializeObject(lst);
            //byte[] buffer = Encoding.UTF8.GetBytes(JsonConvert.SerializeObject(jsonText));

            using (var connection = factory.CreateConnection())//链接服务器，即正在建立终结点。
            {
                //建立一个通道，这个就是Rabbit本身定义的规则了，若是本身写消息队列，这个就能够开脑洞设计了
                //这里Rabbit的玩法就是一个通道channel下包含多个队列Queue
                using (var channel = connection.CreateModel())
                {
                    //for (int i = 0; i < 100; i++)
                    //{
                        channel.QueueDeclare("SPFXJG", false, false, false, null);//建立一个名称为""的消息队列
                        var properties = channel.CreateBasicProperties();
                        properties.DeliveryMode = 1;
                        string message = "Hello Word"; //传递的消息内容 
                        channel.BasicPublish(exchange: "", routingKey: "SPFXJG", properties, Encoding.UTF8.GetBytes(jsontext)); //生产消息
                        Console.WriteLine($"Send:{message}");
                       //  Thread.Sleep(3000);
                   // }
                }
            }
            Console.ReadLine();
        }

　　接收消息

static void Main(string[] args) { var factory = new ConnectionFactory(); factory.HostName = "localhost"; factory.UserName = "guest"; factory.Password = "guest"; using (var connection = factory.CreateConnection()) { using (var channel = connection.CreateModel()) { channel.QueueDeclare("SPFXJG", false, false, false, null); /* 这里定义了一个消费者，用于消费服务器接受的消息 * C#开发须要注意下这里，在一些非面向对象和面向对象比较差的语言中，是很是重视这种设计模式的。 * 好比RabbitMQ使用了生产者与消费者模式，而后不少相关的使用文章都在拿这个生产者和消费者来表述。 * 可是，在C#里，生产者与消费者对咱们而言，根本算不上一种设计模式，他就是一种最基础的代码编写规则。 * 因此，你们不要复杂的名词吓到，其实，并没那么复杂。 * 这里，其实就是定义一个EventingBasicConsumer类型的对象，而后该对象有个Received事件，该事件会在服务接收到数据时触发。 */ 
                    var consumer = new EventingBasicConsumer(channel);//消费者 
                    channel.BasicConsume("SPFXJG", true, consumer);//消费消息 autoAck参数为消费后是否删除
                    consumer.Received += (model, ea) => { var body = ea.Body; var message = Encoding.UTF8.GetString(body); Console.WriteLine("Received： {0}", message); }; Console.ReadLine(); } } }

在本地查看队列效果