C# Socket Clinet编写
扫描二维码
随时随地手机看文章
最近有段时间因为有个项目一直需要Socket数据传输。所以呢没办法就整了一套Socket最简单的版本出来。以便自己日后方便使用。
我遇到的程序Socket是通过Tcp Ip的方式进行数据传输的.
不多说先上图
当输入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);
//创建 ip对象
IPAddress address = IPAddress.Parse(IP.Text.Trim());
//创建网络节点对象 包含 ip和port
IPEndPoint endpoint = new IPEndPoint(address, int.Parse(Port.Text.Trim()));
//连接 服务端监听套接字
sokClient.Connect(endpoint);
//创建负责接收 服务端发送来数据的 线程
threadClient = new Thread(ReceiveMsg);
threadClient.IsBackground = true;
//如果在win7下要通过 某个线程 来调用 文件选择框的代码，就需要设置如下
threadClient.SetApartmentState(ApartmentState.STA);
threadClient.Start();
}
else
{
MessageBox.Show("请将端口跟IP地址填写完整！");
}
}
连接上之后填写内容点击发送按钮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");//这里可以根据客户的需求进行格式的转换
sokClient.Send(arrMsg);
}
}
结束数据端的部分是使用的线程处理的方式进行监听。当数据过来之后进行数据处理为：
void ReceiveMsg()
{
while (isRec)
{
byte[] msgArr = new byte[1024 * 1024 * 1];//接收到的消息的缓冲区
int length = 0;
//接收服务端发送来的消息数据
try
{
length = sokClient.Receive(msgArr);//Receive会阻断线程
string strMsg = System.Text.Encoding.Default.GetString(msgArr, 0, length);//这里可以根据客户的需求进行格式的转换
if (strMsg != "")//发送来的是文字
{
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;//负责 监听 服务端发送来的消息的线程
bool isRec = true;//是否循环接收服务端数据
void ReceiveMsg()
{
while (isRec)
{
byte[] msgArr = new byte[1024 * 1024 * 1];//接收到的消息的缓冲区
int length = 0;
//接收服务端发送来的消息数据
try
{
length = sokClient.Receive(msgArr);//Receive会阻断线程
string strMsg = System.Text.Encoding.Default.GetString(msgArr, 0, length);
if (strMsg != "")//发送来的是文字
{
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);
//创建 ip对象
IPAddress address = IPAddress.Parse(IP.Text.Trim());
//创建网络节点对象 包含 ip和port
IPEndPoint endpoint = new IPEndPoint(address, int.Parse(Port.Text.Trim()));
//连接 服务端监听套接字
sokClient.Connect(endpoint);
//创建负责接收 服务端发送来数据的 线程
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;
}
}
}
运行结果如下：
下载文档
