asp.net core 2.0 webapi集成signalr

来源:http://www.cnblogs.com/Mr-luoye/archive/2017/11/24/7891838.html
-Advertisement-
Play Games

在博客園也很多年了,一直未曾分享過什麼東西,也沒有寫過博客,但自己也是汲取著博客園的知識成長的; 這兩天想著不能這麼無私,最近.NET CORE貌似挺流行的,閑來無事也自己搞了個asp.net core signalr 博客園裡面也有人在.net core 2.0下麵集成了signalr,但是是集成 ...


在博客園也很多年了,一直未曾分享過什麼東西,也沒有寫過博客,但自己也是汲取著博客園的知識成長的;

這兩天想著不能這麼無私,最近.NET CORE貌似挺流行的,閑來無事也自己搞了個asp.net core signalr

博客園裡面也有人在.net core 2.0下麵集成了signalr,但是是集成在同一個項目裡面的,但是大家都知道我們很多的項目都是分離的;

而且signalr涉及到連接數和記憶體資源的占用問題,如果都集成在一個項目裡面當訪問量多大的時候容易造成網站訪問緩慢,具體原因就不多說了

所以我這裡做了一個在.net core webapi裡面集成signalr,我們就可以通過調用webapi來實現伺服器向客戶端推送消息

第一步引用nuget:Mrcrosoft.AspNetCore.SignalR

 

第二步添加配置代碼:

首先ConfigureServices裡面添加如下代碼:

public void ConfigureServices(IServiceCollection services)
        {
            services.AddSignalR();
            services.AddCors(options =>
            {
                options.AddPolicy("SignalrCore",
                    policy => policy.AllowAnyOrigin()
                                    .AllowAnyHeader()
                                    .AllowAnyMethod());
            });
            services.AddSingleton<IServiceProvider, ServiceProvider>();
        }

然後Configure裡面添加

public void Configure(IApplicationBuilder app, IHostingEnvironment env)
        {
            if (env.IsDevelopment())
            {
                app.UseDeveloperExceptionPage();
            }
            //跨域支持
            app.UseCors("SignalrCore");
            app.UseSignalR(routes =>
            {
                routes.MapHub<SignalrHubs>("signalrHubs");
            });
            app.UseWebSockets();

            app.UseMvc();
        }

 

然後我們添加一個hubs

public class SignalrHubs:Hub
    {
        /// <summary>
        /// 創建signalr鏈接
        /// </summary>
        /// <param name="parentId">pid(作為用戶組)</param>
        /// <param name="shopId">sid</param>
        public Task InitUser(string parentId, string shopId)
        {
            Groups.AddAsync(Context.ConnectionId, parentId);
            SignalrGroups.UserGroups.Add(new SignalrGroups()
            {
                ConnectionId = Context.ConnectionId,
                GroupName = parentId,
                ShopId = shopId
            });
            return Clients.All.InvokeAsync("NoticeOnline", "用戶組數據更新完成,新增id為:" + Context.ConnectionId + " pid:" + parentId + "   sid:" + shopId + "");
        }

        public override Task OnDisconnectedAsync(Exception exception)
        {
            //掉線移除用戶
            var user = SignalrGroups.UserGroups.FirstOrDefault(c => c.ConnectionId == Context.ConnectionId);
            if (user != null)
            {
                SignalrGroups.UserGroups.Remove(user);
                Groups.RemoveAsync(Context.ConnectionId, user.GroupName);
            }
            return base.OnDisconnectedAsync(exception);
        }
    }

PS:我這裡是根據本人業務需要來做的,大家可以修改成其他的(用戶量大的時候記憶體占用肯定高,這裡只做一個簡單的例子)

以上基本的環境搭建就已經完成了

接下來控制器裡面的代碼

