5赞
662
当前位置:  开发笔记 > 编程语言 > 正文

c#rabbitmq简单收发消息的示例代码

这篇文章主要介绍了c#rabbitmq简单收发消息的示例代码,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧

发布消息:(生产者)

   /// 
    /// 发送消息
    /// 
    /// 队列名
    /// 消息内容
    private static void PublishInfo(string queue, string message)
    {
      try
      {
        var factory = new ConnectionFactory();
        factory.HostName = "localhost";//RabbitMQ服务在本地运行
        factory.UserName = "guest";//用户名
        factory.Password = "guest";//密码

        using (var cOnnection= factory.CreateConnection())
        {
          using (var channel = connection.CreateModel())
          {
            bool durable = true;//将消息标记为持久性
            channel.QueueDeclare(queue, durable, false, false, null);

            IBasicProperties properties = channel.CreateBasicProperties();
            properties.DeliveryMode = 2;

            var body = Encoding.UTF8.GetBytes(message);
            channel.BasicPublish("", queue, properties, body); //开始传递

          }
        }
      }
      catch (System.Exception ex)
      {
        Console.WriteLine(ex.ToString());
      }
      Console.ReadLine();
    }

使用:

PublishInfo("test", "222222222222");

 点击test进入队列内部:

消费消息:

方法一:旧版可用

 private static void ConsumeInfo(string queue)
    {
      try
      {
        var factory = new ConnectionFactory();
        factory.HostName = "localhost";//RabbitMQ服务在本地运行
        factory.UserName = "guest";//用户名
        factory.Password = "guest";//密码

        using (var cOnnection= factory.CreateConnection())
        {
          using (var channel = connection.CreateModel())
          {
            //bool durable = true;//将消息标记为持久性
            //channel.QueueDeclare("sljcgx:finish-queue", durable, false, false, null);//声明队列,队列不存在则创建该队列

            //设置prefetchCount : 1来告知RabbitMQ,在未收到消费端的消息确认时,不再分发消息,也就确保了当消费端处于忙碌状态时,不再分配任务。
            channel.BasicQos(prefetchSize: 0, prefetchCount: 1, global: false);
            var cOnsumer= new QueueingBasicConsumer(channel);
           
            //false为手动确认,获取消息后需要添加 channel.BasicAck(ea.DeliveryTag, false)确认
            //true则为自动确认,不需要这行代码
            channel.BasicConsume(queue, false, consumer);

            while (true)
            {
              try
              {
                var ea = (BasicDeliverEventArgs)consumer.Queue.Dequeue();//阻塞函数,获取队列中的消息
                var bodyReceive = ea.Body;
                string message = Encoding.UTF8.GetString(bodyReceive);
                Console.WriteLine(message);
                channel.BasicAck(ea.DeliveryTag, false);// 消息确认信号,确认后该消息将从队列里移除
              }
              catch (System.Exception ex)
              {
                
                Console.WriteLine(ex.Message);
              }
            }
          }

        }
      }
      catch (System.Exception ex)
      {
        Console.WriteLine(ex.ToString());
      }
      Console.ReadLine();
    }

方法二:(通用)

   private static void ConsumeInfo2(string queue)
    {
      try
      {
        var factory = new ConnectionFactory();
        factory.HostName = "localhost";//RabbitMQ服务在本地运行
        factory.UserName = "guest";//用户名
        factory.Password = "guest";//密码
        var cOnnection= factory.CreateConnection();
        var channel = connection.CreateModel();
        channel.QueueDeclare(queue, true, false, false, null);//声明队列,队列不存在则创建该队列
        channel.BasicQos(0, 1, false);//公平分发、同一时间只处理一个消息。

        var cOnsumer= new EventingBasicConsumer(channel); //消费者(指定消息通道)该事件在接收到消息时触发
        consumer.Received += (sender, e) =>
        {
          byte[] body = e.Body.ToArray();  //消息字节数组
          string message = Encoding.UTF8.GetString(body); //消息内容

          Console.WriteLine(message);
          channel.BasicAck(e.DeliveryTag, false);    //手工确认

        };
        channel.BasicConsume(queue, false, consumer);  //消费消息(在当前通道中监听 queue 队列,并进行消费)
        Console.ReadLine();
        connection.Close();
        channel.Close();
      }
      catch (System.Exception ex)
      {
        Console.WriteLine(ex.ToString());
      }
    }

