332 lines
11 KiB
C#
332 lines
11 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;
|
||
using static JiangsuEarthquake.Common.Sockets;
|
||
|
||
namespace JiangsuEarthquake.Common
|
||
{
|
||
public class Server : SocketObject
|
||
{
|
||
public PushSockets pushSockets;
|
||
|
||
bool IsStop = false;
|
||
|
||
object obj = new object();
|
||
|
||
/// <summary>
|
||
/// 信号量
|
||
/// </summary>
|
||
private Semaphore semap = new Semaphore(5, 5000);
|
||
|
||
/// <summary>
|
||
/// 客户端队列集合
|
||
/// </summary>
|
||
public List<Sockets> ClientList = new List<Sockets>();
|
||
|
||
/// <summary>
|
||
/// 服务端
|
||
/// </summary>
|
||
private TcpListener listener;
|
||
|
||
/// <summary>
|
||
/// 当前IP地址
|
||
/// </summary>
|
||
private IPAddress Ipaddress;
|
||
|
||
/// <summary>
|
||
/// 校时信息
|
||
/// </summary>
|
||
public List<byte> TimingList = new List<byte>();
|
||
|
||
/// <summary>
|
||
/// 当前监听端口
|
||
/// </summary>
|
||
private int Port;
|
||
|
||
/// <summary>
|
||
/// 当前IP,端口对象
|
||
/// </summary>
|
||
private IPEndPoint ip;
|
||
|
||
/// <summary>
|
||
/// 初始化服务端对象
|
||
/// </summary>
|
||
/// <param name="ipaddress">IP地址</param>
|
||
/// <param name="port">监听端口</param>
|
||
public override void InitSocket(IPAddress ipaddress, int port)
|
||
{
|
||
Ipaddress = ipaddress;
|
||
Port = port;
|
||
listener = new TcpListener(Ipaddress, Port);
|
||
}
|
||
|
||
|
||
/// <summary>
|
||
/// 初始化服务端对象
|
||
/// </summary>
|
||
/// <param name="ipaddress">IP地址</param>
|
||
/// <param name="port">监听端口</param>
|
||
public override void InitSocket(string ipaddress, int port)
|
||
{
|
||
Ipaddress = IPAddress.Parse(ipaddress);
|
||
Port = port;
|
||
ip = new IPEndPoint(Ipaddress, Port);
|
||
listener = new TcpListener(Ipaddress, Port);
|
||
}
|
||
|
||
|
||
/// <summary>
|
||
/// 启动监听,并处理连接
|
||
/// </summary>
|
||
public override bool Start()
|
||
{
|
||
try
|
||
{
|
||
listener.Start();
|
||
Thread AccTh = new Thread(new ThreadStart(delegate
|
||
{
|
||
while (true)
|
||
{
|
||
if (IsStop != false)
|
||
{
|
||
break;
|
||
}
|
||
GetAcceptTcpClient();
|
||
Thread.Sleep(1);
|
||
}
|
||
}));
|
||
AccTh.Start();
|
||
|
||
return true;
|
||
}
|
||
catch (SocketException skex)
|
||
{
|
||
Sockets sks = new Sockets();
|
||
sks.ex = skex;
|
||
if (pushSockets != null)
|
||
pushSockets.Invoke(sks);//推送至UI
|
||
|
||
return false;
|
||
}
|
||
}
|
||
|
||
|
||
/// <summary>
|
||
/// 停止
|
||
/// </summary>
|
||
public override void Stop()
|
||
{
|
||
if (listener != null)
|
||
{
|
||
listener.Stop();
|
||
listener = null;
|
||
IsStop = true;
|
||
pushSockets = null;
|
||
}
|
||
}
|
||
|
||
|
||
/// <summary>
|
||
/// 等待处理新的连接
|
||
/// </summary>
|
||
private void GetAcceptTcpClient()
|
||
{
|
||
try
|
||
{
|
||
if (listener.Pending())
|
||
{
|
||
semap.WaitOne();
|
||
TcpClient tclient = listener.AcceptTcpClient();
|
||
//维护客户端队列
|
||
Socket socket = tclient.Client;
|
||
NetworkStream stream = new NetworkStream(socket, true); //承载这个Socket
|
||
Sockets sks = new Sockets(tclient.Client.RemoteEndPoint as IPEndPoint, tclient, stream);
|
||
sks.NewClientFlag = true;
|
||
//推送新客户端
|
||
if (pushSockets != null)
|
||
pushSockets.Invoke(sks);
|
||
//客户端异步接收
|
||
sks.nStream.BeginRead(sks.RecBuffer, 0, sks.RecBuffer.Length, new AsyncCallback(EndReader), sks);
|
||
//加入客户端集合.
|
||
AddClientList(sks);
|
||
|
||
//主动向客户端发送校时信息
|
||
if (stream.CanWrite)
|
||
{
|
||
TimingList.Clear();
|
||
TimingList.AddRange(new byte[2] { 0xFE, 0xEF }); //帧头（H=0xFE 0xEF)
|
||
TimingList.AddRange(new byte[2] { 0x00, 0x08 }); //长度（L=4+4)(MSH MSL）(从地址码到最后)
|
||
TimingList.Add(0x00); //地址码(ADDR=00)
|
||
TimingList.Add(0x06); //功能码（FUNC=06)
|
||
|
||
TimeSpan ts = DateTime.Now - new DateTime(1970, 1, 1, 8, 0, 0, 0);
|
||
int totalSeconds = (int)ts.TotalSeconds;
|
||
string hexSeconds = totalSeconds.ToString("X2");
|
||
byte[] timeByte = Tools.HexStringToByteArray(hexSeconds);
|
||
TimingList.AddRange(timeByte); //UTC时间
|
||
byte checkSum = Tools.CheckSum(TimingList.ToArray());
|
||
TimingList.Add(checkSum); //校验(CS = 帧头 ...+... 传感器数据）
|
||
TimingList.Add(0x16); //结束符(0x16)
|
||
stream.Write(TimingList.ToArray(), 0, TimingList.Count);
|
||
}
|
||
|
||
semap.Release();
|
||
}
|
||
}
|
||
catch
|
||
{
|
||
return;
|
||
}
|
||
}
|
||
|
||
|
||
/// <summary>
|
||
/// 异步接收发送的信息.
|
||
/// </summary>
|
||
/// <param name="ir"></param>
|
||
private void EndReader(IAsyncResult ir)
|
||
{
|
||
Sockets sks = ir.AsyncState as Sockets;
|
||
if (sks != null && listener != null)
|
||
{
|
||
try
|
||
{
|
||
if (sks.NewClientFlag || sks.Offset != 0)
|
||
{
|
||
sks.NewClientFlag = false;
|
||
sks.Offset = sks.nStream.EndRead(ir);
|
||
if (pushSockets != null)
|
||
pushSockets.Invoke(sks);//推送至UI
|
||
sks.nStream.BeginRead(sks.RecBuffer, 0, sks.RecBuffer.Length, new AsyncCallback(EndReader), sks);
|
||
}
|
||
}
|
||
catch (Exception skex)
|
||
{
|
||
lock (obj)
|
||
{
|
||
//移除异常类
|
||
ClientList.Remove(sks);
|
||
Sockets sk = sks;
|
||
sk.ClientDispose = true;//客户端退出
|
||
sk.ex = skex;
|
||
if (pushSockets != null)
|
||
pushSockets.Invoke(sks);//推送至UI
|
||
}
|
||
}
|
||
}
|
||
}
|
||
|
||
|
||
/// <summary>
|
||
/// 加入队列.
|
||
/// </summary>
|
||
/// <param name="sk"></param>
|
||
private void AddClientList(Sockets sk)
|
||
{
|
||
//虽然有信号量,还是用lock增加系数
|
||
lock (obj)
|
||
{
|
||
Sockets sockets = ClientList.Find(o => { return o.Ip == sk.Ip; });
|
||
//如果不存在则添加,否则更新
|
||
if (sockets == null)
|
||
{
|
||
ClientList.Add(sk);
|
||
}
|
||
else
|
||
{
|
||
ClientList.Remove(sockets);
|
||
ClientList.Add(sk);
|
||
}
|
||
}
|
||
}
|
||
|
||
|
||
/// <summary>
|
||
/// 向所有在线的客户端发送信息.
|
||
/// </summary>
|
||
/// <param name="SendData">发送的byte[]</param>
|
||
public void SendToAll(byte[] SendData)
|
||
{
|
||
try
|
||
{
|
||
Parallel.ForEach(ClientList, new ParallelOptions() { MaxDegreeOfParallelism = 5 }, item =>
|
||
{
|
||
if (item != null)
|
||
SendToClient(item.Ip, SendData);
|
||
});
|
||
}
|
||
catch (Exception ex)
|
||
{
|
||
//Console.Write(ex.Message);
|
||
}
|
||
}
|
||
|
||
|
||
/// <summary>
|
||
/// 向某一位客户端发送信息
|
||
/// </summary>
|
||
/// <param name="ip">客户端IP+端口地址</param>
|
||
/// <param name="SendData">发送的数据包</param>
|
||
public void SendToClient(IPEndPoint ip, byte[] SendData)
|
||
{
|
||
try
|
||
{
|
||
Sockets sks = ClientList.Find(o => { return o.Ip == ip; });
|
||
if (sks == null || !sks.Client.Connected || sks.ClientDispose)
|
||
{
|
||
//没有连接时,标识退出
|
||
Sockets ks = new Sockets();
|
||
sks.ClientDispose = true;//标识客户端下线
|
||
sks.ex = new Exception("客户端无连接");
|
||
if (pushSockets != null)
|
||
pushSockets.Invoke(sks);//推送至UI
|
||
ClientList.Remove(sks);
|
||
}
|
||
if (sks.Client.Connected)
|
||
{
|
||
//获取当前流进行写入.
|
||
NetworkStream nStream = sks.nStream;
|
||
if (nStream.CanWrite)
|
||
{
|
||
//byte[] buffer = Encoding.UTF8.GetBytes(SendData);
|
||
nStream.Write(SendData, 0, SendData.Length);
|
||
}
|
||
else
|
||
{
|
||
//避免流被关闭,重新从对象中获取流
|
||
nStream = sks.Client.GetStream();
|
||
if (nStream.CanWrite)
|
||
{
|
||
//byte[] buffer = Encoding.UTF8.GetBytes(SendData);
|
||
nStream.Write(SendData, 0, SendData.Length);
|
||
}
|
||
else
|
||
{
|
||
//如果还是无法写入,那么认为客户端中断连接.
|
||
ClientList.Remove(sks);
|
||
Sockets ks = new Sockets();
|
||
sks.ClientDispose = true;//如果出现异常,标识客户端下线
|
||
sks.ex = new Exception("客户端无连接");
|
||
if (pushSockets != null)
|
||
pushSockets.Invoke(sks);//推送至UI
|
||
|
||
}
|
||
}
|
||
}
|
||
}
|
||
catch (Exception skex)
|
||
{
|
||
Sockets sks = new Sockets();
|
||
sks.ClientDispose = true;//如果出现异常,标识客户端退出
|
||
sks.ex = skex;
|
||
if (pushSockets != null)
|
||
pushSockets.Invoke(sks);//推送至UI
|
||
}
|
||
}
|
||
}
|
||
}
|