由于RabbitMQ中只有队列（queue）才能存储信息，所以用RabbitMQ实现超大用户级别（百万计）的消息在/离线收发需要对每一个用户创建一个永久队列。

但是RabbitMQ节点内存有限，经测试后发现节点集群也无法满足数百万用户队列收发数据的要求，所以最终决定采用数据库辅助实现该功能。

一、数据库结构

user_list数据库下有4张表：user_info、group_info、groupmember_info、message_info。

user_info表中含有username（主键，非空，VARCHAR(50)）、password(非空，VARCHAR(50))、routingkey（非空，VARCHAR(50)）、has_queue（INT UNSIGNED）四个字段。

group_info表中含有groupname（主键，非空，VARCHAR(50)）、password(非空，VARCHAR(50))、creator（非空，VARCHAR(50)）三个字段。

groupmember_info表中含有username（主键，非空，VARCHAR(50)）、groupname（主键，非空，VARCHAR(50)）两个字段。

message_info表中含有sendtime（非空，VARCHAR(50)）、body（非空，VARCHAR(300)），receiver（非空，VARCHAR(50)）、sender（非空，VARCHAR(100)）四个字段。

 

二、客户端结构

1、文件夹创建以及包依赖安装：

dotnet new console --name Clientmv Client/Program.cs Client/Client.cs

cd Clientdotnet add package RabbitMQ.Client dotnet add package MySql.Datadotnet restore 2、项目结构 Client.cs(主程序):

 

　UserLogin.cs:

 

　UserInfo.cs:

 

　GenerateKey.cs:　

 

　Consumer.cs:

 

　KeyListening.cs:

 

　MQHelper.cs:

 

　UserLogout.cs:

 

 

百度云链接：https://pan.baidu.com/s/1Y93rcqnsv1cA9ZIxH2xrBw 密码：zfc5