c# socket进行通信服务端

小渣渣 · 发表于 2016-1-27 13:01:30

using System;
using System.Collections.Generic;
using System.Linq;
using System.Net;
using System.Net.Sockets;
using System.Text;
using System.Threading;
namespace Remote.Client.SocketClient
{
/// <summary>
/// 同步socket
/// </summary>
public class TsyncSocket
{
private static Socket serviceSocketListener;
public static bool SocketStart(string _ip, int prot)
{
try
{
IPAddress ip = IPAddress.Parse(_ip);
serviceSocketListener = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
serviceSocketListener.Bind(new IPEndPoint(ip, prot)); //绑定IP地址：端口
serviceSocketListener.Listen(1024); //设定最多1024个排队连接请求
Thread myThread = new Thread(ListenClientConnect);
myThread.IsBackground = true;
myThread.Start();
return true;
}
catch (Exception ex)
{
return false;
}
}
/// <summary>
/// 监听客户端连接
/// </summary>
private static void ListenClientConnect()
{
while (true)
{
Socket clientSocket = serviceSocketListener.Accept();
clientSocket.Send(Encoding.UTF8.GetBytes(Remote.Seeting.Msg.success.ToString()));
#region 连接成功
Thread recTh = new Thread(RecMsg); //收消息线程
recTh.IsBackground = true;
recTh.Start(clientSocket);
Thread sendTh = new Thread(SendMsg); //发消息线程
sendTh.IsBackground = true;
sendTh.Start(clientSocket);
#endregion
}
}
/// <summary>
/// 接受消息线程
/// </summary>
/// <param name="o"></param>
private static void RecMsg(object o)
{
Socket connSocket = o as Socket;
try
{
while (true)
{
byte[] buffer = new Byte[1048576];
int receiveLength = connSocket.Receive(buffer);
string str = Encoding.UTF8.GetString(buffer, 0, receiveLength); //接受到的消息
//先解密
string publicMsg=null;
try
{
publicMsg = Remote.Common.Security.RSACryptoProvider.SectionDecrypt(str, Setting.model.SecretKey);
}
catch (Exception ex)
{
connSocket.Send(Encoding.UTF8.GetBytes("消息不正确 msg error"));
continue;
}
if (!string.IsNullOrEmpty(publicMsg))
{
string[] temp = publicMsg.Split('#');
if (temp[0].ToLower().Equals(Setting.model.md5))
{
//秘钥正确
//connSocket.Send(Encoding.UTF8.GetBytes(temp[1]));
string msgtemp = null;
switch (temp[1].ToUpper())
{
case "CMD":
msgtemp=Function.ExeCmd.Cmd(temp[2]);
break;
}
connSocket.Send(Encoding.UTF8.GetBytes(msgtemp));
}
}
else
{
connSocket.Send(Encoding.UTF8.GetBytes("秘钥不正确"));
}
}
}
catch (Exception ex)
{
if (connSocket.Connected)
{
connSocket.Shutdown(SocketShutdown.Both);
connSocket.Close();
}
}
}
/// <summary>
/// 发送消息线程
/// </summary>
/// <param name="o"></param>
private static void SendMsg(object o)
{
Socket connSocket = o as Socket;
try
{
while (true)
{
if (!string.IsNullOrEmpty(Setting.Msg))
{
lock (Setting.Msg)
{
connSocket.Send(Encoding.UTF8.GetBytes(Setting.Msg));
Setting.Msg = null;
}
}
}
}
catch (Exception ex)
{
if (connSocket.Connected)
{
connSocket.Shutdown(SocketShutdown.Both);
connSocket.Close();
}
}
}
}
}

复制代码

这个是服务端

comsharp · 发表于 2023-5-4 18:18:52

有没有内容？模拟websocket客户端连接

		自动登录	找回密码
密码			注册[Register]

[资料] c# socket进行通信服务端

相关帖子