[开源] .NETCore websocket 即时通讯组件---ImCore

ImCore 是一款 .NETCore 下利用 WebSocket 实现的简易、高性能、集群即时通讯组件,支持点对点通讯、群聊通讯、上线下线事件消息等众多实用性功能。

开源地址:https://github.com/2881099/im ,求 star~~

dotnet add package ImCore

IM服务端

public void Configure(IApplicationBuilder app){    app.UseImServer(new ImServerOptions    {        Redis = new CSRedis.CSRedisClient("127.0.0.1:6379,poolsize=5"),        Servers = new[] { "127.0.0.1:6001" },        Server = "127.0.0.1:6001"    });}

一套永远不需要迭代更新的IM服务端

WebApi业务端

public void Configure(IApplicationBuilder app){        ImHelper.Initialization(new ImClientOptions    {        Redis = new CSRedis.CSRedisClient("127.0.0.1:6379,poolsize=5"),        Servers = new[] { "127.0.0.1:6001" }    });    ImHelper.EventBus(        t => Console.WriteLine(t.clientId + "上线了"),        t => Console.WriteLine(t.clientId + "下线了"));}
PrevConnectServer(clientId, string)在终端准备连接 WebSocket 前调用
SendMessage(发送者, 接收者, 消息内容, 是否回执)发送消息
GetClientListByOnline-返回所有在线clientId
EventBus(上线委托, 离线委托)socket上线与下线事件
JoinChan(clientId, 频道名)加入
LeaveChan(clientId, 频道名)离开
GetChanClientList(频道名)获取群聊频道所有clientId
GetChanList-获取所有群聊频道和在线人数
GetChanListByClientId(clientId)获取用户参与的所有群聊频道
GetChanOnline(频道名)获取群聊频道的在线人数
SendChanMessage(clientId, 频道名, 消息内容)发送群聊消息,所有在线的用户将收到消息

说明:clientId 应该与 webApi的用户id相同,或者有关联。

Html5终端

本方案支持集群分区,前端连接 websocket 前,应该先请求 webApi 获得地址(ImHelper.PrevConnectServer)。

运行环境:.NETCore 2.1 + redis-server 2.8

下载Redis-x64-2.8.2402.zip,点击 start.bat 运行;

cd imServer && dotnet run

cd web && dotnet run

打开多个浏览器,访问 http://127.0.0.1:5000 发送群消息

640?wx_fmt=png

imServer 是 websocket 服务中心,可部署多实例,按clientId分区管理socket连接;

webApi 或其他应用端,使用 ImHelper 调用相关方法(如:SendMessage、群聊相关方法);

消息发送利用了 redis 订阅发布技术。每个 imServer 订阅相应的频道,收到消息,指派 websocket 向终端(如浏览器)发送消息;

1、可缓解并发推送消息过多的问题;

2、可解决连接数过多的问题;

客户端连接流程:client -> websocket -> imserver

imserver 订阅消息:client <- imserver <- redis channel

推送消息流程:web1 -> sendmsg方法 -> redis channel -> imserver

imserver 充当消息转发,及维护连接中心,代码万年不变不需要重启维护;

WebSocket

比较笨的办法是浏览器端使用websocket,其他端socket,这种混乱的设计非常难维护。

强烈建议所有端都使用websocket协议,adorid/ios/h5/小程序全部支持websocket客户端。

业务与通讯协议

im系统一般涉及【我的好友】、【我的群】、【历史消息】等等。。

那么,imServer与业务方(webApi)该保持何种关系呢?

用户A向好友B发送消息,分析一下:

  • 需要判断B是否为A好友;

  • 需要判断A是否有权限;

  • 等等。。

诸如此类业务判断会很复杂,我们试想一下,如果使用imServer做业务协议,它是不是会变成巨无霸难以维护?

又比如获取历史聊天记录,难道客户端要先websocket.send('gethistory'),再在onmessage里定位回调处理?


我们可以这样设定,所有用户的主动行为走业务方(webApi),imServer只负责即时消息推送。什么意思?

用户A向好友B发送消息:客户端请求业务方(webApi)接口,由业务方(webApi)后端向imServer发起推送请求,imServer收到指令后,向前端用户B的websocket发送数据,用户B收到了消息。

获取历史消息:客户端请求业务方(webApi)接口,返回json(历史消息)

回执:用户A如何知道消息发送状态(成功或失败或不在线)?imServer端向用户B发送消息时,把状态以消息的方式推给用户A即可(按上面的逻辑),具体请看源码吧。。。

发送消息

采用 redis 轻量级的订阅发布功能,实现消息缓冲发送。

集群分区

单个imServer实例支持多少个客户端连接,两千个没问题?

如果在线用户有10万人,怎么办???

比如部署4个imServer:

