如何在一个.NET Core项目中使用RabbitMQ进行即时消息管理

更新时间：2024年09月28日 10:49:50 作者：新空间代码工作室

本文提供了在.NETCore项目中使用RabbitMQ进行即时消息管理的详细操作指南,包括安装Erlang和RabbitMQ,配置RabbitMQ,以及在.NETCore项目中编写代码和调试,操作步骤详尽,感兴趣的朋友一起看看吧

为了在一个.NET Core项目中使用RabbitMQ进行即时消息管理，以下是详细的全程操作指南，包括安装、配置、编写代码和调试使用。

一、安装RabbitMQ

1. 安装Erlang

RabbitMQ依赖Erlang，因此需要先安装Erlang。

Windows:
下载并运行Erlang安装程序：Erlang下载页面

2. 安装RabbitMQ

Windows:

下载并运行RabbitMQ安装程序：RabbitMQ下载页面

二、配置RabbitMQ

1. 启用管理插件

打开命令提示符，并运行以下命令：

rabbitmq-plugins enable rabbitmq_management

2. 创建用户并设置权限

rabbitmqctl add_user myuser mypassword
rabbitmqctl set_permissions -p / myuser ".*" ".*" ".*"
rabbitmqctl set_user_tags myuser administrator

3. 访问管理界面

在浏览器中访问：http://localhost:15672
使用刚才创建的用户名 myuser 和密码 mypassword 登录。

三、在.NET Core项目中使用RabbitMQ

1. 创建.NET Core项目

打开命令提示符或PowerShell，进入你想创建项目的目录，然后运行以下命令：

dotnet new console -n IMProject
cd IMProject

2. 安装RabbitMQ.Client包

在项目目录中运行以下命令安装RabbitMQ的客户端库：

dotnet add package RabbitMQ.Client

3. 编写发送和接收消息的代码

发送消息 (Producer)

创建一个文件 Producer.cs，内容如下：

using System;
using RabbitMQ.Client;
using System.Text;
class Producer
{
    public static void Main()
    {
        var factory = new ConnectionFactory() { HostName = "localhost" };
        using (var connection = factory.CreateConnection())
        using (var channel = connection.CreateModel())
        {
            channel.QueueDeclare(queue: "chat",
                                 durable: false,
                                 exclusive: false,
                                 autoDelete: false,
                                 arguments: null);
            string message = "Hello World!";
            var body = Encoding.UTF8.GetBytes(message);
            channel.BasicPublish(exchange: "",
                                 routingKey: "chat",
                                 basicProperties: null,
                                 body: body);
            Console.WriteLine(" [x] Sent {0}", message);
        }
    }
}

接收消息 (Consumer)

创建一个文件 Consumer.cs，内容如下：

using System;
using RabbitMQ.Client;
using RabbitMQ.Client.Events;
using System.Text;
class Consumer
{
    public static void Main()
    {
        var factory = new ConnectionFactory() { HostName = "localhost" };
        using (var connection = factory.CreateConnection())
        using (var channel = connection.CreateModel())
        {
            channel.QueueDeclare(queue: "chat",
                                 durable: false,
                                 exclusive: false,
                                 autoDelete: false,
                                 arguments: null);
            var consumer = new EventingBasicConsumer(channel);
            consumer.Received += (model, ea) =>
            {
                var body = ea.Body.ToArray();
                var message = Encoding.UTF8.GetString(body);
                Console.WriteLine(" [x] Received {0}", message);
            };
            channel.BasicConsume(queue: "chat",
                                 autoAck: true,
                                 consumer: consumer);
            Console.WriteLine(" [*] Waiting for messages. To exit press CTRL+C");
            Console.ReadLine();
        }
    }
}

四、调试和运行

1. 运行接收消息的程序

在命令提示符或PowerShell中，运行以下命令：

dotnet run --project ./Consumer.csproj

你应该会看到类似以下的输出：

[*] Waiting for messages. To exit press CTRL+C

2. 运行发送消息的程序

打开另一个命令提示符或PowerShell窗口，运行以下命令：

dotnet run --project ./Producer.csproj

你应该会看到类似以下的输出：

[x] Sent Hello World!

在接收消息的程序窗口中，你应该会看到类似以下的输出：

[x] Received Hello World!

五、集成到IM项目中

为了将RabbitMQ集成到一个更复杂的IM项目中，你可以创建一个ASP.NET Core Web API项目，并在控制器中使用RabbitMQ来发送和接收消息。

1. 创建ASP.NET Core Web API项目

在命令提示符或PowerShell中，运行以下命令：

dotnet new webapi -n IMWebApi
cd IMWebApi

2. 安装RabbitMQ.Client包

在项目目录中运行以下命令安装RabbitMQ的客户端库：

dotnet add package RabbitMQ.Client

3. 创建消息服务

创建一个文件 Services/RabbitMQService.cs，内容如下：

