|
c#实现UDP通讯
现在在公司开发一套硬软结合的产品，这中间除了服务接口，少不了的就是udp通讯了，小主我贴出自己的代码，简单实现UDP通讯，供小白们使用，大神级的就不要来了，快走
程序代码
public partial class Form1 : Form { public Form1() { InitializeComponent(); } /// /// 用于UDP发送的网络服务类 /// private UdpClient udpcSend; /// /// 用于UDP接收的网络服务类 /// private UdpClient udpcRecv;
private void button1_Click(object sender, EventArgs e)
{
if (string.IsNullOrWhiteSpace(richTextBox1.Text))
{
MessageBox.Show("请先输入待发送内容");
return;
}
// 匿名发送
//udpcSend = new UdpClient(0); // 自动分配本地IPv4地址
// 实名发送
IPEndPoint localIpep = new IPEndPoint(IPAddress.Parse("192.168.137.1"),1991); // 本机IP，指定的端口号
udpcSend = new UdpClient(localIpep);
Thread thrSend = new Thread(SendMessage);
thrSend.Start(richTextBox1.Text);
}
///
/// 发送信息
///
///
private void SendMessage(object obj)
{
string message = (string)obj;
byte[] sendbytes = Encoding.Unicode.GetBytes(message);
IPEndPoint remoteIpep = new IPEndPoint(IPAddress.Parse("192.168.137.1"), 8848); // 发送到的IP地址和端口号
udpcSend.Send(sendbytes, sendbytes.Length, remoteIpep);
udpcSend.Close();
ResetTextBox(richTextBox1);
}
///
/// 开关：在监听UDP报文阶段为true，否则为false
///
bool IsUdpcRecvStart = false;
///
/// 线程：不断监听UDP报文
///
Thread thrRecv;
private void button2_Click(object sender, EventArgs e)
{
if (!IsUdpcRecvStart) // 未监听的情况，开始监听
{
IPEndPoint localIpep = new IPEndPoint(IPAddress.Parse("192.168.137.1"), 8848); // 本机IP和监听端口号
udpcRecv = new UdpClient(localIpep);
thrRecv = new Thread(ReceiveMessage);
thrRecv.Start();
IsUdpcRecvStart = true;
ShowMessage(richTextBox2, "UDP监听器已成功启动");
}
else // 正在监听的情况，终止监听
{
thrRecv.Abort(); // 必须先关闭这个线程，否则会异常
udpcRecv.Close();
IsUdpcRecvStart = false;
ShowMessage(richTextBox2, "UDP监听器已成功关闭");
}
}
///
/// 接收数据
///
///
private void ReceiveMessage(object obj)
{
IPEndPoint remoteIpep = new IPEndPoint(IPAddress.Any, 0);//
while (true)
{
try
{
byte[] bytRecv = udpcRecv.Receive(ref remoteIpep);
string message = Encoding.Unicode.GetString(bytRecv, 0, bytRecv.Length);
ShowMessage(richTextBox2, string.Format("{0}[{1}]", remoteIpep, message));
}
catch (Exception ex)
{
ShowMessage(richTextBox2, ex.Message);
break;
}
}
}
// 向RichTextBox中添加文本
delegate void ShowMessageDelegate(RichTextBox txtbox, string message);
private void ShowMessage(RichTextBox txtbox, string message)
{
if (txtbox.InvokeRequired)
{
ShowMessageDelegate showMessageDelegate = ShowMessage;
txtbox.Invoke(showMessageDelegate, new object[] { txtbox, message });
}
else
{
txtbox.Text += message + "\r\n";
}
}
// 清空指定RichTextBox中的文本
delegate void ResetTextBoxDelegate(RichTextBox txtbox);
private void ResetTextBox(RichTextBox txtbox)
{
if (txtbox.InvokeRequired)
{
ResetTextBoxDelegate resetTextBoxDelegate = ResetTextBox;
txtbox.Invoke(resetTextBoxDelegate, new object[] { txtbox });
}
else
{
txtbox.Text = "";
}
}
///
/// 关闭程序，强制退出
///
///
///
private void Form1_FormClosing(object sender, FormClosingEventArgs e)
{
Environment.Exit(0);
}
}
|