222

schangxiang@126.com

2025-08-23 2469c7e6490ee742df25fba27a69f7e866e6e798

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
using HPSocketCS;
using System.Runtime.InteropServices;
namespace iWareCc.Util
{
    /// <summary>
    /// Socket帮助抽象类，该类实现Socket的连接，关闭基本功能
    /// </summary>
    public abstract class SocketClient
    {
        /// <summary>
        /// socket连接客户端
        /// </summary>
        public TcpClient Client;
 
        /// <summary>
        /// 需要连接的服务器IP
        /// </summary>
        private string Ip;
 
        /// <summary>
        /// 需要连接的服务器端口
        /// </summary>
        private ushort Port;
 
        /// <summary>
        /// 记录客户端是否连上
        /// </summary>
        public bool IsClientOn = false;
 
 
        public SocketClient(TcpClient client, string ip, string port)
        {
            this.Client = client;
            this.Ip = ip;
            this.Port = ushort.Parse(port);
 
            //绑定client事件
            Client.OnConnect += new TcpClientEvent.OnConnectEventHandler(OnConnect);
            Client.OnSend += new TcpClientEvent.OnSendEventHandler(OnSend);
            Client.OnReceive += new TcpClientEvent.OnReceiveEventHandler(OnReceive);
            Client.OnClose += new TcpClientEvent.OnCloseEventHandler(OnClose);
        }
 
        /// <summary>
        /// 连接socket
        /// </summary>
        /// <returns>是否连接成功</returns>
        public bool Connect()
        {
 
            return Client.Connetion(Ip, Port, false);
 
        }
 
 
        /// <summary>
        /// 断开socket连接
        /// </summary>
        /// <returns>是否断开成功</returns>
        public bool Disconnect()
        {
            return Client.Stop();
        }
 
        /// <summary>
        /// 发送
        /// </summary>
        /// <param name="bytes"></param>
        /// <returns></returns>
        public virtual bool Send(byte[] bytes)
        {
 
            return Client.Send(bytes, bytes.Length);
        }
 
 
        /// <summary>
        /// 关闭socket时执行的代码
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="enOperation"></param>
        /// <param name="errorCode"></param>
        /// <returns></returns>
        protected abstract HandleResult OnClose(TcpClient sender, SocketOperation enOperation, int errorCode);
 
        /// <summary>
        /// 接收到报文时执行的代码
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="bytes">接收到的字符串</param>
        /// <returns></returns>
        protected abstract HandleResult OnReceive(TcpClient sender, byte[] bytes);
 
        /// <summary>
        /// 发送报文时执行的代码
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="bytes"></param>
        /// <returns></returns>
        protected abstract HandleResult OnSend(TcpClient sender, byte[] bytes);
 
 
        /// <summary>
        /// 连接客户端时执行的代码
        /// </summary>
        /// <param name="sender"></param>
        /// <returns></returns>
        protected abstract HandleResult OnConnect(TcpClient sender);
 
    }
}