System.Net.Sockets
using iService.SocketParam;
using System;
using System.Collections;
using System.Collections.Generic;
using System.Linq;
using System.Net;
using System.Net.Sockets;
using System.Text;
using System.Threading;
using System.Threading.Tasks;
using System.Web.Script.Serialization;
using SocketServer;
namespace iService
{
public class SocketHost
{
private IDictionary<Socket, byte[]> socketClientSesson = new Dictionary<Socket, byte[]>();
public int Port { get; set; }
public void Start()
{
var socketThread = new Thread(() =>
{
Socket socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
IPEndPoint iep = new IPEndPoint(IPAddress.Any, this.Port);
//绑定到通道上
socket.Bind(iep);
//侦听
socket.Listen(100000);
//通过异步来处理
socket.BeginAccept(new AsyncCallback(Accept), socket);
});
socketThread.Start();
Error.WriteToFile("Socket服务器已启动");
}
/// <summary>
/// 链接
/// </summary>
/// <param name="ia"></param>
private void Accept(IAsyncResult ia)
{
try
{
Socket socket = ia.AsyncState as Socket;
var client = socket.EndAccept(ia);
socket.BeginAccept(new AsyncCallback(Accept), socket);
byte[] buf = new byte[1024];
this.socketClientSesson.Add(client, buf);
string sessionId = client.Handle.ToString();
client.BeginReceive(buf, 0, buf.Length, SocketFlags.None, new AsyncCallback(Receive), client);
//保存客户端
//保存完成
Error.WriteToFile(string.Format("客户端({0})已连接", sessionId));
}
catch (Exception ex)
{
Error.WriteToFile("监听请求时出错:\r\n" + ex.ToString());
}
}
/// <summary>
/// 接收信息
/// </summary>
/// <param name="ia"></param>
private void Receive(IAsyncResult ia)
{
var client = ia.AsyncState as Socket;
if (client == null || !this.socketClientSesson.ContainsKey(client))
{
return;
}
int count = client.EndReceive(ia);
byte[] buf = this.socketClientSesson[client];
//byte[] buf = new byte[1024];
string sessionId = client.Handle.ToString();
if (count > 0)
{
try
{
client.BeginReceive(buf, 0, buf.Length, SocketFlags.None, new AsyncCallback(Receive), client);
string context = Encoding.UTF8.GetString(buf, 0, count);
Param.AddCache(sessionId, context);
ArrayList ai = Param.OutCache(sessionId);
foreach (object o in ai)
{
string s = o.ToString();
Error.WriteToFile(string.Format("接收的数据为:{0}", s));
this.Response(client, s);
Thread.Sleep(1000);
}
}
catch (Exception ex)
{
Error.WriteToFile(string.Format("接收的数据出错:{0}", ex.ToString()));
}
}
else
{
try
{
client.Disconnect(true);
this.socketClientSesson.Remove(client);
Param.RemoveCache(sessionId);
Error.WriteToFile(string.Format("客户端({0})已断开", sessionId));
}
catch (Exception ex)
{
Error.WriteToFile(string.Format("客户端已断开出错" + ex.ToString()));
}
}
}
private void Response(Socket sender, string context)
{
SocketRequest request = null;
JavaScriptSerializer jss = new JavaScriptSerializer();
request = jss.Deserialize(context, typeof(SocketRequest)) as SocketRequest;
if (request == null)
{
return;
}
var typeName = "SocketServer." + request.API + "ResponseManager";
Error.WriteToFile(string.Format("反射类名为:{0}", typeName));
Type type = Type.GetType(typeName);
if (type == null)
{
Error.WriteToFile(string.Format("Type反射为空"));
return;
}
var manager = Activator.CreateInstance(type) as IResponseManager;
manager.Exec(sender, this.socketClientSesson.Select(s => s.Key).ToList(),
request.Data as IDictionary<string, object>,request.Sign);
}
}
}