ScanClient/code/HXX.Scanner.Biz/socketServer/biz_socketServer.cs

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.IO;

using Newtonsoft.Json;
using HXX.Scanner.Socket;
using HXX.Scanner.Common;
using HXX.Scanner.Biz.Socket;

namespace HXX.Scanner.Biz
{
    /// <summary>
    /// ws工作管理
    /// </summary>
    public class biz_socketServer
    {
        /// <summary>
        /// 启动web socket
        /// </summary>
        /// <param name="url"></param>
        /// <returns></returns>
        public static bool Start(string url)
        {
            return SocketServerManager.Start(url, on_message_byte, on_message_string, on_close, on_connect);
        }

        /// <summary>
        /// 当新连接进入时
        /// </summary>
        /// <param name="connId"></param>
        private static void on_connect(IntPtr connId)
        {
            biz_connectMessage.Work(connId);
        }

        /// <summary>
        /// 当新消息到达时（string)
        /// </summary>
        /// <param name="connId"></param>
        /// <param name="data"></param>
        private static void on_message_string(IntPtr connId, string data)
        {
            //do nothing
        }

        /// <summary>
        /// 当新消息到达时（byte）
        /// </summary>
        /// <param name="connId"></param>
        /// <param name="data"></param>
        private static void on_message_byte(IntPtr connId, byte[] data)
        {
            Task.Run(() =>
            {
                biz_socketTask.DoWork(connId, data);
            });
        }

        /// <summary>
        /// 当连接关闭时
        /// </summary>
        /// <param name="connId"></param>
        /// <param name="connection_count"></param>
        public static void on_close(IntPtr connId, int connection_count)
        {
            //if (connection_count <= 1)
            //{
            //    config_environment.scan_state = false;
            //}
        }

        /// <summary>
        /// 主动发消息
        /// </summary>
        /// <param name=""></param>
        /// <returns></returns>
        public static void Send(string txt)
        {
            //SocketServerManager.Send_All(txt);
            SocketServerManager.Send_Single(config_environment.current_invoker, txt);
        }
    }
}