C#基于Sockets類(lèi)實(shí)現(xiàn)TCP通訊

更新時(shí)間：2022年01月31日 12:34:12 作者：迎迎一笑

這篇文章主要為大家詳細(xì)介紹了C#基于Sockets類(lèi)實(shí)現(xiàn)TCP通訊，文中示例代碼介紹的非常詳細(xì)，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下

本文實(shí)例為大家分享了C#基于Sockets類(lèi)實(shí)現(xiàn)TCP通訊的具體代碼，供大家參考，具體內(nèi)容如下

最終效果

TCPClient

using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Windows.Forms;
using System.Net;
using System.Net.Sockets;
using System.Threading;

namespace TCPClient02
{
? ? public partial class Form1 : Form
? ? {
? ? ? ? public Form1()
? ? ? ? {
? ? ? ? ? ? InitializeComponent();
? ? ? ? }
? ? ? ? Socket socketSend;
? ? ? ? private void button1_Click(object sender, EventArgs e)
? ? ? ? {
? ? ? ? ? ? //Create socket
? ? ? ? ? ? socketSend = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
? ? ? ? ? ? IPAddress ip = IPAddress.Parse(textBox1.Text);
? ? ? ? ? ? IPEndPoint point = new IPEndPoint(ip, Convert.ToInt32(textBox2.Text));
? ? ? ? ? ? IDInfo idinfo = new IDInfo(); ?//Read ID number information
? ? ? ? ? ? //Get the IP address and port number of the remote server
? ? ? ? ? ? socketSend.Connect(point);
? ? ? ? ? ? ShowMessages("Connection succeeded");

? ? ? ? ? ? //Start a new thread and keep receiving messages sent by the server
? ? ? ? ? ? Thread th = new Thread(ReciveMessages);
? ? ? ? ? ? th.IsBackground = true;
? ? ? ? ? ? th.Start();
? ? ? ? }

? ? ? ? private void button2_Click(object sender, EventArgs e)
? ? ? ? {
? ? ? ? ? ? string str = textBox3.Text.Trim();
? ? ? ? ? ? byte[] buffer = System.Text.Encoding.UTF8.GetBytes(str);
? ? ? ? ? ? socketSend.Send(buffer);
? ? ? ? }


? ? ? ? void ShowMessages(string str)
? ? ? ? {
? ? ? ? ? ? textBox4.AppendText(str + "\r\n");
? ? ? ? }
? ? ? ? void ReciveMessages()
? ? ? ? {
? ? ? ? ? ? while (true)
? ? ? ? ? ? {
? ? ? ? ? ? ? ? byte[] buffer = new byte[1024 * 1024 * 3];
? ? ? ? ? ? ? ? int r = socketSend.Receive(buffer);
? ? ? ? ? ? ? ? if (r == 0)
? ? ? ? ? ? ? ? {
? ? ? ? ? ? ? ? ? ? break;
? ? ? ? ? ? ? ? }
? ? ? ? ? ? ? ? string s = Encoding.UTF8.GetString(buffer, 0, r);
? ? ? ? ? ? ? ? ShowMessages(socketSend.RemoteEndPoint + ":" + s);
? ? ? ? ? ? }
? ? ? ? }

? ? ? ? private void Form1_Load(object sender, EventArgs e)
? ? ? ? {
? ? ? ? ? ? Control.CheckForIllegalCrossThreadCalls = false;
? ? ? ? }
? ? }
}

TCPserver

using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Windows.Forms;
using System.Net.Sockets;
using System.Net;
using System.Threading;

