转： 利用RabbitMQ、MySQL实现超大用户级别的消息在/离线收发

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了转： 利用RabbitMQ、MySQL实现超大用户级别的消息在/离线收发，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含1384字，纯文字阅读大概需要2分钟。

内容图文

由于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 Client
mv Client/Program.cs Client/Client.cs

cd Client
dotnet add package RabbitMQ.Client
dotnet add package MySql.Data
dotnet restore

2、项目结构

Client.cs(主程序):

?View Code

　UserLogin.cs:

?View Code

　UserInfo.cs:

?View Code

　GenerateKey.cs:　

?View Code

　Consumer.cs:

?View Code

　KeyListening.cs:

?View Code

　MQHelper.cs:

?View Code

　UserLogout.cs:

?View Code

 

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

内容总结

以上是互联网集市为您收集整理的转： 利用RabbitMQ、MySQL实现超大用户级别的消息在/离线收发全部内容，希望文章能够帮你解决转： 利用RabbitMQ、MySQL实现超大用户级别的消息在/离线收发所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端

---