imServer1 订阅 redisChanne1
imServer2 订阅 redisChanne2
imServer3 订阅 redisChanne3
imServer4 订阅 redisChanne4

业务方(webApi)端根据接收方的clientId后四位16进制与节点总数取模,定位到对应的redisChannel,进行redis->publish操作将消息定位到相应的imServer。

每个 imServer 管理着对应的终端连接,当接收到 redis 订阅消息后,向对应的终端连接推送数据。

事件消息

IM 系统比较常用的有上线、下线,在 imServer 层才能准确捕捉事件,但业务代码就不合适在这上面编写了。

采用 redis 发布订阅技术,将上线、下线等事件向指定频道发布,业务方(webApi) 通过 ImHelper.EventBus 方法进行订阅捕捉。

640?wx_fmt=png

谢谢支持!

原文链接:https://www.cnblogs.com/kellynic/p/11273742.html


.NET社区新闻,深度好文,欢迎访问公众号文章汇总 http://www.csharpkit.com 

640?wx_fmt=jpeg

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/314623.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

算法竞赛进阶指南——后缀数组

后缀数组 后缀数组 (SA) 是一种重要的数据结构&#xff0c;通常使用倍增或者DC3算法实现&#xff0c;这超出了我们的讨论范围。 在本题中&#xff0c;我们希望使用快排、Hash与二分实现一个简单的O(nlog2n)的后缀数组求法。 详细地说&#xff0c;给定一个长度为 n 的字符串S&a…

NWERC 2018 A. Access Points 二维转一维 + 单调栈

传送门 文章目录题意&#xff1a;思路&#xff1a;题意&#xff1a; 给你平面上nnn个点&#xff0c;你需要对于1−n1-n1−n依次选择nnn个点作为每个点的终点&#xff0c;满足选择的点i<j,xi≤xj,yi≤yji<j,x_i\le x_j,y_i\le y_ji<j,xi​≤xj​,yi​≤yj​&#xff0…

【译】在 Linux 上不安装 Mono 构建 .NET Framework 类库

在这篇文章中&#xff0c;我展示了如何在 Linux 上构建针对 .NET Framework 版本的.NET项目&#xff0c;而不使用 Mono。通用使用微软新发布的 Mocrosoft.NETFramework.ReferenceAssemblies NuGet 包&#xff0c;您将不需要安装除 .NET Core SDK 之外的任何其他软件包&#xff…

hdu 5023 线段树染色问题

题目链接 A Corrupt Mayor’s Performance Art Time Limit: 2000/1000 MS (Java/Others) Memory Limit: 100000/100000 K (Java/Others) Total Submission(s): 4094 Accepted Submission(s): 1418 Problem Description Corrupt governors always find ways to get dirty money…

Codeforces Round #740 (Div. 2) D2. Up the Strip dp + 分块优化 + 逆向思维

传送门 文章目录题意&#xff1a;思路题意&#xff1a; 有nnn个细胞&#xff0c;你初始在第nnn细胞上&#xff0c;假设你当前在xxx处&#xff0c;你每次可以进行如下两个操作&#xff1a; (1)(1)(1)选择[1,x−1][1,x-1][1,x−1]内一个数yyy&#xff0c;跳到第x−yx-yx−y个细胞…

poj 2528 线段树离散化+染色

题目链接 Mayor’s posters Time Limit: 1000MS Memory Limit: 65536K Total Submissions: 92628 Accepted: 26452 Description The citizens of Bytetown, AB, could not stand that the candidates in the mayoral election campaign have been placing their electoral pos…

Codeforces Round #740 (Div. 2) E. Bottom-Tier Reversals 构造

传送门 文章目录题意&#xff1a;思路&#xff1a;题意&#xff1a; 给你一个长度为奇数nnn的排列aaa&#xff0c;每次可以选择长度为奇数的前缀&#xff0c;并将[1,len][1,len][1,len]翻转&#xff0c;你需要用不超过5n2\frac{5n}{2}25n​次操作将其变成有序的&#xff0c;输…

DevOps书单:调研了101名专家,推荐这39本必读书籍

任何一个领域都遵循从新人到熟手&#xff0c;从熟手到专家的路径。在成长过程中&#xff0c;DevOps人经常会陷入没人带&#xff0c;没人管&#xff0c;找不到职业方向的迷茫。DevOps是在商业演进与企业协作的进化过程中诞生的一个全新职业&#xff0c;被很多人看成是一个“全栈…

模板:Prime最小生成树堆优化 + Dijkstra单源最短路堆优化

Dijkstra 单源最短路堆优化 #include<bits/stdc.h> using namespace std; typedef pair<int, int> PII; const int N 2e5 10; int head[N], to[N], value[N], nex[N], cnt 1; int n, m, rt, st, dis[N], visit[N]; struct cmp {bool operator()(PII a, PII b) …

