实例介绍
【实例简介】
【实例截图】
【核心代码】
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;
using System.IO.Ports;
using System.IO;
using System.Diagnostics;
using IP;
namespace BYJ
{
public partial class Form1 : Form
{
Socket mysocket;
Socket myserver;
IPAddress ip;
IPEndPoint point = new IPEndPoint(IPAddress.Any, 0);
Thread thReceive;
UdpClient RecUdpClient;
string filename;
SerialPort myport = new SerialPort();
string[] a = new string[5];
int size = 1024;
byte[] buffer = new byte[1024*1024];
BinaryReader br;
FileStream fs;
System.Windows.Forms.Timer timer1 = new System.Windows.Forms.Timer();
// MyTcpServer myserver;
Form2 f = new Form2();
public Form1()
{
InitializeComponent();
this.MaximizeBox = false;
timer1.Tick = new EventHandler(button_send_Click);
timer1.Interval = 1000;
comboBox1_type.Items.AddRange(new object[]{
"TCP服务端","TCP客户端","UDP服务端","UDP客户端","串口"
});
textBox1_IP.Text = "192.168.10.1";
textBox2_Port.Text = "8080";
comboBox1_type.SelectedIndex = 4;
myport.DataReceived = Port_DataReceived;
a[0] = "COM1";
a[1] = "9600";
a[2] = "N";
a[3] = "8";
a[4] = "1";
}
void TSReceive()
{
mysocket = myserver.Accept();//服务端监听到的Socket为服务端发送数据的目标socket
while (true)
{
try
{
int r = mysocket.Receive(buffer);//接收到监听的Socket的数据
if (checkBox4.Checked == true)//接收文件
{
fs.Write(buffer, 0, r);
fs.Close();
}
if (checkBox1.Checked == true)//16进制
{
buffer = change(buffer);
r *= 2;
}
if (r == 0)
{
MessageBox.Show("连接断开");
break;
}
string strRec = Encoding.Default.GetString(buffer, 0, r);
textBox2_recv.AppendText(strRec "\r\n");
// textBox2_recv.AppendText(mysocket.RemoteEndPoint.ToString() ":" strRec "\r\n");
}
catch
{ }
}
}
void TCReceive()
{
while (true)
{
try
{
int r = mysocket.Receive(buffer);
if (checkBox4.Checked == true)//接收文件
{
fs.Write(buffer, 0, r);
fs.Close();
}
if (checkBox1.Checked == true)//16进制
{
buffer = change(buffer);
r *= 2;
}
if (r == 0)
{
MessageBox.Show("连接断开");
break;
}
string strRec = Encoding.Default.GetString(buffer, 0, r);
textBox2_recv.AppendText(strRec "\r\n");
// textBox2_recv.AppendText(mysocket.RemoteEndPoint.ToString() ":" strRec "\r\n");
}
catch
{ }
}
}
//UDP Clinet接收线程
void UCReceive()
{
while (true)
{
try
{
IPEndPoint ss = new IPEndPoint(IPAddress.Any, 0);
EndPoint Remote = (EndPoint)(ss);
int r = mysocket.ReceiveFrom(buffer, ref Remote);//接收目标IP Remote 发送过来的数
if (checkBox4.Checked == true)//接收文件
{
fs.Write(buffer, 0, r);
fs.Close();
}
if (checkBox1.Checked == true)//16进制
{
buffer = change(buffer);
r *= 2;
}
string strRec = Encoding.Default.GetString(buffer, 0, r);
textBox2_recv.AppendText(strRec "\r\n");
// textBox2_recv.AppendText(Remote.ToString() ":" strRec "\r\n");
}
catch
{ }
}
}
//UDP Server接收线程
void USReceive()
{
while (true)
{
try
{
buffer = RecUdpClient.Receive(ref point);
int r = buffer.Length;
if (checkBox4.Checked == true)//接收文件
{
fs.Write(buffer, 0, r);
fs.Close();
}
if (checkBox1.Checked == true)//16进制
{
buffer = change(buffer);
}
else
{ }
string strRec = Encoding.Default.GetString(buffer);
textBox2_recv.AppendText(strRec "\r\n");
// textBox2_recv.AppendText(point.ToString() ": " strRec "\r\n");
}
catch
{ }
}
}
private void button1_Click(object sender, EventArgs e)
{
int port = Int32.Parse(textBox2_Port.Text);
ip = IPAddress.Parse(textBox1_IP.Text);
switch (comboBox1_type.SelectedIndex)
{
case 0://TCP服务端
myserver = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
point = new IPEndPoint(ip, Convert.ToInt32(textBox2_Port.Text));//绑定端口号
if (button1.Text == "断开")
{
myserver.Close();
button1.Text = "连接";
comboBox1_type.Enabled = true;
}
else
{
try
{
myserver.Bind(point);//绑定监听端口
myserver.Listen(10);
thReceive = new Thread(TSReceive);
thReceive.IsBackground = true;
thReceive.Start();
button1.Text = "断开";
comboBox1_type.Enabled = false;
}
catch (SocketException ex)
{
MessageBox.Show(ex.Message);
}
}
break;
case 1://TCP客户端
mysocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
if(button1.Text=="断开")
{
mysocket.Close();
button1.Text = "连接";
comboBox1_type.Enabled = true;
}
else
{
try
{
mysocket.Connect(new IPEndPoint(ip, port));
thReceive = new Thread(TCReceive);
thReceive.IsBackground = true;
thReceive.Start();
button1.Text = "断开";
comboBox1_type.Enabled = false;
}
catch (SocketException ex)
{
MessageBox.Show(ex.Message);
}
}
break;
case 2://UDP服务端
if (button1.Text == "断开")
{
mysocket.Close();
button1.Text = "连接";
comboBox1_type.Enabled = true;
}
else
{
try
{
mysocket = new Socket(AddressFamily.InterNetwork, SocketType.Dgram, ProtocolType.Udp);
ip = IPAddress.Parse(textBox1_IP.Text);
RecUdpClient = new UdpClient(new IPEndPoint(ip, Convert.ToInt32(textBox2_Port.Text)));
thReceive = new Thread(USReceive);
thReceive.IsBackground = true;
thReceive.Start();
button1.Text = "断开";
comboBox1_type.Enabled = false;
}
catch (SocketException ex)
{
MessageBox.Show(ex.Message);
}
}
break;
case 3://UDP客户端
if (button1.Text == "断开")
{
mysocket.Close();
button1.Text = "连接";
comboBox1_type.Enabled = true;
}
else
{
try
{
mysocket = new Socket(AddressFamily.InterNetwork, SocketType.Dgram, ProtocolType.Udp);
ip = IPAddress.Parse(textBox1_IP.Text);
point = new IPEndPoint(ip, Convert.ToInt32(textBox2_Port.Text));
thReceive = new Thread(UCReceive);
thReceive.IsBackground = true;
thReceive.Start();
button1.Text = "断开";
comboBox1_type.Enabled = false;
}
catch (SocketException ex)
{
MessageBox.Show(ex.Message);
}
}
break;
case 4://串口
if(button1.Text =="打开串口")
{
openPort(myport);
}
else
{
if (myport.IsOpen)
{
myport.Close();
button1.Text = "打开串口";
}
}
break;
}
}
public void openPort(SerialPort SP)
{
SP.PortName = a[0];
SP.BaudRate = Convert.ToInt32(a[1]);
string parity = a[2];
if (parity == "N")
{
SP.Parity = Parity.None;
}
else if (parity == "E")
{
SP.Parity = Parity.Even;
}
else if (parity == "O")
{
SP.Parity = Parity.Odd;
}
float f = Convert.ToSingle(a[4].Trim());
if (f == 1)
SP.StopBits = StopBits.One;
else if (f == 1.5)
SP.StopBits = StopBits.OnePointFive;
else if (f == 2)
SP.StopBits = StopBits.Two;
else
SP.StopBits = StopBits.One;
SP.DataBits = Convert.ToInt32(a[3]);
try
{
SP.Open();
button1.Text = "关闭串口";
}
catch (Exception ex)
{
MessageBox.Show(ex.Message);
}
}
private void comboBox1_type_SelectedIndexChanged(object sender, EventArgs e)
{
if(comboBox1_type.SelectedIndex==4)
{
textBox1_IP.Enabled = false;
textBox2_Port.Enabled = false;
button2.Enabled = true;
checkBox4.Enabled = false;
checkBox5.Enabled = false;
}
else
{
textBox1_IP.Text = GetIP.GetLocalIP();
textBox1_IP.Enabled = true;
textBox2_Port.Enabled = true;
button2.Enabled = false;
checkBox4.Enabled = true;
checkBox5.Enabled = true;
}
switch(comboBox1_type.SelectedIndex)
{
case 0:
button1.Text = "监听";
break;
case 1:
button1.Text = "连接";
break;
case 2:
button1.Text = "监听";
break;
case 3:
button1.Text = "连接";
break;
case 4:
button1.Text = "打开串口";
break;
}
}
private static byte[] strToToHexByte(string hexString)
{
hexString = hexString.Replace(" ", "");
if ((hexString.Length % 2) != 0)
{
int len = hexString.Length - 1;
hexString = hexString.Insert(len, "1");
}
byte[] returnBytes = new byte[hexString.Length / 2];
for (int i = 0; i < returnBytes.Length; i )
{
returnBytes[i] = Convert.ToByte(hexString.Substring(i * 2, 2), 16);
if (i == returnBytes.Length - 1)
{
returnBytes[i] -= 0x10;
}
}
return returnBytes;
}
void Port_DataReceived(object sender, SerialDataReceivedEventArgs e)
{
string s=null;
byte[] buf = null;
try
{
do //确保数据接收完整----用myport.ReadExisting(s)会出现中文乱码现象
{
int count = myport.BytesToRead;
if (count <= 0)
break;
byte[] readBuffer = new byte[count];
Application.DoEvents();
myport.Read(readBuffer, 0, count);
s = System.Text.Encoding.Default.GetString(readBuffer);
} while (myport.BytesToRead > 0);
if (checkBox1.Checked == true)
{
byte[] temp = Encoding.Default.GetBytes(s);
buf = change(temp);
s = Encoding.Default.GetString(buf, 0, buf.Length);
}
textBox2_recv.AppendText(s "\n");
}
catch (Exception ex)
{
MessageBox.Show(ex.Message);
}
}
byte[] change(byte[] inbuf)//将ASCII替换成16进制
{
byte[] outbuf = new byte[inbuf.Length * 2];
int i = 0, j=0,len = inbuf.Length;
byte uctemp;
for (i = 0; i < len;i )
{
uctemp= (byte)(inbuf[i] & 0xf0);
uctemp = (byte)(uctemp >> 4);
if(uctemp>9)
{
uctemp = 0x37;
}
else
{
uctemp = 0x30;
}
outbuf[j ] = uctemp;
uctemp = (byte)(inbuf[i] & 0x0f);
if (uctemp > 9)
{
uctemp = 0x37;
}
else
{
uctemp = 0x30;
}
outbuf[j ] = uctemp;
}
return outbuf;
}
private void button_send_Click(object sender, EventArgs e)
{
int len=0;
byte[] buf = null;
if (checkBox2.Checked == true)//16进制发送
{
byte[] temp = Encoding.Default.GetBytes(textBox1_send.Text);
buf = change(temp);
len = buf.Length;
}
else//ASCII发送
{
buf = Encoding.Default.GetBytes(textBox1_send.Text);
len = buf.Length;
}
if (comboBox1_type.SelectedIndex != 4)
{
try
{
if (checkBox5.Checked == true)//发送文件
{
//将文件转换成二进制流进行发送
System.IO.FileStream fs =new System.IO.FileStream(filename,FileMode.Open,FileAccess.Read);
br = new BinaryReader(fs, Encoding.UTF8);
br.Read(buffer, 0, size);
mysocket.BeginSend(buffer, 0, size, SocketFlags.None,new AsyncCallback(EndSendFile), null);
}
else
{
mysocket.SendTo(buf, point);
}
}
catch (Exception ex)
{
MessageBox.Show(ex.Message);
}
}
else
{
try
{
myport.Write(buf, 0, len);
}
catch (Exception ex)
{
MessageBox.Show(ex.Message);
}
}
}
private void EndSendFile(IAsyncResult AR)
{
int i = 0;
mysocket.EndSend(AR);
//判断文件是否读完，没读完继续读到缓冲区
if ((i = br.Read(buffer, 0, size)) != 0)
{
mysocket.BeginSend(buffer, 0, size, SocketFlags.None, new AsyncCallback(EndSendFile), null);
}
}
private void button2_Click(object sender, EventArgs e)
{
f.StartPosition = FormStartPosition.CenterParent;//在窗口1中央显示
f.ShowDialog();//弹出Form2串口参数设置窗口
if (f.DialogResult == DialogResult.OK)
{
a = f.str;//返回串口参数
}
}
private void checkBox3_CheckedChanged(object sender, EventArgs e)
{
if(checkBox3.Checked ==true)//若选中则开启定时器，进行数据连发
{
timer1.Start();
}
else
{
timer1.Stop();
}
}
private void checkBox4_CheckedChanged(object sender, EventArgs e)
{
SaveFileDialog sfd = new SaveFileDialog();
//弹出文件保存选择框
if (sfd.ShowDialog() == System.Windows.Forms.DialogResult.OK)
{
//创建文件流
fs = new FileStream(sfd.FileName, FileMode.OpenOrCreate);
}
}
private void checkBox5_CheckedChanged(object sender, EventArgs e)//选择要发送的文件
{
if (checkBox5.Checked == true)
{
OpenFileDialog file = new OpenFileDialog();
file.ShowDialog();
if (file.FileName.Length > 0)
{
this.textBox1_send.Text = file.FileName;
filename = file.FileName;
textBox1_send.Enabled = false;
}
else
{
checkBox5.Checked = false;
}
}
else
{
textBox1_send.Clear();
textBox1_send.Enabled = true;
}
}
}
}
好例子网口号：伸出你的我的手 — 分享！
小贴士
感谢您为本站写下的评论，您的评论对其它用户来说具有重要的参考价值，所以请认真填写。
- 类似“顶”、“沙发”之类没有营养的文字，对勤劳贡献的楼主来说是令人沮丧的反馈信息。
- 相信您也不想看到一排文字/表情墙，所以请不要反馈意义不大的重复字符，也请尽量不要纯表情的回复。
- 提问之前请再仔细看一遍楼主的说明，或许是您遗漏了。
- 请勿到处挖坑绊人、招贴广告。既占空间让人厌烦，又没人会搭理，于人于己都无利。
关于好例子网
本站旨在为广大IT学习爱好者提供一个非营利性互相学习交流分享平台。本站所有资源都可以被免费获取学习研究。本站资源来自网友分享，对搜索内容的合法性不具有预见性、识别性、控制性，仅供学习研究，请务必在下载后24小时内给予删除，不得用于其他任何用途，否则后果自负。基于互联网的特殊性，平台无法对用户传输的作品、信息、内容的权属或合法性、安全性、合规性、真实性、科学性、完整权、有效性等进行实质审查；无论平台是否已进行审查，用户均应自行承担因其传输的作品、信息、内容而可能或已经产生的侵权或权属纠纷等法律责任。本站所有资源不代表本站的观点或立场，基于网友分享，根据中国法律《信息网络传播权保护条例》第二十二与二十三条之规定，若资源存在侵权或相关问题请联系本站客服人员，点此联系我们。关于更多版权及免责申明参见 版权及免责申明
网友评论
我要评论