关于socket用winform实现简单通信 大牛可绕道 初学者可以看看 我做的时候把客户端窗口隐藏了 大家可以自己改一下
2017-02-19 16:58
756 查看
服务器端
using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.IO;
using System.Net;
using System.Net.Sockets;
using System.Text;
using System.Threading;
using System.Windows.Forms;
namespace TcpFrmServer
{
public partial class Form1 : Form
{
List<Socket> ProxSocketList = new List<Socket>();
public Form1()
{
InitializeComponent();
}
//public object Threadpool { get; private set; }
private void btnStart_Click(object sender, EventArgs e)
{
}
public void Connect(object socket)
{
var serverSocket = socket as Socket;
this.TextToLog("服务器端开始接受消息");
while (true)
{
var proxSocket = serverSocket.Accept();
this.TextToLog(string.Format("客户端:{0}链接到位", proxSocket.RemoteEndPoint.ToString()));
ProxSocketList.Add(proxSocket);
ThreadPool.QueueUserWorkItem(new WaitCallback(Data), proxSocket);
}
}
public void Data(object socket)
{
var proxSocket = socket as Socket;
byte[] b = new byte[1024 * 1024];
int i = 0;
while (true)
{
try
{
i = proxSocket.Receive
(b, 0, b.Length, SocketFlags.None);
}
catch (Exception ex)
{
TextToLog
(string.Format("接收到客户端：{0}错误", proxSocket.RemoteEndPoint.ToString()));
ProxSocketList.Remove(proxSocket);
Connetct(proxSocket); //
return;
}
if (i <= 0)
{
TextToLog
(string.Format("接收到客户端：{0}正常", proxSocket.RemoteEndPoint.ToString()));
ProxSocketList.Remove(proxSocket);
Connect(proxSocket);
return;
}
string str = Encoding.Default.GetString(b, 0, i);
TextToLog
(string.Format("接收到客户端：{0}的消息:{1}", proxSocket.RemoteEndPoint.ToString(), str));
}
}
private void Connetct(Socket proxSocket)
{
try
{
if (proxSocket.Connected)
{
proxSocket.Shutdown(SocketShutdown.Both);
proxSocket.Close(100);
}
}
catch (Exception ex)
{
}
}
public void TextToLog(string txt)
{
if (txtLog.InvokeRequired)
{
txtLog.BeginInvoke(new Action<string>(s =>
{
this.txtLog.Text = string.Format("{0}\r\n{1}", s, txtLog.Text);
}), txt);
}
else
{
this.txtLog.Text = string.Format("{0}\r\n{1}", txt, txtLog.Text);
}
}
/// <summary>
/// 发送
/// </summary>
/// <param name="sender"></param>
/// <param name="e"></param>
private void btnSendMsg_Click(object sender, EventArgs e)
{
foreach (var proxSocket in ProxSocketList)
{
if (proxSocket.Connected)
{
byte[] data = Encoding.Default.GetBytes(txtMsg.Text);
byte[] result = new byte[data.Length + 1];
result[0] = 1;
Buffer.BlockCopy(data, 0, result, 1, data.Length);
proxSocket.Send(data, 0, data.Length, SocketFlags.None);
}
}
}
private void Form1_Load(object sender, EventArgs e)
{
Socket socket = new Socket
(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
socket.Bind(new IPEndPoint(IPAddress.Parse("地址"),65530));
socket.Listen(10);
ThreadPool.QueueUserWorkItem(new WaitCallback(this.Connect), socket);
}
private void btnSendFile_Click(object sender, EventArgs e)
{
using (OpenFileDialog ofd = new OpenFileDialog())
{
if (ofd.ShowDialog() != DialogResult.OK)
{
return;
}
byte[] data = File.ReadAllBytes(ofd.FileName);
byte[] result = new byte[data.Length + 1];
result[0] = 3;
Buffer.BlockCopy(data, 0, result, 1, data.Length);
foreach (var proxSocket in ProxSocketList)
{
if (!proxSocket.Connected)
{
continue;
}
proxSocket.Send(result, SocketFlags.None);
}
}
}
private void button1_Click(object sender, EventArgs e)
{
foreach (var proxSocket in ProxSocketList)
{
if (!proxSocket.Connected)
{
proxSocket.Send(new byte[] { 2 }, SocketFlags.None);
}
}
}
}
}
客户端------------------------------------------------------------------------------------------------------------------------------------------------
4000
------------------------------------------------------------------------------
using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.IO;
using System.Net;
using System.Net.Sockets;
using System.Text;
using System.Threading;
using System.Windows.Forms;
namespace TcpFrmClient
{
public partial class Form1 : Form
{
public Socket sockets { get; set; }
public Form1()
{
InitializeComponent();
Control.CheckForIllegalCrossThreadCalls = false;
}
private void btnConncet_Click(object sender, EventArgs e)
{
}
public void Data(object socket)
{
var proxSocket = socket as Socket;
byte[] data = new byte[1024 * 1024];
int n = 0;
while (true)
{
try
{
n = proxSocket.Receive
(data, 0, data.Length, SocketFlags.None);
}
catch (Exception ex)
{
// TextToLog
//(string.Format("接收到服务器：{0}错误", proxSocket.RemoteEndPoint.ToString()));
Contnet();
return;
}
if (n <= 0)
{
// TextToLog
//(string.Format("接收到服务器端：{0}正常", proxSocket.RemoteEndPoint.ToString()));
Contnet(); //
return;
}
if (data[0] == 1)
{
string strMsg = RecieveString(data);
// TextToLog
//(string.Format("接收到客户端：{0}的消息:{1}", proxSocket.RemoteEndPoint.ToString(), strMsg));
}
else if (data[0]==2)
{
break;
}
else if (data[0] == 3)
{
RecieveFile(data,n);
}
// string str = Encoding.Default.GetString(data);
// TextToLog
//(string.Format("接收到客户端：{0}的消息:{1}", proxSocket.RemoteEndPoint.ToString(), str));
}
}
public void RecieveFile(byte[] data,int n)
{
using (SaveFileDialog sfd =new SaveFileDialog())
{
//try
//{
if (sfd.ShowDialog(this) != DialogResult.OK)
{
return;
}
byte[] fileData = new byte[n - 1];
Buffer.BlockCopy(data, 1, fileData, 0, n - 1);
File.WriteAllBytes(sfd.FileName, fileData);
//}
//catch (Exception ex)
//{
// // MessageBox.Show(".......");
//}
}
}
public string RecieveString(byte[] datas)
{
string str = Encoding.Default.GetString(datas, 1, datas.Length - 1);
return str;
}
private void Contnet()
{
try
{
if (sockets.Connected)
{
sockets.Shutdown(SocketShutdown.Both);
sockets.Close(100);
}
}
catch (Exception ex)
{
}
}
public void TextToLog(string txt)
{
if (txtLog.InvokeRequired)
{
txtLog.BeginInvoke(new Action<string>(s =>
{
this.txtLog.Text = string.Format("{0}\r\n{1}", s, txtLog.Text);
}), txt);
//txtLog.Invoke(new Action<string>(s =>
//{
// this.txtLog.Text = string.Format("{0}\r\n{1}", s, txtLog.Text);
//}), txt);
}
else
{
this.txtLog.Text = string.Format("{0}\r\n{1}", txt, txtLog.Text);
}
}
private void btnSendMsg_Click(object sender, EventArgs e)
{
if (sockets.Connected)
{
byte[] data = Encoding.Default.GetBytes(txtMsg.Text);
sockets.Send(data, 0, data.Length, SocketFlags.None);
}
}
private void Form1_Load(object sender, EventArgs e)
{
Socket socket = new Socket
(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
sockets = socket;
try
{
socket.Connect
(new IPEndPoint(IPAddress.Parse("ip地址"),65530));
}
catch (Exception ex)
{
MessageBox.Show("....");
return;
}
Thread thread = new Thread(new ParameterizedThreadStart(Data));
thread.IsBackground = true;
thread.Start(sockets);
}
private void txtLog_TextChanged(object sender, EventArgs e)
{
}
}
}
using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.IO;
using System.Net;
using System.Net.Sockets;
using System.Text;
using System.Threading;
using System.Windows.Forms;
namespace TcpFrmServer
{
public partial class Form1 : Form
{
List<Socket> ProxSocketList = new List<Socket>();
public Form1()
{
InitializeComponent();
}
//public object Threadpool { get; private set; }
private void btnStart_Click(object sender, EventArgs e)
{
}
public void Connect(object socket)
{
var serverSocket = socket as Socket;
this.TextToLog("服务器端开始接受消息");
while (true)
{
var proxSocket = serverSocket.Accept();
this.TextToLog(string.Format("客户端:{0}链接到位", proxSocket.RemoteEndPoint.ToString()));
ProxSocketList.Add(proxSocket);
ThreadPool.QueueUserWorkItem(new WaitCallback(Data), proxSocket);
}
}
public void Data(object socket)
{
var proxSocket = socket as Socket;
byte[] b = new byte[1024 * 1024];
int i = 0;
while (true)
{
try
{
i = proxSocket.Receive
(b, 0, b.Length, SocketFlags.None);
}
catch (Exception ex)
{
TextToLog
(string.Format("接收到客户端：{0}错误", proxSocket.RemoteEndPoint.ToString()));
ProxSocketList.Remove(proxSocket);
Connetct(proxSocket); //
return;
}
if (i <= 0)
{
TextToLog
(string.Format("接收到客户端：{0}正常", proxSocket.RemoteEndPoint.ToString()));
ProxSocketList.Remove(proxSocket);
Connect(proxSocket);
return;
}
string str = Encoding.Default.GetString(b, 0, i);
TextToLog
(string.Format("接收到客户端：{0}的消息:{1}", proxSocket.RemoteEndPoint.ToString(), str));
}
}
private void Connetct(Socket proxSocket)
{
try
{
if (proxSocket.Connected)
{
proxSocket.Shutdown(SocketShutdown.Both);
proxSocket.Close(100);
}
}
catch (Exception ex)
{
}
}
public void TextToLog(string txt)
{
if (txtLog.InvokeRequired)
{
txtLog.BeginInvoke(new Action<string>(s =>
{
this.txtLog.Text = string.Format("{0}\r\n{1}", s, txtLog.Text);
}), txt);
}
else
{
this.txtLog.Text = string.Format("{0}\r\n{1}", txt, txtLog.Text);
}
}
/// <summary>
/// 发送
/// </summary>
/// <param name="sender"></param>
/// <param name="e"></param>
private void btnSendMsg_Click(object sender, EventArgs e)
{
foreach (var proxSocket in ProxSocketList)
{
if (proxSocket.Connected)
{
byte[] data = Encoding.Default.GetBytes(txtMsg.Text);
byte[] result = new byte[data.Length + 1];
result[0] = 1;
Buffer.BlockCopy(data, 0, result, 1, data.Length);
proxSocket.Send(data, 0, data.Length, SocketFlags.None);
}
}
}
private void Form1_Load(object sender, EventArgs e)
{
Socket socket = new Socket
(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
socket.Bind(new IPEndPoint(IPAddress.Parse("地址"),65530));
socket.Listen(10);
ThreadPool.QueueUserWorkItem(new WaitCallback(this.Connect), socket);
}
private void btnSendFile_Click(object sender, EventArgs e)
{
using (OpenFileDialog ofd = new OpenFileDialog())
{
if (ofd.ShowDialog() != DialogResult.OK)
{
return;
}
byte[] data = File.ReadAllBytes(ofd.FileName);
byte[] result = new byte[data.Length + 1];
result[0] = 3;
Buffer.BlockCopy(data, 0, result, 1, data.Length);
foreach (var proxSocket in ProxSocketList)
{
if (!proxSocket.Connected)
{
continue;
}
proxSocket.Send(result, SocketFlags.None);
}
}
}
private void button1_Click(object sender, EventArgs e)
{
foreach (var proxSocket in ProxSocketList)
{
if (!proxSocket.Connected)
{
proxSocket.Send(new byte[] { 2 }, SocketFlags.None);
}
}
}
}
}
客户端------------------------------------------------------------------------------------------------------------------------------------------------
4000
------------------------------------------------------------------------------
using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.IO;
using System.Net;
using System.Net.Sockets;
using System.Text;
using System.Threading;
using System.Windows.Forms;
namespace TcpFrmClient
{
public partial class Form1 : Form
{
public Socket sockets { get; set; }
public Form1()
{
InitializeComponent();
Control.CheckForIllegalCrossThreadCalls = false;
}
private void btnConncet_Click(object sender, EventArgs e)
{
}
public void Data(object socket)
{
var proxSocket = socket as Socket;
byte[] data = new byte[1024 * 1024];
int n = 0;
while (true)
{
try
{
n = proxSocket.Receive
(data, 0, data.Length, SocketFlags.None);
}
catch (Exception ex)
{
// TextToLog
//(string.Format("接收到服务器：{0}错误", proxSocket.RemoteEndPoint.ToString()));
Contnet();
return;
}
if (n <= 0)
{
// TextToLog
//(string.Format("接收到服务器端：{0}正常", proxSocket.RemoteEndPoint.ToString()));
Contnet(); //
return;
}
if (data[0] == 1)
{
string strMsg = RecieveString(data);
// TextToLog
//(string.Format("接收到客户端：{0}的消息:{1}", proxSocket.RemoteEndPoint.ToString(), strMsg));
}
else if (data[0]==2)
{
break;
}
else if (data[0] == 3)
{
RecieveFile(data,n);
}
// string str = Encoding.Default.GetString(data);
// TextToLog
//(string.Format("接收到客户端：{0}的消息:{1}", proxSocket.RemoteEndPoint.ToString(), str));
}
}
public void RecieveFile(byte[] data,int n)
{
using (SaveFileDialog sfd =new SaveFileDialog())
{
//try
//{
if (sfd.ShowDialog(this) != DialogResult.OK)
{
return;
}
byte[] fileData = new byte[n - 1];
Buffer.BlockCopy(data, 1, fileData, 0, n - 1);
File.WriteAllBytes(sfd.FileName, fileData);
//}
//catch (Exception ex)
//{
// // MessageBox.Show(".......");
//}
}
}
public string RecieveString(byte[] datas)
{
string str = Encoding.Default.GetString(datas, 1, datas.Length - 1);
return str;
}
private void Contnet()
{
try
{
if (sockets.Connected)
{
sockets.Shutdown(SocketShutdown.Both);
sockets.Close(100);
}
}
catch (Exception ex)
{
}
}
public void TextToLog(string txt)
{
if (txtLog.InvokeRequired)
{
txtLog.BeginInvoke(new Action<string>(s =>
{
this.txtLog.Text = string.Format("{0}\r\n{1}", s, txtLog.Text);
}), txt);
//txtLog.Invoke(new Action<string>(s =>
//{
// this.txtLog.Text = string.Format("{0}\r\n{1}", s, txtLog.Text);
//}), txt);
}
else
{
this.txtLog.Text = string.Format("{0}\r\n{1}", txt, txtLog.Text);
}
}
private void btnSendMsg_Click(object sender, EventArgs e)
{
if (sockets.Connected)
{
byte[] data = Encoding.Default.GetBytes(txtMsg.Text);
sockets.Send(data, 0, data.Length, SocketFlags.None);
}
}
private void Form1_Load(object sender, EventArgs e)
{
Socket socket = new Socket
(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
sockets = socket;
try
{
socket.Connect
(new IPEndPoint(IPAddress.Parse("ip地址"),65530));
}
catch (Exception ex)
{
MessageBox.Show("....");
return;
}
Thread thread = new Thread(new ParameterizedThreadStart(Data));
thread.IsBackground = true;
thread.Start(sockets);
}
private void txtLog_TextChanged(object sender, EventArgs e)
{
}
}
}
内容来自用户分享和网络整理，不保证内容的准确性，如有侵权内容，可联系管理员处理 
相关文章推荐
- android的Socket编程---实现简单的服务器，并与客户端通信
- C++ 简单的 Tcp 实现[socket] 客户端与客户端通信
- Android中socket编程实现简单的客户端和服务器之间的通信
- spring有自己的视图可以实现pdf导出，但是获取pdf总页数太麻烦了，大家有简单的方法吗？
- linux网络编程之用socket实现简单客户端和服务端的通信（基于UDP）
- 利用Tcp和socket实现的客户端与服务端的简单通信
- 群上出的一个算法题,上我的解,大家可以用自己会的语言实现一下哦,我用的php
- 网络编程：使用Socket实现简单的服务器和客户端的通信
- Java中利用socket实现简单的服务端与客户端的通信（基础级）
- Android简单实现Socket通信，客户端连接服务器后，服务器向客户端发送文字数据
- Java实现简单的Socket服务器与客户端字符串通讯（适合初学者阅读）
- 关于android Socket通信中线程阻塞的问题解决（有点乱，随感，有兴趣的可以看看）
- 关于用Socket实现，客户端和服务器端的通信
- 【转】 C++ 简单的 Tcp 实现[socket] 客户端与客户端通信
- Java实现简单的Socket服务器与客户端字符串通讯（适合初学者阅读）
- C++ 简单的 Tcp 实现[socket] 服务器端与客户端通信
- C++ 简单的 Tcp 实现[socket] 客户端与客户端通信
- 使用socket实现简单的客户端和服务端通信(C#语言)
- Android 使用socket 实现简单的客户端和服务器端互相通信
- Java中利用socket实现简单的服务端与客户端的通信（入门级）