Gym - 102001K Boomerangs 构造 + 三元环

传送门 文章目录题意&#xff1a;思路&#xff1a;题意&#xff1a; 给你一张nnn个点mmm条边的简单图&#xff0c;让你找出尽可能多的三元环&#xff0c;要求每个三元环都不能共边&#xff0c;输出三元环数量和具体是那个。 n,m≤1e5n,m\le1e5n,m≤1e5 思路&#xff1a; 其实…

面对人性,有的选择向左,有的向右

这里是Z哥的个人公众号每周五11&#xff1a;45 按时送达有时也会有感而发&#xff0c;来加个餐&#xff5e;我的第「84」篇原创敬上前天早上&#xff0c;在36kr看到一篇文章《一个负能量的人&#xff0c;可以轻易搞垮周围人的生活》&#xff0c;讲述了可能我们每个人身边都存在…

10分钟了解分布式CAP、BASE理论

CAP理论2000年7月&#xff0c;Eric Brewer教授提出CAP猜想&#xff1b;2年后&#xff0c;Seth Gilbert和Nancy Lynch从理论上证明了CAP&#xff1b;之后&#xff0c;CAP理论正式成为分布式计算领域的公认定理。CAP定律说的是在一个分布式计算机系统中&#xff0c;一致性&#x…

2018 ICPC Asia Jakarta Regional Contest J. Future Generation 状压dp

传送门 文章目录题意&#xff1a;思路&#xff1a;题意&#xff1a; 给你nnn个串&#xff0c;字符集是a−za-za−z&#xff0c;让你在每个串种选择一个子序列&#xff0c;保证对于i<j,si<sji<j,s_i<s_ji<j,si​<sj​&#xff0c;也就是选择的串字典序是严格…

ASP.NET Core Web Api之JWT刷新Token(三)

本节我们进入JWT最后一节内容&#xff0c;JWT本质上就是从身份认证服务器获取访问令牌&#xff0c;继而对于用户后续可访问受保护资源&#xff0c;但是关键问题是&#xff1a;访问令牌的生命周期到底设置成多久呢&#xff1f;见过一些使用JWT的童鞋会将JWT过期时间设置成很长&a…

简单dfs序 + 树链剖分

树链剖分 DFS序 先来讲一讲DFS序是什么东西&#xff0c;直接上图&#xff0c;方便理解。 估计巨巨们应该知道了DFS序的两个重要的东西&#xff0c;in,outin,outin,out数组。 ininin数组就是这个点进入DFS的时间。outoutout数组就是这个点退出DFS递归栈的时间。这个时间要注意…

#3864. Hero meet devil dp套dp + 状压 + 状态机

传送门 文章目录题意&#xff1a;思路&#xff1a;题意&#xff1a; 给你一个只包含ACGTACGTACGT的串sss&#xff0c;再给你一个mmm&#xff0c;第iii行输出有多少个长度为mmm且只包含ACGTACGTACGT的串与sss的lcslcslcs为iii。 ∣s∣≤15,m≤1000|s|\le15,m\le1000∣s∣≤15,m…

WeihanLi.Npoi 导出支持自定义列内容啦

WeihanLi.Npoi 导出支持自定义列内容啦Intro之前也有网友给提出过希望列合并或者自定义列内容的 issue 或请求&#xff0c;起初因为自己做 WeihanLi.Npoi 这个扩展的最初目的是导入导出的简单化&#xff0c;使用这个扩展导出的 Excel/csv 可以直接导入成 List<TEntity>&a…

线段树优化的Dijkstra

板子 我测得的是这个东西在不开O2O2O2的情况下比pairpriorityqueuepair priority_queuepairpriorityq​ueue快了将近1/31/31/3 #include<bits/stdc.h> #define mid (l r >> 1) #define lson rt << 1, l, mid #define rson rt << 1 | 1, mid 1, ru…

P4590 [TJOI2018]游园会 dp套dp + 状态机

传送门 文章目录题意&#xff1a;思路&#xff1a;题意&#xff1a; 给你一个长度为nnn的串sss&#xff0c;其只包含NOINOINOI三个字母&#xff0c;给你一个mmm&#xff0c;代表ttt串的长度&#xff0c;ttt串包含NOINOINOI三个字母但是不存在三个连续的NOINOINOI子串&#xff…

让 .Net 更方便的导入导出 Excel

让 .Net 更方便的导入导出ExcelIntro因为前一段时间需要处理一些 excel 数据&#xff0c;主要是导入/导出操作&#xff0c;将 Excel 数据转化为对象再用程序进行处理和分析&#xff0c;没有找到比较满意的库&#xff0c;于是就自己造了一个轮子&#xff0c;屏蔽掉了 xlsx 与 xl…