首页 > 其他分享 >RabbitMQ 生产者和消费代码实例

RabbitMQ 生产者和消费代码实例

时间:2022-10-13 00:12:40浏览次数:35  
标签:false 生产者 factory RabbitMQ 实例 Rabbit var properties channel

     启动服务 

    1.进入rabbitmq的安装 sbin目录下cmd进入命令窗口

         

 

 

     2.cmd输入命令 rabbitmq-server.bat,如图启动成功

          

 

     3.在浏览器访问  http://localhost:15672,默认用户名密码都是 guest 如下 

 

        

 

      

 

 

       4.生成消费者信息代码实例   引用包

      

     public static void Connection()
        {

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

            using (var connection = factory.CreateConnection())//连接服务器,即正在创建终结点。
            {
                //创建一个通道,这个就是Rabbit自己定义的规则了,如果自己写消息队列,这个就可以开脑洞设计了
                //这里Rabbit的玩法就是一个通道channel下包含多个队列Queue
                using (var channel = connection.CreateModel())
                {
                    channel.QueueDeclare("kibaQueue", false, false, false, null);//创建一个名称为kibaqueue的消息队列
                    var properties = channel.CreateBasicProperties();
                    properties.DeliveryMode = 1;
                    string message = "I am Kiba518"; //传递的消息内容
                    channel.BasicPublish("", "kibaQueue", properties, Encoding.UTF8.GetBytes(message)); //生产消息
                    Console.WriteLine($"Send:{message}");
                }

            }

        }

 

 

 这里是生产者生成的三条消息

 

   

 

标签:false,生产者,factory,RabbitMQ,实例,Rabbit,var,properties,channel
From: https://www.cnblogs.com/kkds/p/16786598.html

相关文章

  • 应用实例(三):柱状图
    基础使用frompyecharts.chartsimportBarfrompyecharts.optionsimportLabelOpts#使用Bar构建基础柱状图bar=Bar()#添加x轴的数据bar.add_xaxis(["中国",......
  • RabbitMQ 镜像队列
    一、基本原理1.工作原理搭建RabbitMQ集群以后,尽管交换器和绑定关系能够在单点故障问题上幸免于难,但是队列及其存储的消息却不行,这是因为队列进程及其内容仅仅维持......
  • RabbitMQ 存储机制
    一、消息存储机制不管是持久化的消息还是非持久化的消息都可以被写入到磁盘。持久化的消息在到达队列时就被写入到磁盘,非持久化的消息一般只保存在内存中,在内存吃紧的......
  • 多个生产者,单个消费者,信号量
    #include<stdio.h>#include<fcntl.h>#include<stdlib.h>#include<pthread.h>#include<semaphore.h>#definemin(a,b)((a)<(b)?(a):(b))#defineNBUFF10#de......
  • mysql事务处理用法与实例详解
    MySQL的事务支持不是绑定在MySQL服务器本身,而是与存储引擎相关1.MyISAM:不支持事务,用于只读程序提高性能2.InnoDB:支持ACID事务、行级锁、并发3.BerkeleyDB:支持事务  一......
  • 它让你1小时精通RabbitMQ消息队列(新增死信处理)
    支持.NET/.NETFramework/.NETCoreRabbitMQ作为一款主流的消息队列工具早已广受欢迎。相比于其它的MQ工具,RabbitMQ支持的语言更多、功能更完善。本文提供一种市面上最/......
  • echarts入门实例
    去echarts官网把dist里的echarts.min.js下载下来然后放进文件夹里然后新建一个html,也放进该文件夹里源码如下:<!DOCTYPEhtml><htmllang="en"><head><metacha......
  • 02 RabbitMQ 3.8 Feature Focus - Quorum Queues
    标题:RabbitMQ3.8FeatureFocus-QuorumQueues原文:https://www.cloudamqp.com/blog/rabbitmq-quorum-queues.html时间:2019-03-28RabbitMQ3.8将于今年推出,它将带来四......
  • [翻译] Quorum Queues - Making RabbitMQ More Competitive In Reliable Messaging
    目录AnIntroductiontoRaftBriefOverviewofRaftWriteSafetyReadSafetyRabbitMQQuorumQueuesNewDrawbacksQuestionsandOpenTopicsCouldtheidempotencyofwr......
  • Windows 上下载安装 RabbitMQ 的方法步骤
    RabbitMQ是一套开源(MPL)的消息队列服务软件,是由LShift提供的一个AdvancedMessageQueuingProtocol(AMQP)的开源实现,由以高性能、健壮以及可伸缩性出名的Erlang写成......