C#队列学习笔记：RabbitMQ实现客户端相互通讯|C#教程

当前位置:

首页 > 编程开发 > C#编程 >

C#教程之C#队列学习笔记：RabbitMQ实现客户端相互通讯

本站最新发布 C#从入门到精通
试听地址 https://www.xin3721.com/eschool/CSharpxin3721/

一、引言

fanout类型的Exchange，路由规则非常简单：它会把所有发送到该Exchange的消息，路由到所有与它绑定的Queue中。假设有一个聊天室，各个客户端都订阅在同一fanout exchange type，那每个客户端发送出来的消息，所有的客户端都能收到，因为大家都订阅了。此时，只需要简单地限制一下，只有是与我有关的消息，才在聊天界面上显示。这样，即可达到相互通讯的效果。

二、示例

2.1、环境准备

本示例使用EasyNetQ来实现，请先在NuGet上安装。

2.2、实体类

新建一个实体类MessageBody：

    public class MessageBody
    {
        public string FromUserId { get; set; }
        public string Message { get; set; }
        public string ToUserId { get; set; }
    }

2.3、主窗体

新建一个ChatMain窗体：

代码如下：

    public partial class ChatMain : Form
    {
        public ChatMain()
        {
            InitializeComponent();
        }

        /// <summary>
        /// 客户端 A
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private void Button1_Click(object sender, EventArgs e)
        {
            ChatWith chatWith = new ChatWith(currentUserId: "UserA")
            {
                StartPosition = FormStartPosition.CenterScreen
            };
            chatWith.Show();
        }

        /// <summary>
        /// 客户端 B
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private void Button2_Click(object sender, EventArgs e)
        {
            ChatWith chatWith = new ChatWith(currentUserId: "UserB")
            {
                StartPosition = FormStartPosition.CenterScreen
            };
            chatWith.Show();
        }

        /// <summary>
        /// 客户端 C
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private void Button3_Click(object sender, EventArgs e)
        {

            ChatWith chatWith = new ChatWith(currentUserId: "UserC")
            {
                StartPosition = FormStartPosition.CenterScreen
            };
            chatWith.Show();

        }

        /// <summary>
        /// 客户端 D
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private void Button4_Click(object sender, EventArgs e)
        {
            ChatWith chatWith = new ChatWith(currentUserId: "UserD")
            {
                StartPosition = FormStartPosition.CenterScreen
            };
            chatWith.Show();
        }
    }

2.4、客户端窗体

新建一个ChatWith窗体：