C#實(shí)現(xiàn)套接字發(fā)送接收數(shù)據(jù)
更新時(shí)間：2021年11月25日 15:19:40 作者：普通還不自信的程序員
這篇文章主要為大家詳細(xì)介紹了C#實(shí)現(xiàn)套接字發(fā)送接收數(shù)據(jù)，文中示例代碼介紹的非常詳細(xì)，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下
本文實(shí)例為大家分享了C#實(shí)現(xiàn)套接字發(fā)送接收數(shù)據(jù)的具體代碼，供大家參考，具體內(nèi)容如下
服務(wù)端
namespace TestServer
{
public partial class ServerForm : Form
{
Socket socketSend;
// 將遠(yuǎn)程連接的客戶端的IP地址和socket存入集合
Dictionary<string, Socket> dicSocket = new Dictionary<string, Socket>();
public ServerForm()
{
InitializeComponent();
}
private void btnStart_Click(object sender, EventArgs e)
{
try
{
// 當(dāng)點(diǎn)擊開(kāi)始監(jiān)聽(tīng)后，在服務(wù)器創(chuàng)建一個(gè)負(fù)責(zé)監(jiān)聽(tīng)I(yíng)P地址和端口號(hào)的socket
Socket socketWatch = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
IPAddress ip = IPAddress.Any;//;IPAddress.Parse(txtServer.Text)
IPEndPoint point = new IPEndPoint(ip, Convert.ToInt32(txtPort.Text));
// 監(jiān)聽(tīng)
socketWatch.Bind(point);
ShowMsg("監(jiān)聽(tīng)成功");
socketWatch.Listen(10);
Thread th = new Thread(Listen);
th.IsBackground = true;
th.Start(socketWatch);
}
catch { }
}
void Listen(object o)
{
// 等待客戶端連接 并創(chuàng)建一個(gè)負(fù)責(zé)通信的Socket
Socket socketWatch = o as Socket;
while (true)
{
socketSend = socketWatch.Accept();
dicSocket.Add(socketSend.RemoteEndPoint.ToString(),socketSend);
cboUsers.Items.Add(socketSend.RemoteEndPoint.ToString());
ShowMsg(socketSend.RemoteEndPoint.ToString() + " : " + "連接成功");
Thread th = new Thread(Recive);
th.IsBackground = true;
th.Start(socketSend);
}
}
void Recive(object o)
{
socketSend = o as Socket;
while (true)
{
// 客戶端連接成功后，服務(wù)器應(yīng)接受客戶端發(fā)來(lái)的消息
byte[] buffer = new byte[1024 * 1024 * 2];
// 實(shí)際接收到的有效字節(jié)數(shù)
int r = socketSend.Receive(buffer);
if (r == 0)
{
break;
}
string str = Encoding.UTF8.GetString(buffer, 0, r);
ShowMsg(socketSend.RemoteEndPoint + " : " + str);
}
}
void ShowMsg(string str)
{
txtLog.AppendText(str + "\r\n");
}
private void Form1_Load(object sender, EventArgs e)
{
Control.CheckForIllegalCrossThreadCalls = false;
}
private void btnSend_Click(object sender, EventArgs e)
{
string str = txtMsg.Text;
byte[] buffer = Encoding.UTF8.GetBytes(str);
string ip = cboUsers.SelectedItem.ToString();
dicSocket[ip].Send(buffer);
//socketSend.Send(buffer);
txtMsg.Text = "";
}
private void btnSendUser_Click(object sender, EventArgs e)
{
string json = JsonConvert.SerializeObject(UserList());
byte[] buffer = Encoding.UTF8.GetBytes(json);
socketSend.Send(buffer);
}
private List<User> UserList()
{
List<User> userList = new List<User>();
User user = null;
string sql = "select * from user_table";
SqlCommand cmd = SqlUtils.ConnectSql(sql);
SqlDataReader sdr = cmd.ExecuteReader();
while (sdr.Read())
{
user = new User(sdr.GetInt32(0), sdr.GetString(1), sdr.GetString(2), sdr.GetInt32(3));
userList.Add(user);
}
return userList;
}
}
}
客戶端
namespace TestClient
{
public partial class ClientForm : Form
{
Socket socketSend;
public ClientForm()
{
InitializeComponent();
}
private void btnStart_Click(object sender, EventArgs e)
{
try
{
// 創(chuàng)建負(fù)責(zé)通信的socket
socketSend = new Socket(AddressFamily.InterNetwork,SocketType.Stream,ProtocolType.Tcp);
IPAddress ip = IPAddress.Parse(txtServer.Text);
IPEndPoint point = new IPEndPoint(ip,Convert.ToInt32(txtPort.Text));
socketSend.Connect(point);
ShowMsg("連接成功");
Thread th = new Thread(Recive);
th.IsBackground = true;
th.Start();
}
catch { }
}
void Recive()
{
while (true)
{
// 客戶端連接成功后，服務(wù)器應(yīng)接受客戶端發(fā)來(lái)的消息
byte[] buffer = new byte[1024 * 1024 * 2];
// 實(shí)際接收到的有效字節(jié)數(shù)
int r = socketSend.Receive(buffer);
if (r == 0)
{
break;
}
string str = Encoding.UTF8.GetString(buffer, 0, r);
ShowMsg(socketSend.RemoteEndPoint + " : " + str);
}
}
void ShowMsg(string str)
{
txtLog.AppendText(str + "\r\n");
}
private void Form1_Load(object sender, EventArgs e)
{
Control.CheckForIllegalCrossThreadCalls = false;
}
private void btnSend_Click(object sender, EventArgs e)
{
string str = txtMsg.Text.Trim();
byte[] buffer = Encoding.UTF8.GetBytes(str);
socketSend.Send(buffer);
txtMsg.Text = "";
}
}
}
效果
發(fā)送json數(shù)據(jù)
以上就是本文的全部?jī)?nèi)容，希望對(duì)大家的學(xué)習(xí)有所幫助，也希望大家多多支持腳本之家。
相關(guān)文章
用?FieldMask?提高?C#?gRpc?的服務(wù)性能
這篇文章主要介紹了用?FieldMask?提高?C#?gRpc?的服務(wù)性能,FieldMask?是一個(gè)?protobuf?消息，包含一個(gè)名為?paths?的字段，用于指定用于指定讀取操作返回或更新操作修改的字,下文詳細(xì)內(nèi)容,需要的朋友可以參考一下2022-03-03
這篇文章介紹了C#多線程的資源池限制，文中通過(guò)示例代碼介紹的非常詳細(xì)。對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值，需要的朋友可以參考下2022-02-02
在本篇文章中小編給大家分享了關(guān)于C# winform程序讀取文本中的值的相關(guān)知識(shí)點(diǎn)，有興趣的朋友們學(xué)習(xí)下。2019-06-06
Unity是一個(gè)Component-Based的引擎，所有物體都是GameObject。本文將詳細(xì)介紹GameObject和MonoBehaviour，感興趣的同學(xué)，可以參考下。2021-05-05
輕松學(xué)習(xí)C#的讀寫(xiě)操作，小編也是第一次接觸C#的讀寫(xiě)操作，感興趣的小伙伴們可以參考一下，大家一起學(xué)習(xí)2015-11-11
這篇文章介紹了C#實(shí)現(xiàn)工廠模式的方法，文中通過(guò)示例代碼介紹的非常詳細(xì)。對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值，需要的朋友可以參考下2022-07-07
C#實(shí)現(xiàn)對(duì)二維數(shù)組排序的方法
這篇文章主要介紹了C#實(shí)現(xiàn)對(duì)二維數(shù)組排序的方法,實(shí)例分析了C#數(shù)組遍歷與排序的相關(guān)技巧,需要的朋友可以參考下2015-06-06
這篇文章主要介紹了C#接口(Interface)用法,較為詳細(xì)的分析了C#中接口的功能、實(shí)現(xiàn)及使用技巧,具有一定參考借鑒價(jià)值,需要的朋友可以參考下2021-07-07
C#實(shí)現(xiàn)Base64處理的加密解密,編碼解碼示例
這篇文章主要介紹了C#實(shí)現(xiàn)Base64處理的加密解密,編碼解碼,結(jié)合實(shí)例形式分析了基于C#實(shí)現(xiàn)的base64編碼解碼操作相關(guān)技巧,需要的朋友可以參考下2017-01-01
C#實(shí)現(xiàn)json的序列化和反序列化實(shí)例代碼
這篇文章主要介紹了C#實(shí)現(xiàn)json的序列化和反序列化實(shí)例代碼，有需要的朋友可以參考一下2013-12-12