.NET下使用socket.io随笔记录

1、问题背景

目前公司在互联网产品上须要程序与前端部分要进行一个实时交互，在进行必定程度上的选型后，决定使用socket.io框架进行一个实践，算是公司的一个新的 尝试，也算是给本身增长增加见闻，因为我是作后端以及桌面程序开发，因此前端部分就不细聊，主要是针对桌面程序如何链接socket.io进行一个尝试

2、基本逻辑图

　　本地应用程序：部署在局域网内（能够联通外网），主要负责相关数据获取

　　Web浏览器端：跟本地应用程序不是处于同一个网络，请求发起方

　　中转服务（重点）：中转服务集成认证功能，必须通过认证的客户端才容许进行链接，而且对于客户端要有惟一指定的ID进行链接操做

　　总体思路如以上的流程图，由Web浏览器端开始发起请求，Web浏览器端经过链接中转服务，将信息发送给指定的本地应用程序，应用程序处理完成后，将结果经过原路径进行一个反馈

2、客户端程序开发

　　客户端SDK采用SocketIoClientDotNet，这是一个github上开源的，能够链接socket.io的客户端，支持.net 3.5及以上，能够方便的帮助咱们进行链接socket.io的开发

 Socket  socket = IO.Socket("ws://192.168.7.4:3000", new IO.Options()
            {
                Reconnection = true,
                Cookies = new Dictionary<string, string>() { { "companyId", GlobalStatic.COMPANY.COMPANY_ID }, { "userId", GlobalStatic.UserDomain.user.USER_ID } },
                Timeout = 60000,
                ReconnectionDelay = 1000,

                Transports = new List<string>() { "websocket" },
                Path ="heart"
            });

            socket.On(Socket.EVENT_CONNECT, () =>
            {

                JObject jObject = JObject.Parse(Newtonsoft.Json.JsonConvert.SerializeObject(new
                {
                    companyId = GlobalStatic.COMPANY.COMPANY_ID,
                    token = GlobalStatic.TOKEN,
                    hostId = GlobalStatic.HOST_ID,
                    hostName = GlobalStatic.HOST_NAME,
                    printerNames = GlobalStatic.HOSTINFO.PrinterName,
                    source = "assistant",
                    userId = GlobalStatic.UserDomain.user.USER_ID
                }));
                socket.Emit("authentication", jObject);
                Debug.WriteLine("authentication");
            });
            socket.On(Socket.EVENT_DISCONNECT, (data) =>
            {
                Debug.WriteLine("心跳断开链接" + data);
                flag = false;
                OnConnectionStatus?.Invoke(flag);
                socket.Disconnect();
            });
            socket.On("authenticated", (obj) =>
            {
                flag = true;
                OnConnectionStatus?.Invoke(flag);
                Debug.WriteLine("心跳认证成功：" + obj);
            });
            socket.On("unauthorized", (obj) =>
            {
                Debug.WriteLine("心跳认证失败" + obj);
                socket.Disconnect();
            });

SocketIoClientDotNet注意点：

1. emit的数据必须为字符串或者JObject（Newtonsoft.Json中的）
2. 从实际状况来看，内部每一个On的监听都是维护了一个线程，全部若是是不想要阻塞的话，那在on的方法中还须要本身起线程去完成
3. 若是不在options中设置AutoConnect=false的话，那实例化socket成功以后就会进行connect动做

3、关于SocketIoClientDotNet坑的问题

　　在实际的使用过程当中，偶然发如今程序开了好久 以后，线程数会一直增多，尝试调节各类参数都毫无做用，最后只能无奈的跟踪源码部分，在Thread文件夹下找到Heartbeat_net35.cs文件中，发现run方法里的while一直没法跳出去，而且注册DoWork愈来愈多，以下所示，致使线程愈来愈多，目前解决办法是将该代码注释掉，还没发现什么问题，若是有哪位知道这段代码做用的话，望告知，谢谢

using System;
using System.ComponentModel;
using System.Threading;

namespace Quobject.EngineIoClientDotNet.Thread
{
    public class Heartbeat
    {
        private volatile bool gotHeartbeat = false;
        private BackgroundWorker heartBeatTimer= new BackgroundWorker();
        private CancellationTokenSource ts;

        private Heartbeat()
        {
            ts = new CancellationTokenSource();
        }

        public static Heartbeat Start(Action onTimeout, int timeout)
        {
            Heartbeat heartbeat = new Heartbeat();
            heartbeat.Run(onTimeout, timeout);
            return heartbeat;            
        }

        public void OnHeartbeat()
        {
            gotHeartbeat = true;
        }

        private void Run(Action onTimeout, int timeout)
        {
            heartBeatTimer = new BackgroundWorker();

            heartBeatTimer.DoWork += (s, e) =>
            {
               while (!ts.IsCancellationRequested)
               {
                    System.Threading.Thread.Sleep(timeout);
                    if (!gotHeartbeat && !ts.IsCancellationRequested)
                    {
                        onTimeout();
                        break;
                    }
                }
            };

            heartBeatTimer.RunWorkerAsync();
        }

        public void Stop()
        {
            ts.Cancel();
        }
    }
}

　　

做者： Mango

出处： http://www.cnblogs.com/OMango/

关于本身：专一.Net桌面开发以及Web后台开发，开始接触微服务、docker等互联网相关

本文版权归做者和博客园共有，欢迎转载，但未经做者赞成必须保留此段声明，且在文章页面明显位置给出, 原文连接 若有问题， 可邮件（hongjb@yizit.com）咨询.