概述
C#建立TCP/IP连接
在C/S模式下做网络信号传输,使用TCP/IP协议是首选。
其传输机制:
首先服务端与客户端建立套接字(socket)连接,建立完套接字后,服务端与客户端通过套接字进行数据传输。通常服务端和客户端需要各开启一个线程进行数据的接收。
1.构建连接
首先服务端开启套接字监听服务,然后客户端根据服务器的IP、端口进行连接。
1.1服务端开启套接字
Socket serverSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream,ProtocolType.Tcp);
serverSocket.Bind(new IPEndPoint(ip, myProt)); //绑定IP地址:端口
serverSocket.Listen(10);//设定最多10个排队连接请求
注意在绑定IP时serverSocket.Bind(new IPEndPoint(ip, myProt));
如果使用127.0.0.1时,客户端连接服务端的IP也必须是127.0.0.1,即要求服务端、客户端都在本地才可以通联。因此,需要将服务器套接字绑定的IP改为对外的IP,如192.168.0.1;
获取对外IP的方法为
/// <summary>
/// 获取本地IP
/// </summary>
/// <returns></returns>
private string GetAddressIP()
{
string AddressIP = string.Empty;
foreach (IPAddress _IPAddress in Dns.GetHostEntry(Dns.GetHostName()).AddressList)
{
if (_IPAddress.AddressFamily.ToString() == "InterNetwork")
{
AddressIP = _IPAddress.ToString();
}
}
return AddressIP;
}
1.2开启监听客户端连接的线程
new Thread(ListenClientConnect).Start(this);
/// <summary>
/// 监听客户端连接
/// </summary>
private static void ListenClientConnect(object server)
{
Server myServer = (Server)server;
myServer.clientSocket = serverSocket.Accept();//线程在此等待,直到有客户端连接后方继续执行
myServer.clientSocket.Send(Encoding.UTF8.GetBytes("连接成功"));
Thread receiveThread = new Thread(ReceiveMessage);//启动接收信息线程
receiveThread.Start(server);
}
当serverSocket.Accept()执行后就完成了套接字的建立,就可以发送消息了。
1.3客户端建立与服务端的连接
客户端也定义一个套接字 clientSocket,再调用其connect方法与服务端连接。
public bool createConn()
{
try
{
IPAddress ip = IPAddress.Parse(textBox_serverIp.Text);
clientSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
int connPort = Int16.Parse(textBox_serverPort.Text);
clientSocket.Connect(new IPEndPoint(ip, connPort)); //配置服务器IP与端口
writeLog("连接服务器成功");
button_createConn.Text = "断开连接";
//开启监听线程
receiveThread = new Thread(receiveMsg);
receiveThread.Start(this);
}
catch (Exception e)
{
writeLog("连接服务器失败" + e.ToString());
return false;
}
return true;
}
2.数据传输
2.1数据发送
服务端与客户端数据发送均是调用Socket进行传输。注意传输的数据需要进行编码Encoding.UTF8.GetBytes()
/// <summary>
/// 发送消息
/// </summary>
/// <param name="signal"></param>
/// <returns></returns>
private bool sendSignal(string signal)
{
if (clientSocket == null)
{
writeLog("发送失败,未连接客户端");
return false;
}
try
{
clientSocket.Send(Encoding.UTF8.GetBytes(signal + "。"));
return true;
}
catch (Exception e)
{
writeLog("发送失败" + e.ToString());
clientSocket = null;
}
return false;
}
2.2数据接收
数据的接收建议开启一个新的线程进行接收,接收是通过调用socket的Receive方法实现的。
new Thread(receiveMsg).Start(this);
/// <summary>
/// 接受消息处理线程
/// </summary>
/// <param name="clientForm"></param>
public static void receiveMsg(object clientForm)
{
Client myClient = (Client)clientForm;
byte[] result = new byte[1024];
while (true)
{
try
{
//通过clientSocket接收数据
int receiveLength = myClient.clientSocket.Receive(result);
string resultStr = Encoding.UTF8.GetString(result, 0, receiveLength);
myClient.writeLog(string.Format("接收服务器消息:{0}", resultStr));
}
catch (Exception e)
{
myClient.writeLog("读取数据失败,服务器可能已经断开" + e.ToString());
Thread.Sleep(300);
myClient.closeConn();
}
}
}
3.关闭连接
想套接字发送关闭的信号后,将本地套接字关闭
clientSocket.Shutdown(SocketShutdown.Both);
myServer.clientSocket.Close();
4.点击下载例程
最后
以上就是犹豫大侠为你收集整理的C#建立TCP/IP连接C#建立TCP/IP连接的全部内容,希望文章能够帮你解决C#建立TCP/IP连接C#建立TCP/IP连接所遇到的程序开发问题。
如果觉得靠谱客网站的内容还不错,欢迎将靠谱客网站推荐给程序员好友。
本图文内容来源于网友提供,作为学习参考使用,或来自网络收集整理,版权属于原作者所有。
发表评论 取消回复