当前位置: 首页 > news >正文

Windows install RabbitMQ via PowerShell via administrator role

//Run PowerShell as Administrator role
//Run below commands respectively
//First command
Set-ExecutionPolicy Bypass -Scope Process -Force; [System.Net.ServicePointManager]::SecurityProtocol = [System.Net.ServicePointManager]::SecurityProtocol -bor 3072; iex ((New-Object System.Net.WebClient).DownloadString('https://community.chocolatey.org/install.ps1'))//Second Command
choco install rabbitmq 

 

 

 

image

 

 

 

 

 

image

 

 

//Send.cs
using RabbitMQ.Client;
using System.Text;namespace ConsoleApp6
{internal class Program{static async Task Main(string[] args){await SendMessageAsync();}public static async Task SendMessageAsync(){var factory = new ConnectionFactory { HostName = "localhost" };using (var connection = await factory.CreateConnectionAsync()){using (var channel = await connection.CreateChannelAsync()){await channel.QueueDeclareAsync(queue: "hello", durable: false,exclusive: false, autoDelete: false, arguments: null);for (int i = 1; i < 11; i++){string msg = $"Id:{i},now {DateTime.Now.ToString("yyyyMMdd HH:mm:ss.ffff")}_{Guid.NewGuid():N}";var body = Encoding.UTF8.GetBytes(msg);await channel.BasicPublishAsync(exchange: string.Empty,routingKey: "hello", body: body);Console.WriteLine($"[X] sent {msg}");}Console.WriteLine($"Press [enter] to exit!");Console.ReadLine();}}}}
}//Receive.cs
using RabbitMQ.Client;
using RabbitMQ.Client.Events;
using System.Text;
using System.Threading.Tasks;namespace ConsoleApp7
{internal class Program{static async Task Main(string[] args){await ReceiveDemo();}static async Task ReceiveDemo(){var factory = new ConnectionFactory { HostName = "localhost" };using (var connection = await factory.CreateConnectionAsync()){using (var channel = await connection.CreateChannelAsync()){await channel.QueueDeclareAsync(queue: "hello",durable: false, exclusive: false, autoDelete: false, arguments: null);Console.Write($"[*] Waiting for messages.");var consumer=new AsyncEventingBasicConsumer(channel);consumer.ReceivedAsync +=async (s, e) =>{var body = e.Body.ToArray();var message = Encoding.UTF8.GetString(body);Console.WriteLine($"[x] Received {message}");};await channel.BasicConsumeAsync(queue:"hello", autoAck: true, consumer: consumer);Console.WriteLine("Press [Enter] to exit.");Console.ReadLine();}}}}
}

 

 

 

 

 

 

 

 

 

 

 

 

image

 

 

image

 

http://www.gsyq.cn/news/16514.html

相关文章:

  • 一些做题记录(2025 2-3)
  • 实用指南:Linux 权限管理入门:从基础到实践
  • 无法定时发送
  • MongoDB财报超预期,文档数据库技术解析
  • 2020CSPS T1 儒略日题解
  • Python 语言编程技巧
  • kafka 常用知识点 - 指南
  • 英语_阅读_ChatGPT_待读
  • 详细介绍:Qwen2.5-VL 损失函数
  • visual studio
  • HttpServletResponse 对象用来做什么? - 详解
  • [LUCKY」在Windows下使用STUN穿透实现Minecraft联机并设置SRV记录
  • 详细介绍:如何用 pnpm patch 给 element-plus 打补丁修复线上 bug(以 2.4.4 修复 PR#15197 为例)
  • Go 为何天生适合云原生? - 指南
  • ARC 207
  • 深入解析:C++:内存管理
  • [KaibaMath1001] 关于∀ε0,|a-b|ε = a=b的证明
  • 基于Web的分布式图集管理系统架构设计与实践 - 教程
  • 国庆 Day2 强基物理
  • unix/linux source 命令,其发展历程详细时间线、由来、历史背景 - 指南
  • AtCoder Regular Contest 207 (Div.1) 游记
  • 详细介绍:云原生时代 Kafka 深度实践:05性能调优与场景实战
  • 从零开始学Flink:数据输出的终极指南
  • 自然语言处理(NLP)的系统学习路径规划 - 实践
  • 【JNI】JNI基础语法
  • 从Chrome渲染器代码执行到内核:MSG_OOB漏洞分析与利用
  • US$78.85 KEYDIY KD ZB42-4 Universal Smart Remote Key 3+1 Buttons for Lexus Type 5pcs/lot
  • Python中小整数对象池、intern机制和大整数对象池
  • ctf逆向常见算法----base64
  • 02020409 EF Core基础09-一对一、多对多、EF Core基于关系的复杂查询