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

 更新时间:2020-09-24 15:09:12   作者:佚名   我要评论(0)

发布消息:(生产者)


/// <summary>
/// 发送消息
/// </summary>
/// <param name="queue">队列名</param>
/// <param name="message">消息

发布消息:(生产者)

   /// <summary>
    /// 发送消息
    /// </summary>
    /// <param name="queue">队列名</param>
    /// <param name="message">消息内容</param>
    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 收发消息内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家!

您可能感兴趣的文章:
  • C#调用RabbitMQ实现消息队列的示例代码
  • C#操作RabbitMQ的完整实例
  • C#实现rabbitmq 延迟队列功能实例代码

相关文章

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

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

    发布消息:(生产者) /// <summary> /// 发送消息 /// </summary> /// <param name="queue">队列名</param> /// <param name="message">消息
    2020-09-24
  • ASP.net百度主动推送功能实现代码

    ASP.net百度主动推送功能实现代码

    官方提供了curl、post、php、ruby的实现示例,并没有C#的官方示例。既然提供了post的方式,那么就可以用C#实现,下面是实现代码: ASP.net百度主动推送代码范例 p
    2020-09-24
  • ASP .NET Core API发布与部署以及遇到的坑和解决方法

    ASP .NET Core API发布与部署以及遇到的坑和解决方法

    最近在写.Net Core的API,由于之前没接触过Core,所以自己的想法很简单,感觉和.Net都是差不多的东西,发布部署还是按.Net的那一套来,可谓是困难重重,走了
    2020-09-24
  • 深入浅析ASP在线压缩access数据库的方法

    深入浅析ASP在线压缩access数据库的方法

    ASP在线压缩ACCESS数据库原理很简单:利用JRO.JetEngine的压缩功能建立一个新的数据库文件,然后把原来的删掉、替换!既然这样,压缩程序只需几行就ok了! 把下面的
    2020-09-24
  • 如何利用PHP实现上传图片功能详解

    如何利用PHP实现上传图片功能详解

    HTML文件 一、 设置编码UTF-8 对于中文网页需要使用<meta charset="utf-8">声明编码,否则会出现乱码。 二 、form表单 <form>标签用于为用户输入创建 HTML 表单,表
    2020-09-24
  • Openlayers实现点闪烁扩散效果

    Openlayers实现点闪烁扩散效果

    本文实例为大家分享了Openlayers实现点闪烁扩散效果的具体代码,供大家参考,具体内容如下 点闪烁样式: DOM的样式实现 /**橙色点扩散闪烁样式*/ .point_animati
    2020-09-24
  • vue使用openlayers实现移动点动画

    vue使用openlayers实现移动点动画

    本文实例为大家分享了vue使用openlayers实现移动点动画的具体代码,供大家参考,具体内容如下 做项目时,本来打算仿照官网的Example中动画制作,引入vue中后,发现它
    2020-09-24
  • SpringBoot后端接口的实现(看这一篇就够了)

    SpringBoot后端接口的实现(看这一篇就够了)

    摘要:本文演示如何构建起一个优秀的后端接口体系,体系构建好了自然就有了规范,同时再构建新的后端接口也会十分轻松。 一个后端接口大致分为四个部分组成:接口地
    2020-09-24
  • MySQL MyISAM 与InnoDB 的区别

    MySQL MyISAM 与InnoDB 的区别

    区别: 1. InnoDB支持事务,MyISAM不支持,对于InnoDB每一条SQL语言都默认封装成事务,自动提交,这样会影响速度,所以最好把多条SQL语言放在begin和commit之间,
    2020-09-24
  • 详解bat文件暂停延时的脚本代码

    详解bat文件暂停延时的脚本代码

    ping 192.0.2.2 -n 1 -w 10000 > nul 该-w 10000部分指定所需的超时(以毫秒为单位)。 该-n 1部分告诉ping它应该只尝试一次(通常会尝试4次)。 该> nul部分已
    2020-09-24

最新评论