到此这篇关于c# rabbitmq 简单收发消息的示例代码的文章就介绍到这了,更多相关c# rabbitmq 收发消息内容请搜索以前的文章或继续浏览下面的相关文章希望大家以后多多支持!

推荐阅读
  • java语言可以进行:1、Android应用开发;2、金融业应用的服务器程序开发;3、网站开发;4、软件工具开发;5、交易系统开发;6、嵌入式领域开发;7、大数据开发等等。 ... [详细]
  • 区别:Java不可以将一个非布尔值当做布尔值在逻辑表达式中使用,C++却可以。C++引入了操作符重载机制,Java不支持。C++有goto,Java没有goto。C++中有多继承,Java中只有单一继承,但Java可以通过接口实现多继承。 ... [详细]
  • 工业机器人常用编程语言:1、硬件描述语言(HDLs),一般用来描述电气的编程方式;2、Assembly语言;3、MATLAB;4、C#.NET;5、Java;6、Python;7、CC++。 ... [详细]
  • 在我们开发微信页面的时候,需要大量用到了各种呈现的效果,一般可以使用Boostrap的效果来设计不同的页面,不过微信团队也提供很多这方面的资源,包括JSSDK的接口,以及Weui的页面样式和相关功能页面,给我们提供了很大的便利,本文是在自己做的一些H5微信应用页面上做了一些功能总结,希望能够给大家提供一定的帮助。 ... [详细]
  • 通过模板消息接口,公众号能向关注其账号的用户发送预设模板的消息。模板消息仅用于公众号向用户发送重要的服务通知,只能用于符合其要求的服务场景中,如信用卡刷卡通知,商品购买成功通知等。不支持广告等营销类消息以及其它所有可能对用户造成骚扰的消息。本文主要介绍基于C#开发实现公众号模板消息的管理功能。 ... [详细]
  • 本文主要介绍了C#微信开发之接收返回文本消息原理与实现方法,具有一定的参考价值,下面跟着小编一起来看下吧 ... [详细]
  • vscode调试运行c#程序的方法是:1、首先安装【c#extension】插件;2、接着创建workspace文件夹,并打开控制台;3、然后运行【dotnet】命令,创建基础程序进行【restore】;4、最后运行程序即可。 ... [详细]
  • sql是高度非过程化和面向集合的操作语言。使用SQL进行数据操作,用户只需提出“做什么”,而不必指明“怎么做”,因此用户无须了解存取路径,存取路径的选择以及SQL语句的操作过程由系统自动完成;SQL采用集合操作方式。 ... [详细]
  • 要学会使用redis,首先要掌握redis基础知识,像redis命令、字符串、redis、哈希、集合、有序集合、脚本、链接、服务器等相关基础知识。 ... [详细]
  • Redis是一个高性能的key-value数据库,而且Redis是基于内存读取的,所以数据一般都存放中物理内存中,单例Redis最多能处理2.5亿个key,当然数据类型不同能存储的多少也不相同。 ... [详细]
devbox
重新生活好吗
这个家伙很懒,什么也没留下!
PHP1.CN | 中国最专业的PHP中文社区 | DevBox开发工具箱 | json解析格式化 |PHP资讯 | PHP教程 | 数据库技术 | 服务器技术 | 前端开发技术 | PHP框架 | 开发工具 | 在线工具
Copyright © 1998 - 2020 PHP1.CN. All Rights Reserved PHP1.CN 第一PHP社区 版权所有 京ICP备19059560号-4