实例介绍
【实例简介】基于C#的以太网通信
【实例截图】
【核心代码】
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;
using System.IO;
namespace NetWork
{
public partial class Form1 : Form
{
public Form1()
{
InitializeComponent();
}
IPAddress ip;
IPEndPoint point = new IPEndPoint(IPAddress.Any,0);
IPAddress ip2;
IPEndPoint point2 = new IPEndPoint(IPAddress.Any, 0);
string protocol;
Socket aimSocket;
Socket aimSocket2;
Socket mySocket;
UdpClient RecUdpClient;
//IPEndPoint remote;
private void Form1_Load(object sender, EventArgs e)//初始化为UDP Server模式
{
cobProtocol.SelectedIndex = 0;
txtIP.Text = GetAddressIP();
// txtIP2.Text = GetAddressIP();
Control.CheckForIllegalCrossThreadCalls = false;
}
string GetAddressIP()
{
string AddressIP = "";
foreach (IPAddress _IPAddress in Dns.GetHostEntry(Dns.GetHostName()).AddressList)
{
if (_IPAddress.AddressFamily.ToString() == "InterNetwork")
{
AddressIP = _IPAddress.ToString();
ip = _IPAddress;//设定全局的IP
}
}
return AddressIP;
}
Thread thReceive = null;
private void btnStart_Click(object sender, EventArgs e)//设置目标IP（Client），本地IP（Server）
{
try
{
if (protocol == "UDP Server")
{
if (btnStart.Text == "连接")
{
btnStart.Text = "断开";
aimSocket = new Socket(AddressFamily.InterNetwork, SocketType.Dgram, ProtocolType.Udp);
RecUdpClient = new UdpClient(new IPEndPoint(ip, Convert.ToInt32(txtPort.Text)));
// MessageBox.Show("UDP Server创建成功");
thReceive = new Thread(USReceive);
thReceive.IsBackground = true;
thReceive.Start();
}
else
{
if(thReceive!=null)
{
thReceive.Abort();
btnStart.Text = "连接";
}
}
}
else if (protocol == "UDP Client")//UPD客户端，目标IP和端口 调用Socket.SendTo
{
aimSocket = new Socket(AddressFamily.InterNetwork, SocketType.Dgram, ProtocolType.Udp);//建立通信的Socket
ip = IPAddress.Parse(txtIP.Text);
point = new IPEndPoint(ip, Convert.ToInt32(txtPort.Text));
MessageBox.Show("UDP Client设置成功");
Thread thReceive = new Thread(UCReceive);
thReceive.IsBackground = true;
thReceive.Start();
}
else if (protocol == "TCP Server")
{
if (btnStart.Text == "连接")
{
btnStart.Text = "断开";
// mySocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
// point = new IPEndPoint(ip, Convert.ToInt32(txtPort.Text));//绑定端口号
// mySocket.Bind(point);//绑定监听端口
// mySocket.Listen(10);//等待连接是一个阻塞过程，创建线程来监听
//work_item work = new work_item { _id = 2, _ip_in = new IPEndPoint(IPAddress.Any, 1723), _ip_out_host = "10.10.8.72", _ip_out_port = 1008 };
// mySocket.BeginAccept(on_local_connected, new object[] { mySocket, work });//接受connect
// // MessageBox.Show("TCP Server绑定成功");
// // thReceive = new Thread(TSReceive);
// // thReceive.IsBackground = true;
// //thReceive.Start();
listert = new Thread(new ThreadStart(tcplister));
listert.Start();
}
else
{
if (listert != null)
{
listert.Abort();
btnStart.Text = "连接";
}
}
}
else if (protocol == "TCP Client")
{
ip = IPAddress.Parse(txtIP.Text);//目标IP
point = new IPEndPoint(ip, Convert.ToInt32(txtPort.Text));//目标端口
aimSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
aimSocket.Connect(point);//连接服务器
MessageBox.Show("连接成功");
Thread thReceive = new Thread(TCReceive);
thReceive.IsBackground = true;
thReceive.Start();
}
else if (protocol == "TCP Client2")
{
try
{
StartClient2();
MessageBox.Show("连接成功");
}
catch (Exception psx)
{
MessageBox.Show("连接失败：" psx.Message);
}
}
}
catch(Exception pxp)
{
MessageBox.Show(pxp.Message);
}
}
public void StartClient2()
{
StartCC1();
StartCC2();
}
public void StartCC1()
{
ip = IPAddress.Parse(txtIP.Text);//目标IP
point = new IPEndPoint(ip, Convert.ToInt32(txtPort.Text));//目标端口
aimSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
aimSocket.Connect(point);//连接服务器
Thread thReceive = new Thread(TCReceive1);
thReceive.IsBackground = true;
thReceive.Start();
}
public void StartCC2()
{
ip2 = IPAddress.Parse(txtIP2.Text);//目标IP2
point2 = new IPEndPoint(ip2, Convert.ToInt32(txtPort2.Text));//目标端口
aimSocket2 = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
aimSocket2.Connect(point2);//连接服务器
Thread thReceive2 = new Thread(TCReceive2);
thReceive2.IsBackground = true;
thReceive2.Start();
}
Thread listert = null;
public void tcplister()
{
TcpListener tcpl = new TcpListener(ip, Convert.ToInt32(txtPort.Text));
tcpl.Start();
Console.WriteLine("Listening on {0}", ((IPEndPoint)tcpl.LocalEndpoint).ToString());
Console.WriteLine("Server now waiting for clients to connect");
//Console.WriteLine("Press Ctrl c to Quit...");
int ThreadID = 0;
while (btnStart.Text == "断开")
{
while (!tcpl.Pending())
{
Thread.Sleep(100);
}
ParameterizedThreadStart myThreadStart = new ParameterizedThreadStart(HandleThread);
Thread myWorkerThread = new Thread(myThreadStart);
myWorkerThread.Name = (ThreadID ).ToString();
myWorkerThread.Start(tcpl);
}
}
public void HandleThread(object myt)
{
TcpListener tcpl=(TcpListener)myt;
string strClientIP = "";
string strClientPort = "";
string strLocalIP = "";
string strLocalPort = "";
Thread currentThread = Thread.CurrentThread;
try
{
// Accept will block until someone connects
Socket s = tcpl.AcceptSocket();
//RequestID ;
strLocalIP = ((IPEndPoint)s.LocalEndPoint).Address.ToString();
strLocalPort = ((IPEndPoint)s.LocalEndPoint).Port.ToString();
strClientIP = ((IPEndPoint)s.RemoteEndPoint).Address.ToString();
strClientPort = ((IPEndPoint)s.RemoteEndPoint).Port.ToString();
const int BUFFERSIZE = 4096;//that's enough???
Byte[] readclientchar = new Byte[BUFFERSIZE];
string[] RequestLines = new string[32];
int rc = 0;
do
{
//use BUFFERSIZE contral the receive data size to avoid the BufferOverflow attack
rc = s.Receive(readclientchar, 0, BUFFERSIZE, SocketFlags.None);
string strReceive =Encoding.ASCII.GetString(readclientchar, 0, rc);
Console.WriteLine(DateTime.Now.ToString() " Request ID=[{0}] {1}->{2}:{3} ",
currentThread.Name,
((IPEndPoint)s.RemoteEndPoint).ToString(),
((IPEndPoint)s.LocalEndPoint).ToString(), strReceive);
} while (rc>0);
Console.WriteLine(DateTime.Now.ToString() " Closed ID=[{0}] {1}->{2} :Server Closed", currentThread.Name,
((IPEndPoint)s.LocalEndPoint).ToString(), ((IPEndPoint)s.RemoteEndPoint).ToString());
s.Close();
}
catch (SocketException)
{
Console.WriteLine(DateTime.Now.ToString() " Closed ID=[{0}] {1}:{2}->{3}:{4} :Client Closed", currentThread.Name,
strClientIP, strClientPort, strLocalIP, strLocalPort);
currentThread.Abort();
}
}
public void on_local_connected (IAsyncResult ar)
{
object[] ar_arr = ar.AsyncState as object[];
Socket sock_svr = ar_arr[0] as Socket;
//work_item work = (work_item)ar_arr[1];
// comboBox1.Items.Add(work);
//Socket sock_cli = sock_svr.EndAccept(ar);
aimSocket = sock_svr.Accept();
IPEndPoint clientipe = (IPEndPoint)aimSocket.RemoteEndPoint;
string ipport = clientipe.Address.ToString() ":" clientipe.Port.ToString();
comboBox1.Items.Add(ipport);
sock_svr.BeginAccept(on_local_connected, ar.AsyncState);
//Socket sock_cli_remote = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
// Thread thReceive = new Thread(TCReceive);
// thReceive.IsBackground = true;
// thReceive.Start();
// thReceive.Start(new object[] { sock_cli, sock_cli_remote, work._id, true });
}
private void cobProtocol_SelectedIndexChanged(object sender, EventArgs e)
{
//[0] UDP Server [1] UDP Client [2] TCP Server [3] TCP Client
//此处设置标准位？？？ 然后为btnConnect做准备？
protocol = cobProtocol.SelectedItem.ToString();
if (protocol == "UPD Server")
{
lblIP.Text = "本地IP地址：";
lblPort.Text = "本地端口号：";
}
else if (protocol == "UDP Client")
{
lblIP.Text = "服务器IP地址：";
lblPort.Text = "服务器端口号：";
}
else if (protocol == "TCP Server")
{
lblIP.Text = "本地IP地址：";
lblPort.Text = "本地端口号：";
}
else if (protocol == "TCP Client")
{
lblIP.Text = "服务器IP地址：";
lblPort.Text = "服务器端口号：";
}
}
private void btnSend_Click(object sender, EventArgs e)
{
try
{
byte[] buffer = Encoding.Default.GetBytes(txtSend.Text);
aimSocket.SendTo(buffer, point);
}
catch
{ }
}
//TCP Server接收线程
void TSReceive()
{
Socket aimSocket1 = mySocket.Accept();//服务端监听到的Socket为服务端发送数据的目标socket
IPEndPoint clientipe = (IPEndPoint)aimSocket1.RemoteEndPoint;
string ipport = clientipe.Address.ToString() ":" clientipe.Port.ToString();
comboBox1.Text = ipport;
byte[] buffer = new byte[1024];
while (true)
{
try
{
int r = aimSocket1.Receive(buffer);//接收到监听的Socket的数据
if (r == 0)
{
MessageBox.Show("连接断开");
break;
}
string strRec = Encoding.Default.GetString(buffer, 0, r);
txtRec.AppendText(aimSocket1.RemoteEndPoint.ToString() ":" strRec "\r\n");
}
catch
{ }
}
}
//TCP Client接收线程
void TCReceive()
{
byte[] buffer = new byte[1024];
while (true)
{
try
{
int r = aimSocket.Receive(buffer);
if (r == 0)
{
MessageBox.Show("连接断开");
break;
}
string strRec = Encoding.Default.GetString(buffer, 0, r);
txtRec.AppendText(aimSocket.RemoteEndPoint.ToString() ":" strRec "\r\n");
}
catch
{ }
}
}
public bool tc1isout = false;
public bool tc2isout = false;
void TCReceive1()
{
byte[] buffer = new byte[1024];
while (true)
{
try
{
int r = aimSocket.Receive(buffer);
if (r == 0)
{
tc1isout = true;
IPEndPoint iep = ((IPEndPoint)aimSocket.RemoteEndPoint);
MessageBox.Show(iep.Address.ToString() ":" iep.Port.ToString() "连接断开");
break;
}
aimSocket2.Send(buffer, 0, r, SocketFlags.None);
string strRec = Encoding.Default.GetString(buffer, 0, r);
txtRec.AppendText(aimSocket.RemoteEndPoint.ToString() ":" strRec "\r\n");
}
catch
{ }
}
}
void TCReceive2()
{
byte[] buffer = new byte[1024];
while (true)
{
try
{
int r = 0;
r = aimSocket2.Receive(buffer);
if (r == 0)
{
IPEndPoint iep = ((IPEndPoint)aimSocket2.RemoteEndPoint);
MessageBox.Show(iep.Address.ToString() ":" iep.Port.ToString() "连接断开");
tc2isout = true;
break;
}
aimSocket.Send(buffer, 0, r, SocketFlags.None);
string strRec2 = Encoding.Default.GetString(buffer, 0, r);
txtRec.AppendText(aimSocket2.RemoteEndPoint.ToString() ":" strRec2 "\r\n");
}
catch
{ }
}
}
//UDP Clinet接收线程
void UCReceive()
{
byte[] buffer = new byte[1024];
while (true)
{
try
{
IPEndPoint ss = new IPEndPoint(IPAddress.Any, 0);
EndPoint Remote = (EndPoint)(ss);
int r = aimSocket.ReceiveFrom(buffer, ref Remote);//接收目标IP Remote 发送过来的数
string strRec = Encoding.Default.GetString(buffer,0,r);
txtRec.AppendText(Remote.ToString() ": " strRec "\r\n");
}
catch
{ }
}
}
//UDP Server接收线程
void USReceive()
{
while (true)
{
try
{
byte[] buffer = RecUdpClient.Receive(ref point);
string strRec = Encoding.Default.GetString(buffer);
txtRec.AppendText(point.ToString() ": " strRec "\r\n");
}
catch
{ }
}
}
public Thread zzth = null;
public void zzvod()
{
ZF.NginxMain();
}
private void nginxstart_Click(object sender, EventArgs e)
{
if (nginxstart.Text == "中转开启")
{
work_item wi = new work_item { _id = 2, _ip_in = new IPEndPoint(IPAddress.Any, int.Parse(txtPort.Text)), _ip_out_host = txtIP2.Text, _ip_out_port = ushort.Parse(txtPort2.Text) };
//ZF.MainLink(wi);
if (zzth == null)
{
zzth=new Thread(new ThreadStart(zzvod));
zzth.Start();
}
timer1.Enabled = true;
nginxstart.Text = "中转停止";
}
else
{
zzth.Abort();
zzth = null;
nginxstart.Text = "中转开启";
timer1.Enabled = false;
}
}
private void timer1_Tick(object sender, EventArgs e)
{
//this.BeginInvoke(new EventHandler(delegate
//{
// TimeStatusLabel.Text = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss");
//}));
// this.txtRec.Text = ZF.show_statestr();
dataGridView1.DataSource= ZF.gettransterdata();
}
private void Test_Click(object sender, EventArgs e)
{
try
{
if (tc1isout)
{
StartCC1();
}
if (tc2isout)
{
StartCC2();
}
if ((!tc1isout)&& (!tc2isout))
StartClient2();
MessageBox.Show("连接成功");
}
catch(Exception psx) {
MessageBox.Show("连接失败：" psx.Message);
}
}
private void btnsettings_Click(object sender, EventArgs e)
{
string appstr = AppDomain.CurrentDomain.BaseDirectory "app.ini";
if (!File.Exists(appstr))
{
FileStream fs = File.Create(appstr);
fs.Close();
StreamWriter sw = new StreamWriter(appstr, false
, Encoding.UTF8);
sw.Write(@"1,0.0.0.0:1723,172.22.247.1:8085
2,0.0.0.0:1724,10.10.8.53.1:3389");
sw.Close();
}
System.Diagnostics.Process.Start("notepad.exe", appstr);
}
}
}
好例子网口号：伸出你的我的手 — 分享！
网友评论
小贴士
感谢您为本站写下的评论，您的评论对其它用户来说具有重要的参考价值，所以请认真填写。
- 类似“顶”、“沙发”之类没有营养的文字，对勤劳贡献的楼主来说是令人沮丧的反馈信息。
- 相信您也不想看到一排文字/表情墙，所以请不要反馈意义不大的重复字符，也请尽量不要纯表情的回复。
- 提问之前请再仔细看一遍楼主的说明，或许是您遗漏了。
- 请勿到处挖坑绊人、招贴广告。既占空间让人厌烦，又没人会搭理，于人于己都无利。
关于好例子网
本站旨在为广大IT学习爱好者提供一个非营利性互相学习交流分享平台。本站所有资源都可以被免费获取学习研究。本站资源来自网友分享，对搜索内容的合法性不具有预见性、识别性、控制性，仅供学习研究，请务必在下载后24小时内给予删除，不得用于其他任何用途，否则后果自负。基于互联网的特殊性，平台无法对用户传输的作品、信息、内容的权属或合法性、安全性、合规性、真实性、科学性、完整权、有效性等进行实质审查；无论平台是否已进行审查，用户均应自行承担因其传输的作品、信息、内容而可能或已经产生的侵权或权属纠纷等法律责任。本站所有资源不代表本站的观点或立场，基于网友分享，根据中国法律《信息网络传播权保护条例》第二十二与二十三条之规定，若资源存在侵权或相关问题请联系本站客服人员，点此联系我们。关于更多版权及免责申明参见 版权及免责申明
支持(0) 盖楼(回复)
支持(0) 盖楼(回复)
支持(0) 盖楼(回复)
支持(0) 盖楼(回复)