[Produces("application/json")]
    [Route("api/MRSoftPush")]
    public class MRSoftPushController : Controller
    {
        private IHubContext<SignalrHubs> hubContext;
        public MRSoftPushController(IServiceProvider service)
        {
            hubContext = service.GetService<IHubContext<SignalrHubs>>();
        }

        [HttpGet]
        public string Get()
        {
            return DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss:ffff");
        }

        /// <summary>
        /// 單個connectionid推送
        /// </summary>
        /// <param name="groups"></param>
        /// <returns></returns>
        [HttpPost,Route("AnyOne")]
        public IActionResult AnyOne([FromBody]IEnumerable<SignalrGroups> groups)
        {
            if (groups != null && groups.Any())
            {
                var ids = groups.Select(c=>c.ShopId);
                var list = SignalrGroups.UserGroups.Where(c=>ids.Contains(c.ShopId));
                foreach (var item in list)
                    hubContext.Clients.Client(item.ConnectionId).InvokeAsync("AnyOne", $"{item.ConnectionId}: {item.Content}");
            }
            return Ok();
        }

        /// <summary>
        /// 全部推送
        /// </summary>
        /// <param name="message"></param>
        /// <returns></returns>
        [HttpGet,Route("EveryOne")]
        public IActionResult EveryOne(string message)
        {
            hubContext.Clients.All.InvokeAsync("EveryOne", $"{message}");
            return Ok();
        }

        /// <summary>
        /// 組推送
        /// </summary>
        /// <param name="group"></param>
        /// <returns></returns>
        [HttpPost,Route("AnyGroups")]
        public IActionResult AnyGroups([FromBody]SignalrGroups group)
        {
            if (group != null)
            {
                hubContext.Clients.Group(group.GroupName).InvokeAsync("AnyGroups", $"{group.Content}");
            }
            return Ok();
        }

        /// <summary>
        /// 多參數接收方式
        /// </summary>
        /// <param name="message"></param>
        /// <returns></returns>
        [HttpGet,Route("MoreParamsRequest")]
        public IActionResult MoreParamsRequest(string message)
        {
            hubContext.Clients.All.InvokeAsync("MoreParamsRequest", message, DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss:ffff"));
            return Ok();
        }
    }

伺服器端的代碼到這裡全部完成,接下來咱們看客戶端的代碼

我的客戶端代碼是在另外一個項目裡面,和伺服器端是分離的

<input type="text" id="ParentId" placeholder="ParentId" />
<br />
<input type="text" id="ShopId" placeholder="ShopId" />
<br />
<button id="fuckyou">用戶上線</button>
<br />
<br />
<br />

<ul id="message" style="color:red;"></ul>

@section scripts {
    <script>
        $(function () {

            let hubUrl = 'http://192.168.0.149:8009/signalrHubs';
            let httpConnection = new signalR.HttpConnection(hubUrl);
            let hubConnection = new signalR.HubConnection(httpConnection);
            $("#fuckyou").click(function () {
                hubConnection.invoke('InitUser', $("#ParentId").val(), $("#ShopId").val());
            });
            hubConnection.on('NoticeOnline', data => {
                $("#message").append("<li>" + data + "</li>");
            });
            hubConnection.on('EveryOne', data => {
                $("#message").append("<li style=\"color:red;\">全部推送:" + data + "</li>");
            });
            hubConnection.on('AnyGroups', data => {
                $("#message").append("<li style=\"color:black;\">單個用戶組推送:" + data + "</li>");
            });
            hubConnection.on('AnyOne', data => {
                $("#message").append("<li style=\"color:blue;\">單個ID推送:" + data + "</li>");
            });
            hubConnection.on('MoreParamsRequest', (message, date) => {
                $("#message").append("<li style=\"color:green;\">多參數接收:" + message + " : " + data + "</li>");
            });
            hubConnection.start();

        });
    </script>
}

頁面上引用連個js

<script src="/js/signalr-client.min.js"></script>
<script src="/js/jquery.min.js"></script>

 

到這裡基本就已經完成了,下麵看一下運行效果

 

第一次寫博客,有點緊張,代碼寫得比較倉促,很多細節都沒有優化,有很多不足之處,望各位多多指正

 


您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • 安裝Zabbix 下載安裝zabbix的YUM源 安裝Zabbix 安裝之後進入MySQL資料庫,創建Zabbix資料庫(密碼有複雜要求) 導入Zabbix到資料庫 配置zabbix用戶 配置Zabbix伺服器端 拷貝zabbix文件到html目錄 Zabbix加入開機啟動並啟動 在瀏覽器中測試Za ...
  • 前言 最近幾個月一直在研究開源的APM和監控方案,並對比使用了Zipkin,CAT,Sky walking,PinPoint(僅對比,未實際部署),Elastic APM,TICK Stack,Prometheus等開源產品,其中不乏功能強大的監控和追蹤系統,但它們都對.NET/.NET Core沒 ...
  • 傳送門:https://www.cnblogs.com/akwwl/p/3573666.html 之前錯誤:使用layui與web uploader上傳文件都報異常,後來終於找到原因是asp.net預設最大上傳文件大小為4M,運行超時時間為90S。 解決方法 1 : 修改web.config文件可以 ...
  • 背景: > 一直使用 Newtonsoft.Json.dll 也算挺穩定的。 > 但這個框架也挺鬧心的: > 1、影響編譯失敗:https://www.cnblogs.com/zihuxinyu/archive/2013/05/06/3063181.html (我也經常遇到) > 2、WinCE版本 ...
  • 面向對象六大原則: 單一職責原則、開閉原則、里式轉換原則、依賴倒置原則、介面隔離原則、迪米特原則 里式轉換原則: 關於里氏轉換原則,我總結出了兩點: 1、子類對象可以隱式轉換為父類對象。 2、如果父類對象有子類的構造函數實例化出來,那麼這個父類對象可以強制轉換為該子類對象。 強制轉換會用到 is 和 ...
  • 虛方法: 1、在父類方法的返回值前加 virtual 關鍵字,標記為虛方法,表示這個方法可以被子類重寫。 2、虛方法必須有方法體,方法體中可以沒有任何內容。 3、子類可以根據需求選擇性的是否重寫虛方法。如果需要重寫,在子類方法的返回值前加 override 關鍵字。 4、子類在重寫虛方法時,可以根據 ...
  • .net core的跨平臺有了Linux,不能沒有docker……網上的系列文章一大推,特別是docker還有了中文官網:https://www.docker-cn.com/ 。上面說的很清楚了,這裡只是操作記錄。操作的環境是:Ubuntu 16.04、docker。 一、參照官網安裝docker, ...
  • 恢復內容開始 Session共用是分散式架構設計中的一大難點,儘管session共用的解決方案不少,但是.net 下的解決方案還是比較少,而且說明文檔也很少。 之前嘗試用memcached緩存session,以解決session共用問題,後來發現實在是沒有解決方案,github上有一個Memcach ...
一周排行
    -Advertisement-
    Play Games
  • 移動開發(一):使用.NET MAUI開發第一個安卓APP 對於工作多年的C#程式員來說,近來想嘗試開發一款安卓APP,考慮了很久最終選擇使用.NET MAUI這個微軟官方的框架來嘗試體驗開發安卓APP,畢竟是使用Visual Studio開發工具,使用起來也比較的順手,結合微軟官方的教程進行了安卓 ...
  • 前言 QuestPDF 是一個開源 .NET 庫,用於生成 PDF 文檔。使用了C# Fluent API方式可簡化開發、減少錯誤並提高工作效率。利用它可以輕鬆生成 PDF 報告、發票、導出文件等。 項目介紹 QuestPDF 是一個革命性的開源 .NET 庫,它徹底改變了我們生成 PDF 文檔的方 ...
  • 項目地址 項目後端地址: https://github.com/ZyPLJ/ZYTteeHole 項目前端頁面地址: ZyPLJ/TreeHoleVue (github.com) https://github.com/ZyPLJ/TreeHoleVue 目前項目測試訪問地址: http://tree ...
  • 話不多說,直接開乾 一.下載 1.官方鏈接下載: https://www.microsoft.com/zh-cn/sql-server/sql-server-downloads 2.在下載目錄中找到下麵這個小的安裝包 SQL2022-SSEI-Dev.exe,運行開始下載SQL server; 二. ...
  • 前言 隨著物聯網(IoT)技術的迅猛發展,MQTT(消息隊列遙測傳輸)協議憑藉其輕量級和高效性,已成為眾多物聯網應用的首選通信標準。 MQTTnet 作為一個高性能的 .NET 開源庫,為 .NET 平臺上的 MQTT 客戶端與伺服器開發提供了強大的支持。 本文將全面介紹 MQTTnet 的核心功能 ...
  • Serilog支持多種接收器用於日誌存儲,增強器用於添加屬性,LogContext管理動態屬性,支持多種輸出格式包括純文本、JSON及ExpressionTemplate。還提供了自定義格式化選項,適用於不同需求。 ...
  • 目錄簡介獲取 HTML 文檔解析 HTML 文檔測試參考文章 簡介 動態內容網站使用 JavaScript 腳本動態檢索和渲染數據,爬取信息時需要模擬瀏覽器行為,否則獲取到的源碼基本是空的。 本文使用的爬取步驟如下: 使用 Selenium 獲取渲染後的 HTML 文檔 使用 HtmlAgility ...
  • 1.前言 什麼是熱更新 游戲或者軟體更新時,無需重新下載客戶端進行安裝,而是在應用程式啟動的情況下,在內部進行資源或者代碼更新 Unity目前常用熱更新解決方案 HybridCLR,Xlua,ILRuntime等 Unity目前常用資源管理解決方案 AssetBundles,Addressable, ...
  • 本文章主要是在C# ASP.NET Core Web API框架實現向手機發送驗證碼簡訊功能。這裡我選擇是一個互億無線簡訊驗證碼平臺,其實像阿裡雲,騰訊雲上面也可以。 首先我們先去 互億無線 https://www.ihuyi.com/api/sms.html 去註冊一個賬號 註冊完成賬號後,它會送 ...
  • 通過以下方式可以高效,並保證數據同步的可靠性 1.API設計 使用RESTful設計,確保API端點明確,並使用適當的HTTP方法(如POST用於創建,PUT用於更新)。 設計清晰的請求和響應模型,以確保客戶端能夠理解預期格式。 2.數據驗證 在伺服器端進行嚴格的數據驗證,確保接收到的數據符合預期格 ...