C#网络编程之Socket编程

第C#网络编程之Socket编程byte[]buffer=newbyte[1]{2};

dicSocket[cmb_Socket.SelectedItem.ToString()].Send(buffer);

///summary

///停止监听

////summary

///paramname="sender"/param

///paramname="e"/param

privatevoidbtn_StopListen_Click(objectsender,EventArgse)

socketWatch.Close();

socketSend.Close();

//终止线程

AcceptSocketThread.Abort();

threadReceive.Abort();

}

客户端界面

代码实现如下：

usingSystem;

usingSystem.Collections.Generic;

usingSystem.ComponentModel;

usingSystem.Data;

usingSystem.Drawing;

usingSystem.Linq;

usingSystem.Text;

usingSystem.Threading.Tasks;

usingSystem.Windows.Forms;

usingSystem.Net.Sockets;

usingSystem.Net;

usingSystem.Threading;

usingSystem.IO;

namespaceSocketClient

publicpartialclassFrmClient:Form

publicFrmClient()

InitializeComponent();

//定义回调

privatedelegatevoidSetTextCallBack(stringstrValue);

//声明

privateSetTextCallBacksetCallBack;

//定义接收服务端发送消息的回调

privatedelegatevoidReceiveMsgCallBack(stringstrMsg);

//声明

privateReceiveMsgCallBackreceiveCallBack;

//创建连接的Socket

SocketsocketSend;

//创建接收客户端发送消息的线程

ThreadthreadReceive;

///summary

///连接

////summary

///paramname="sender"/param

///paramname="e"/param

privatevoidbtn_Connect_Click(objectsender,EventArgse)

socketSend=newSocket(AddressFamily.InterNetwork,SocketType.Stream,ProtocolType.Tcp);

IPAddressip=IPAddress.Parse(this.txt_IP.Text.Trim());

socketSend.Connect(ip,Convert.ToInt32(this.txt_Port.Text.Trim()));

//实例化回调

setCallBack=newSetTextCallBack(SetValue);

receiveCallBack=newReceiveMsgCallBack(SetValue);

this.txt_Log.Invoke(setCallBack,"连接成功");

//开启一个新的线程不停的接收服务器发送消息的线程

threadReceive=newThread(newThreadStart(Receive));

//设置为后台线程

threadReceive.IsBackground=true;

threadReceive.Start();

catch(Exceptionex)

MessageBox.Show("连接服务端出错:"+ex.ToString());

///summary

///接口服务器发送的消息

////summary

privatevoidReceive()

while(true)

byte[]buffer=newbyte[2048];

//实际接收到的字节数

intr=socketSend.Receive(buffer);

if(r==0)

break;

else

//判断发送的数据的类型

if(buffer[0]==0)//表示发送的是文字消息

stringstr=Encoding.Default.GetString(buffer,1,r-1);

this.txt_Log.Invoke(receiveCallBack,"接收远程服务器:"+socketSend.RemoteEndPoint+"发送的消息:"+str);

//表示发送的是文件

if(buffer[0]==1)

SaveFileDialogsfd=newSaveFileDialog();

sfd.InitialDirectory=@"";

sfd.Title="请选择要保存的文件";

sfd.Filter="所有文件|*.*";

sfd.ShowDialog(this);

stringstrPath=sfd.FileName;

using(FileStream