namespace TCPserver
{
? ? public partial class Form1 : Form
? ? {
? ? ? ? public Form1()
? ? ? ? {
? ? ? ? ? ? InitializeComponent();
? ? ? ? }

? ? ? ? private void button1_Click(object sender, EventArgs e)
? ? ? ? {
? ? ? ? ? ? try
? ? ? ? ? ? {
? ? ? ? ? ? ? ? //創(chuàng)建一個(gè)負(fù)責(zé)監(jiān)聽(tīng)的Socket
? ? ? ? ? ? ? ? Socket socketWatch = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
? ? ? ? ? ? ? ? //創(chuàng)建ip地址和端口號(hào)
? ? ? ? ? ? ? ? //IPAddress ip = IPAddress.Parse(textBox1.Text);
? ? ? ? ? ? ? ? IPAddress ip = IPAddress.Any;
? ? ? ? ? ? ? ? IPEndPoint point = new IPEndPoint(ip, Convert.ToInt32(textBox2.Text));
? ? ? ? ? ? ? ? //讓負(fù)責(zé)監(jiān)聽(tīng)的socket綁定ip地址和端口號(hào)
? ? ? ? ? ? ? ? socketWatch.Bind(point);

? ? ? ? ? ? ? ? ShowMsg("監(jiān)聽(tīng)成功");
? ? ? ? ? ? ? ? //設(shè)置監(jiān)聽(tīng)隊(duì)列（某一時(shí)刻連接客戶(hù)端的最大數(shù)目）
? ? ? ? ? ? ? ? socketWatch.Listen(10);

? ? ? ? ? ? ? ? //線(xiàn)程執(zhí)行的方法
? ? ? ? ? ? ? ? Thread th = new Thread(Listen); ? //服務(wù)器開(kāi)始監(jiān)聽(tīng)
? ? ? ? ? ? ? ? th.IsBackground = true;
? ? ? ? ? ? ? ? th.Start(socketWatch);

? ? ? ? ? ? }
? ? ? ? ? ? catch
? ? ? ? ? ? {

? ? ? ? ? ? }


? ? ? ? }

? ? ? ? void ShowMsg(string str)
? ? ? ? {
? ? ? ? ? ? textBox3.AppendText(str + "\r\n");

? ? ? ? }

? ? ? ? /// <summary>
? ? ? ? /// 等待客戶(hù)端的連接 并且創(chuàng)建與之通信的Socket
? ? ? ? /// </summary>
? ? ? ? ///?
? ? ? ? Socket socketSend;
? ? ? ? void Listen(object o)
? ? ? ? {
? ? ? ? ? ? Socket socketWatch = o as Socket;
? ? ? ? ? ? //負(fù)責(zé)監(jiān)聽(tīng)的socket 來(lái)接收客戶(hù)端的連接 ?
? ? ? ? ? ? //創(chuàng)建跟客戶(hù)端通信的socket

? ? ? ? ? ? while (true)
? ? ? ? ? ? {
? ? ? ? ? ? ? ? try
? ? ? ? ? ? ? ? {
? ? ? ? ? ? ? ? ? ? socketSend = socketWatch.Accept();
? ? ? ? ? ? ? ? ? ? ShowMsg(socketSend.RemoteEndPoint.ToString() + "連接成功");
? ? ? ? ? ? ? ? ? ? //開(kāi)始一個(gè)新的線(xiàn)程不斷接受客戶(hù)端發(fā)送過(guò)來(lái)的消息
? ? ? ? ? ? ? ? ? ? Thread th = new Thread(Recive);
? ? ? ? ? ? ? ? ? ? th.IsBackground = true;
? ? ? ? ? ? ? ? ? ? th.Start(socketSend);
? ? ? ? ? ? ? ? }
? ? ? ? ? ? ? ? catch
? ? ? ? ? ? ? ? {

? ? ? ? ? ? ? ? }


? ? ? ? ? ? }

? ? ? ? }
? ? ? ? /// <summary>
? ? ? ? /// 服務(wù)器不斷接受客戶(hù)端發(fā)送過(guò)來(lái)的消息
? ? ? ? /// </summary>
? ? ? ? /// <param name="o"></param>
? ? ? ? void Recive(object o)
? ? ? ? {
? ? ? ? ? ??

? ? ? ? ? ? Socket socketSend = o as Socket;
? ? ? ? ? ? while (true)
? ? ? ? ? ? {
? ? ? ? ? ? ? ?try
? ? ? ? ? ? ? ? {
? ? ? ? ? ? ? ? ? ? //客戶(hù)端連接成功后，服務(wù)器應(yīng)該接收客戶(hù)端發(fā)來(lái)的消息
? ? ? ? ? ? ? ? ? ? byte[] buffer = new byte[1024 * 1024 * 2];
? ? ? ? ? ? ? ? ? ? //實(shí)際接收到的有效字節(jié)數(shù)
? ? ? ? ? ? ? ? ? ? int bytelen = socketSend.Receive(buffer);
? ? ? ? ? ? ? ? ? ? if (bytelen == 0)
? ? ? ? ? ? ? ? ? ? {
? ? ? ? ? ? ? ? ? ? ? ? break;

? ? ? ? ? ? ? ? ? ? }
? ? ? ? ? ? ? ? ? ? string str = Encoding.UTF8.GetString(buffer, 0, bytelen);
? ? ? ? ? ? ? ? ? ? ShowMsg(socketSend.RemoteEndPoint + ":" + str);
? ? ? ? ? ? ? ? }
? ? ? ? ? ? ? ? catch
? ? ? ? ? ? ? ? { ?}
? ? ? ? ? ? ? ??
? ? ? ? ? ? ? ??

? ? ? ? ? ? }

? ? ? ? }


? ? ? ? private void textBox1_TextChanged(object sender, EventArgs e)
? ? ? ? {

? ? ? ? }

? ? ? ? private void Form1_Load(object sender, EventArgs e)
? ? ? ? {
? ? ? ? ? ? Control.CheckForIllegalCrossThreadCalls = false;
? ? ? ? }

? ? ? ?/// <summary>
? ? ? ?/// 服務(wù)器給客戶(hù)端發(fā)送消息
? ? ? ?/// </summary>
? ? ? ?/// <param name="sender"></param>
? ? ? ?/// <param name="e"></param>
? ? ? ? private void button3_Click(object sender, EventArgs e)
? ? ? ? {
? ? ? ? ? ? string str = textBox4.Text;
? ? ? ? ? ? byte[] buffer = System.Text.Encoding.UTF8.GetBytes(str);
? ? ? ? ? ? socketSend.Send(buffer);

? ? ? ? }
? ? }
}

以上就是本文的全部?jī)?nèi)容，希望對(duì)大家的學(xué)習(xí)有所幫助，也希望大家多多支持腳本之家。

您可能感興趣的文章: