最近有段時間因為有個項目一直需要Socket數(shù)據(jù)傳輸。所以呢沒辦法就整了一套Socket最簡單的版本出來。以便自己日后方便使用。
我遇到的程序Socket是通過Tcp Ip的方式進行數(shù)據(jù)傳輸?shù)?
不多說先上圖
當輸入IP跟端口之后進行連接button事件：
? ? ? ? private void Open_Click(object sender, EventArgs e)
? ? ? ? {
? ? ? ? ? ? if (IP.Text != "" && Port.Text != "")
? ? ? ? ? ? {
? ? ? ? ? ? ? ? Open.Enabled = false;
? ? ? ? ? ? ? ? Close.Enabled = true;
? ? ? ? ? ? ? ? //實例化 套接字
? ? ? ? ? ? ? ? sokClient = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
? ? ? ? ? ? ? ? //創(chuàng)建 ip對象
? ? ? ? ? ? ? ? IPAddress address = IPAddress.Parse(IP.Text.Trim());
? ? ? ? ? ? ? ? //創(chuàng)建網(wǎng)絡節(jié)點對象 包含 ip和port
? ? ? ? ? ? ? ? IPEndPoint endpoint = new IPEndPoint(address, int.Parse(Port.Text.Trim()));
? ? ? ? ? ? ? ? //連接 服務端監(jiān)聽套接字
? ? ? ? ? ? ? ? sokClient.Connect(endpoint);
? ? ? ? ? ? ? ? //創(chuàng)建負責接收 服務端發(fā)送來數(shù)據(jù)的 線程
? ? ? ? ? ? ? ? threadClient = new Thread(ReceiveMsg);
? ? ? ? ? ? ? ? threadClient.IsBackground = true;
? ? ? ? ? ? ? ? //如果在win7下要通過 某個線程 來調用 文件選擇框的代碼，就需要設置如下
? ? ? ? ? ? ? ? threadClient.SetApartmentState(ApartmentState.STA);
? ? ? ? ? ? ? ? threadClient.Start();
? ? ? ? ? ? }
? ? ? ? ? ? else
? ? ? ? ? ? {
? ? ? ? ? ? ? ? MessageBox.Show("請將端口跟IP地址填寫完整！");
? ? ? ? ? ? }
? ? ? ? }
連接上之后填寫內容點擊發(fā)送按鈕button事件如下：
? ? ? ? private void button1_Click(object sender, EventArgs e)
? ? ? ? {
? ? ? ? ? ? if (txtInput.Text != "")
? ? ? ? ? ? {
? ? ? ? ? ? ? ? string Timer = DateTime.Now.ToString(); ? ? ? ? ? ?// 2008-9-4 20:02:10
? ? ? ? ? ? ? ? txtShow.AppendText("Client " + Timer + ":" + txtInput.Text.Trim() + "rn");
? ? ? ? ? ? ? ? byte[] arrMsg = System.Text.Encoding.Default.GetBytes(txtInput.Text.Trim() + "rn");//這里可以根據(jù)客戶的需求進行格式的轉換
? ? ? ? ? ? ? ? sokClient.Send(arrMsg);
? ? ? ? ? ? }
? ? ? ? }
結束數(shù)據(jù)端的部分是使用的線程處理的方式進行監(jiān)聽。當數(shù)據(jù)過來之后進行數(shù)據(jù)處理為：
? ? ? ? void ReceiveMsg()
? ? ? ? {
? ? ? ? ? ? ? ? while (isRec)
? ? ? ? ? ? ? ? {
? ? ? ? ? ? ? ? ? ? byte[] msgArr = new byte[1024 * 1024 * 1];//接收到的消息的緩沖區(qū)
? ? ? ? ? ? ? ? ? ? int length = 0;
? ? ? ? ? ? ? ? ? ? //接收服務端發(fā)送來的消息數(shù)據(jù)
? ? ? ? ? ? ? ? ? ? try
? ? ? ? ? ? ? ? ? ? {
? ? ? ? ? ? ? ? ? ? ? ? length = sokClient.Receive(msgArr);//Receive會阻斷線程
? ? ? ? ? ? ? ? ? ? ? ? string strMsg = System.Text.Encoding.Default.GetString(msgArr, 0, length);//這里可以根據(jù)客戶的需求進行格式的轉換
? ? ? ? ? ? ? ? ? ? ? ? if (strMsg != "")//發(fā)送來的是文字
? ? ? ? ? ? ? ? ? ? ? ? {
? ? ? ? ? ? ? ? ? ? ? ? ? ? string Timer = DateTime.Now.ToString(); ? ? ? ? ? ?// 2008-9-4 20:02:10
? ? ? ? ? ? ? ? ? ? ? ? ? ? // string strMsg = System.Text.Encoding.UTF8.GetString(msgArr, 1, length - 1);
? ? ? ? ? ? ? ? ? ? ? ? ? ? Invoke(new Action(delegate { txtShow.AppendText("Server " + Timer + ":" + strMsg + "rn"); }));
? ? ? ? ? ? ? ? ? ? ? ? }
? ? ? ? ? ? ? ? ? ? }
? ? ? ? ? ? ? ? ? ? catch { }
? ? ? ? ? ? ? ? }
? ? ? ? }
大體的主要代碼就是這樣了，好了。將所有的代碼都貼一下方便大家使用：
using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Linq;
using System.Net;
using System.Net.Sockets;
using System.Text;
using System.Threading;
using System.Threading.Tasks;
using System.Windows.Forms;
namespace Socket_Client
{
? ? public partial class Form1 : Form
? ? {
? ? ? ? Socket sokClient = null;//負責與服務端通信的套接字
? ? ? ? Thread threadClient = null;//負責 監(jiān)聽 服務端發(fā)送來的消息的線程
? ? ? ? bool isRec = true;//是否循環(huán)接收服務端數(shù)據(jù)
? ? ? ? void ReceiveMsg()
? ? ? ? {
? ? ? ? ? ? ? ? while (isRec)
? ? ? ? ? ? ? ? {
? ? ? ? ? ? ? ? ? ? byte[] msgArr = new byte[1024 * 1024 * 1];//接收到的消息的緩沖區(qū)
? ? ? ? ? ? ? ? ? ? int length = 0;
? ? ? ? ? ? ? ? ? ? //接收服務端發(fā)送來的消息數(shù)據(jù)
? ? ? ? ? ? ? ? ? ? try
? ? ? ? ? ? ? ? ? ? {
? ? ? ? ? ? ? ? ? ? ? ? length = sokClient.Receive(msgArr);//Receive會阻斷線程
? ? ? ? ? ? ? ? ? ? ? ? string strMsg = System.Text.Encoding.Default.GetString(msgArr, 0, length);
? ? ? ? ? ? ? ? ? ? ? ? if (strMsg != "")//發(fā)送來的是文字
? ? ? ? ? ? ? ? ? ? ? ? {
? ? ? ? ? ? ? ? ? ? ? ? ? ? string Timer = DateTime.Now.ToString(); ? ? ? ? ? ?// 2008-9-4 20:02:10
? ? ? ? ? ? ? ? ? ? ? ? ? ? // string strMsg = System.Text.Encoding.UTF8.GetString(msgArr, 1, length - 1);
? ? ? ? ? ? ? ? ? ? ? ? ? ? Invoke(new Action(delegate { txtShow.AppendText("Server " + Timer + ":" + strMsg + "rn"); }));
? ? ? ? ? ? ? ? ? ? ? ? }
? ? ? ? ? ? ? ? ? ? }
? ? ? ? ? ? ? ? ? ? catch { }
? ? ? ? ? ? ? ? }
? ? ? ? }
? ? ? ? public Form1()
? ? ? ? {
? ? ? ? ? ? InitializeComponent();
? ? ? ? }
? ? ? ? private void Open_Click(object sender, EventArgs e)
? ? ? ? {
? ? ? ? ? ? if (IP.Text != "" && Port.Text != "")
? ? ? ? ? ? {
? ? ? ? ? ? ? ? Open.Enabled = false;
? ? ? ? ? ? ? ? Close.Enabled = true;
? ? ? ? ? ? ? ? //實例化 套接字
? ? ? ? ? ? ? ? sokClient = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
? ? ? ? ? ? ? ? //創(chuàng)建 ip對象
? ? ? ? ? ? ? ? IPAddress address = IPAddress.Parse(IP.Text.Trim());
? ? ? ? ? ? ? ? //創(chuàng)建網(wǎng)絡節(jié)點對象 包含 ip和port
? ? ? ? ? ? ? ? IPEndPoint endpoint = new IPEndPoint(address, int.Parse(Port.Text.Trim()));
? ? ? ? ? ? ? ? //連接 服務端監(jiān)聽套接字
? ? ? ? ? ? ? ? sokClient.Connect(endpoint);
? ? ? ? ? ? ? ? //創(chuàng)建負責接收 服務端發(fā)送來數(shù)據(jù)的 線程
? ? ? ? ? ? ? ? threadClient = new Thread(ReceiveMsg);
? ? ? ? ? ? ? ? threadClient.IsBackground = true;
? ? ? ? ? ? ? ? //如果在win7下要通過 某個線程 來調用 文件選擇框的代碼，就需要設置如下
? ? ? ? ? ? ? ? threadClient.SetApartmentState(ApartmentState.STA);
? ? ? ? ? ? ? ? threadClient.Start();
? ? ? ? ? ? }
? ? ? ? ? ? else
? ? ? ? ? ? {
? ? ? ? ? ? ? ? MessageBox.Show("請將端口跟IP地址填寫完整！");
? ? ? ? ? ? }
? ? ? ? }
? ? ? ? private void Close_Click(object sender, EventArgs e)
? ? ? ? {
? ? ? ? ? ? Open.Enabled = true;
? ? ? ? ? ? Close.Enabled = false;
? ? ? ? ? ? sokClient.Close();
? ? ? ? }
? ? ? ? private void button1_Click(object sender, EventArgs e)
? ? ? ? {
? ? ? ? ? ? if (txtInput.Text != "")
? ? ? ? ? ? {
? ? ? ? ? ? ? ? string Timer = DateTime.Now.ToString(); ? ? ? ? ? ?// 2008-9-4 20:02:10
? ? ? ? ? ? ? ? txtShow.AppendText("Client " + Timer + ":" + txtInput.Text.Trim() + "rn");
? ? ? ? ? ? ? ? byte[] arrMsg = System.Text.Encoding.Default.GetBytes(txtInput.Text.Trim() + "rn");
? ? ? ? ? ? ? ? sokClient.Send(arrMsg);
? ? ? ? ? ? }
? ? ? ? }
? ? ? ? private void Form1_Load(object sender, EventArgs e)
? ? ? ? {
? ? ? ? ? ? Close.Enabled = false;
? ? ? ? }
? ? }
}
運行結果如下：
下載文檔