using RabbitMQ.Client;
using RabbitMQ.Client.Events;
using System;
using System.Text;
public class RabbitMQService
{
    private readonly ConnectionFactory _factory;
    public RabbitMQService()
    {
        _factory = new ConnectionFactory() { HostName = "localhost" };
    }
    public void SendMessage(string message)
    {
        using (var connection = _factory.CreateConnection())
        using (var channel = connection.CreateModel())
        {
            channel.QueueDeclare(queue: "chat",
                                 durable: false,
                                 exclusive: false,
                                 autoDelete: false,
                                 arguments: null);
            var body = Encoding.UTF8.GetBytes(message);
            channel.BasicPublish(exchange: "",
                                 routingKey: "chat",
                                 basicProperties: null,
                                 body: body);
            Console.WriteLine(" [x] Sent {0}", message);
        }
    }
    public void ReceiveMessages()
    {
        using (var connection = _factory.CreateConnection())
        using (var channel = connection.CreateModel())
        {
            channel.QueueDeclare(queue: "chat",
                                 durable: false,
                                 exclusive: false,
                                 autoDelete: false,
                                 arguments: null);
            var consumer = new EventingBasicConsumer(channel);
            consumer.Received += (model, ea) =>
            {
                var body = ea.Body.ToArray();
                var message = Encoding.UTF8.GetString(body);
                Console.WriteLine(" [x] Received {0}", message);
            };
            channel.BasicConsume(queue: "chat",
                                 autoAck: true,
                                 consumer: consumer);
            Console.WriteLine(" [*] Waiting for messages. To exit press CTRL+C");
            Console.ReadLine();
        }
    }
}

4. 创建控制器

创建一个文件 Controllers/ChatController.cs，内容如下：

using Microsoft.AspNetCore.Mvc;
[ApiController]
[Route("[controller]")]
public class ChatController : ControllerBase
{
    private readonly RabbitMQService _rabbitMQService;
    public ChatController()
    {
        _rabbitMQService = new RabbitMQService();
    }
    [HttpPost("send")]
    public IActionResult SendMessage([FromBody] string message)
    {
        _rabbitMQService.SendMessage(message);
        return Ok("Message sent");
    }
    [HttpGet("receive")]
    public IActionResult ReceiveMessages()
    {
        _rabbitMQService.ReceiveMessages();
        return Ok("Receiving messages");
    }
}

5. 运行Web API

在命令提示符或PowerShell中，运行以下命令：

dotnet run

你可以使用Postman或其他API测试工具来发送和接收消息：

发送消息：POST http://localhost:5000/chat/send，请求体为纯文本消息。
接收消息：GET http://localhost:5000/chat/receive。

六、调试和测试

1. 发送消息

使用Postman发送一个POST请求到http://localhost:5000/chat/send，请求体为纯文本消息，例如：“Hello from Postman”。

2. 接收消息

在浏览器或Postman中发送一个GET请求到http://localhost:5000/chat/receive，你应该会在控制台中看到接收到的消息。

七、总结

通过以上步骤，你已经成功地在一个.NET Core项目中使用RabbitMQ进行即时消息管理。你可以根据项目的需求进一步扩展和优化。例如，使用依赖注入来管理RabbitMQService，处理消息的持久化存储，添加更多的业务逻辑等。

//python 因为爱，所以学
print("Hello, Python!")

到此这篇关于在一个.NET Core项目中使用RabbitMQ进行即时消息管理的文章就介绍到这了,更多相关.NET Core使用RabbitMQ即时消息管理内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！

您可能感兴趣的文章:

asp.net获取ListView与gridview中当前行的行号
这篇文章主要介绍了asp.net获取ListView与gridview中当前行的行号,实例分析了asp.net针对ListView与gridview获取行号的实现技巧,需要的朋友可以参考下
2016-01-01
基于.net core微服务的另一种实现方法
这篇文章主要给大家介绍了基于.net core微服务的另一种实现方法，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧
2018-07-07
C# .Net动态调用webService实现思路及代码
动态调用web服务将执行以下步骤:获取WSDL/生成客户端代理类代码/设定编译参数/编译代理类/生成代理实例,并调用方法,很详细的，感兴趣的你可不要错过了哈
2013-02-02
C# 命名规则(挺不错的)
我自己总结的一套命名规则，其实规则很重要，它是一种标准，可有可无，但有总会比无好，大家正在编码的同志仔细看看，给点改进意见。
2009-02-02
基于MVC5中的Model层开发数据注解
下面小编就为大家分享一篇基于MVC5中的Model层开发数据注解，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧
2017-12-12
asp.net AJAX注册类
单纯用JavaScript，不需要注册，但是就是用不了AJAX的某些机制。
2010-02-02
JQuery运用ajax注册用户实例(后台asp.net)
JQuery运用ajax注册用户实例，其实那中后台语言都是差不多的形式。
2009-12-12
asp.net静态方法弹出对话框实现思路
为菜鸟所准备……其实就是弹出JavaScript小窗口,总得来说就是定义的一个DIV,感兴趣的朋友可以了解下，或许对你学习asp.net有所帮助
2013-02-02
使用EF CORE迁移数据库
这篇文章介绍了使用EF CORE迁移数据库的方法，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧
2022-05-05
ASP.NET无刷新分页简单实现
无刷新分页功能，虽然比较简单，但是涉及到的知识面蛮多的，我记录一下制作的步骤与心得，仅供参考。如有哪里不足，希望大家指出，有更好的方法，也可以提出来，大家一起学习。
2015-09-09