最初的版本是这样的：点击打开链接。但一直没有调好，所以就咨询了一下同事翔哥，最后初步搞定！
客户端代码：
using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Linq;
using System.Text;
using System.Windows.Forms;
using System.Net.Sockets;
using System.Threading;
using System.Net;
using System.Diagnostics;
namespace SocketClient
{
public partial class Client : Form
{
Socket vsServerSocket;
Thread vsClientThread;
string strIP = "127.0.0.1";
public delegate void PassString(string strMsg);
int nPort = 9001;
public Client()
{
InitializeComponent();
}
public void SetSendData(string strMsg)
{
if (tBoxClientSend.InvokeRequired == true)
{
PassString d = new PassString(SetSendData);
this.Invoke(d, new object[] { strMsg });
}
else
{
tBoxClientSend.Text = strMsg;
}
}
public void SetRecvData(string strMsg)
{
if (tBoxClientReceive.InvokeRequired == true)
{
PassString d = new PassString(SetRecvData);
this.Invoke(d, new object[] { strMsg });
}
else
{
tBoxClientReceive.Text = strMsg;
}
}
private void ClientHandle()
{
string strRecv = string.Empty;
//IPEndPoint其实就是一个IP地址和端口的绑定，可以代表一个服务，用来Socket通讯。
//IPAddress类中有一个 Parse()方法，可以把点分的十进制IP表示转化成IPAddress类
IPEndPoint ipep = new IPEndPoint(IPAddress.Parse(strIP), nPort);
//创建套接字实例
//这里创建的时候用ProtocolType.Tcp，表示建立一个面向连接(TCP)的Socket
vsServerSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
try
{
//将所创建的套接字与IPEndPoint绑定
vsServerSocket.Bind(ipep);
}
catch (SocketException ex)
{
MessageBox.Show("Connect Error: " + ex.Message);
return;
}
Byte[] buffer = new Byte[1024];
//设置套接字为收听模式
vsServerSocket.Listen(10);
//循环监听
while (true)
{
//接收服务器信息
int bufLen = 0;
try
{
Socket vsClientSocket = vsServerSocket.Accept();
bufLen=vsClientSocket.Receive(buffer);
vsClientSocket.Send(Encoding.ASCII.GetBytes("aaaaa"), 5, SocketFlags.None);
}
catch (Exception ex)
{
MessageBox.Show("Receive Error:" + ex.Message);
}
strRecv = Encoding.ASCII.GetString(buffer, 0, bufLen);
SetRecvData(strRecv);
//vsClientSocket.Shutdown(SocketShutdown.Both);
//vsClientSocket.Close();
}
}
//发送数据
private void btnSend_Click(object sender, EventArgs e)
{
byte[] data = new byte[1024];
string ss = tBoxClientSend.Text;
Socket centerClient = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
IPEndPoint GsServer = new IPEndPoint(IPAddress.Parse("127.0.0.1"), 9002);
centerClient.Connect(GsServer);
centerClient.Send(Encoding.ASCII.GetBytes(ss));
centerClient.Close();
}
private void Client_Load(object sender, EventArgs e)
{
//连接服务器
//通过ThreadStart委托告诉子线程讲执行什么方法
vsClientThread = new Thread(new ThreadStart(ClientHandle));
vsClientThread.Start();
}
//窗体关闭时杀死客户端进程
private void Client_FormClosing(object sender, FormClosingEventArgs e)
{
KillProcess();
}
//杀死客户端进程
private void KillProcess()
{
Process[] processes = Process.GetProcessesByName("SocketClient");
foreach (Process process in processes)
{
process.Kill();
break;
}
}
}
}服务端代码：
using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Linq;
using System.Text;
using System.Windows.Forms;
using System.Threading;
using System.Net.Sockets;
using System.Net;
using System.Diagnostics;
namespace SocketServer
{
public partial class Server : Form
{
Thread vsServerThread;
Socket vsServerSocket;
string strIP = "127.0.0.1";
public delegate void PassString(string strMsg);
int nPort = 9002;
public Server()
{
InitializeComponent();
}
private void SeverSendData(string strMsg)
{
//Control.InvokeRequired 属性,命名空间： System.Windows.Forms
//获取一个值，该值指示调用方在对控件进行方法调用时是否必须调用 Invoke 方法，因为调用方位于创建控件所在的线程以外的线程中。
if (tBoxServerSend.InvokeRequired == true)
{
//Control.Invoke 方法 (Delegate)
//在拥有此控件的基础窗口句柄的线程上执行指定的委托。
PassString d = new PassString(SeverSendData);
this.Invoke(d, new object[] { strMsg });
}
else
{
tBoxServerSend.Text = strMsg;
}
}
private void SeverRecvData(string strMsg)
{
if (tBoxServerReceive.InvokeRequired == true)
{
PassString d = new PassString(SeverRecvData);
this.Invoke(d, new object[] { strMsg });
}
else
{
tBoxServerReceive.Text = strMsg;
}
}
private void ServerStart()
{
string strRecv = string.Empty;
//创建IPEndPoint实例
IPEndPoint ipep = new IPEndPoint(IPAddress.Parse(strIP), nPort);
//创建一个套接字
vsServerSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
//将所创建的套接字与IPEndPoint绑定
try
{
vsServerSocket.Bind(ipep);
}
catch (Exception ee)
{
MessageBox.Show(ee.ToString());
return;
}
//设置套接字为收听模式
vsServerSocket.Listen(10);
int bufLen = 0;
//循环监听
while (true)
{
//在套接字上接收接入的连接
Socket vsClientSocket = vsServerSocket.Accept();
try
{
Byte[] buffer = new Byte[1024];
//在套接字上接收客户端发送的信息
bufLen = vsClientSocket.Receive(buffer);
vsClientSocket.Send(Encoding.ASCII.GetBytes("aaaaa"), 5, SocketFlags.None);
if (bufLen == 0)
continue;
//将指定字节数组中的一个字节序列解码为一个字符串。
strRecv = Encoding.ASCII.GetString(buffer, 0, bufLen);
SeverRecvData(strRecv.ToString());
}
catch (Exception ex)
{
MessageBox.Show("Listening Error: " + ex.Message);
vsClientSocket.Close();
vsServerSocket.Close();
}
}
}
private void btnSend_Click(object sender, EventArgs e)
{
byte[] data = new byte[1024];
string ss = tBoxServerSend.Text;
Socket centerClient = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
IPEndPoint GsServer = new IPEndPoint(IPAddress.Parse("127.0.0.1"), 9001);
centerClient.Connect(GsServer);
centerClient.Send(Encoding.ASCII.GetBytes(ss));
centerClient.Send(Encoding.ASCII.GetBytes(ss));
//Thread.Sleep(100);
//centerClient.Close();
}
private void Server_Load(object sender, EventArgs e)
{
vsServerThread = new Thread(new ThreadStart(ServerStart));
vsServerThread.Start();
}
//窗体关闭时杀死客户端进程
private void Server_FormClosing(object sender, FormClosingEventArgs e)
{
KillProcess();
}
//杀死客户端进程
private void KillProcess()
{
Process[] processes = Process.GetProcessesByName("Server");
foreach (Process process in processes)
{
process.Kill();
break;
}
}
}
}
效果如下：
客户端可以发送消息给服务端，服务端也可以发送消息给客户端。
缺点：
现在服务端只能连接一个客户端
