110 lines
3.4 KiB
C#
110 lines
3.4 KiB
C#
|
using System;
|
|||
|
|
using System.Collections.Generic;
|
|||
|
|
using System.Linq;
|
|||
|
|
using System.Net.Sockets;
|
|||
|
|
using System.Net;
|
|||
|
|
using System.Text;
|
|||
|
|
using System.Threading.Tasks;
|
|||
|
|
|
|||
|
|
namespace AutomaticApp.Common
|
|||
|
|
{
|
|||
|
|
public class Sockets
|
|||
|
|
{
|
|||
|
|
public delegate void PushSockets(Sockets sockets);
|
|||
|
|
|
|||
|
|
/// <summary>
|
|||
|
|
///
|
|||
|
|
/// </summary>
|
|||
|
|
public Sockets()
|
|||
|
|
{
|
|||
|
|
|
|||
|
|
}
|
|||
|
|
/// <summary>
|
|||
|
|
/// 创建Sockets对象
|
|||
|
|
/// </summary>
|
|||
|
|
/// <param name="ip">Ip地址</param>
|
|||
|
|
/// <param name="client">TcpClient</param>
|
|||
|
|
/// <param name="ns">承载客户端Socket的网络流</param>
|
|||
|
|
public Sockets(IPEndPoint ip, TcpClient client, NetworkStream ns)
|
|||
|
|
{
|
|||
|
|
Ip = ip;
|
|||
|
|
Client = client;
|
|||
|
|
nStream = ns;
|
|||
|
|
}
|
|||
|
|
/// <summary>
|
|||
|
|
/// 创建Sockets对象
|
|||
|
|
/// </summary>
|
|||
|
|
/// <param name="name">用户名</param>
|
|||
|
|
/// <param name="pass">密码</param>
|
|||
|
|
/// <param name="ip">Ip地址</param>
|
|||
|
|
/// <param name="client">TcpClient</param>
|
|||
|
|
/// <param name="ns">承载客户端Socket的网络流</param>
|
|||
|
|
public Sockets(string name, string pass, IPEndPoint ip, TcpClient client, NetworkStream ns)
|
|||
|
|
{
|
|||
|
|
UserName = name;
|
|||
|
|
Password = pass;
|
|||
|
|
Ip = ip;
|
|||
|
|
Client = client;
|
|||
|
|
nStream = ns;
|
|||
|
|
}
|
|||
|
|
/// <summary>
|
|||
|
|
/// 接收缓冲区
|
|||
|
|
/// </summary>
|
|||
|
|
public byte[] RecBuffer = new byte[8 * 1024];
|
|||
|
|
/// <summary>
|
|||
|
|
/// 发送缓冲区
|
|||
|
|
/// </summary>
|
|||
|
|
public byte[] SendBuffer = new byte[8 * 1024];
|
|||
|
|
/// <summary>
|
|||
|
|
/// 异步接收后包的大小
|
|||
|
|
/// </summary>
|
|||
|
|
public int Offset { get; set; }
|
|||
|
|
/// <summary>
|
|||
|
|
/// 用户名
|
|||
|
|
/// </summary>
|
|||
|
|
public string UserName { get; set; }
|
|||
|
|
/// <summary>
|
|||
|
|
/// 密码
|
|||
|
|
/// </summary>
|
|||
|
|
public string Password { get; set; }
|
|||
|
|
/// <summary>
|
|||
|
|
/// 当前IP地址，端口号
|
|||
|
|
/// </summary>
|
|||
|
|
public IPEndPoint Ip { get; set; }
|
|||
|
|
/// <summary>
|
|||
|
|
/// 客户端主通信程序
|
|||
|
|
/// </summary>
|
|||
|
|
public TcpClient Client { get; set; }
|
|||
|
|
/// <summary>
|
|||
|
|
/// 承载客户端Socket的网络流
|
|||
|
|
/// </summary>
|
|||
|
|
public NetworkStream nStream { get; set; }
|
|||
|
|
/// <summary>
|
|||
|
|
/// 发生异常时不为null
|
|||
|
|
/// </summary>
|
|||
|
|
public Exception ex { get; set; }
|
|||
|
|
/// <summary>
|
|||
|
|
/// 新客户端标识.如果推送器发现此标识为true,那么认为是客户端上线 仅服务端有效
|
|||
|
|
/// </summary>
|
|||
|
|
public bool NewClientFlag { get; set; }
|
|||
|
|
/// <summary>
|
|||
|
|
/// 客户端退出标识.如果服务端发现此标识为true,那么认为客户端下线
|
|||
|
|
/// 客户端接收此标识时,认为客户端异常.
|
|||
|
|
/// </summary>
|
|||
|
|
public bool ClientDispose { get; set; }
|
|||
|
|
|
|||
|
|
}
|
|||
|
|
/// <summary>
|
|||
|
|
/// Socket基类(抽象类)
|
|||
|
|
/// 抽象3个方法,初始化Socket(含一个构造),停止,启动方法.
|
|||
|
|
/// 此抽象类为TcpServer与TcpClient的基类,前者实现后者抽象方法
|
|||
|
|
/// </summary>
|
|||
|
|
public abstract class SocketObject
|
|||
|
|
{
|
|||
|
|
public abstract void InitSocket(IPAddress ipaddress, int port);
|
|||
|
|
public abstract void InitSocket(string ipaddress, int port);
|
|||
|
|
public abstract void Start();
|
|||
|
|
public abstract void Stop();
|
|||
|
|
}
|
|||
|
|
}
|