c语言网络编程UDP(C语言网络编程实践影印版)
c#udp源端口目的端口不同
在unity中使用UDP进行数据的交互,建立C/S模式,两个客户端和一个服务端。两个客户端使用不同的端口往服务端发送数据,服务端根据收到的数据进行处理和判断,控制服务端的显示。
说明:两个客户端连接的是Kinect V2,需要将检测到的人体的数据信息发送到服务端进行系统数据的整体显示。指定的消息协议是ClientID|index|PosLeft|Left_S|PosRight|Right_S|ACTION| ClientID|index|PosLeft|Left_S|PosRight|Right_S|ACTION| ...
这是客户端根据检测到人体的数量向服务端发送的数据格式。
服务端:使用两个线程用于接收两个客户端的数据,将收到的数据添加到Queue中。在需要显示数据的Update中从Queue中取出数据进行处理控制。
这里服务端的接收数据脚本直接上代码:
using UnityEngine;
using System.Collections;
//引入库
using System.Net;
using System.Net.Sockets;
using System.Text;
using System.Threading;
using System.Collections.Generic;
public class UdpHelpHandler : MonoBehaviour {
//以下默认都是私有的成员
Socket socket,socket2; //目标socket
EndPoint clientEnd; //客户端
IPEndPoint ipEnd,ipEnd2; //侦听端口
string recvStr,recvStr2; //接收的字符串
string sendStr; //发送的字符串
byte[] recvData=new byte[1024]; //接收的数据,必须为字节
byte[] recvData2=new byte[1024]; //接收的数据,必须为字节
byte[] sendData=new byte[1024]; //发送的数据,必须为字节
int recvLen,recvLen2; //接收的数据长度
Thread connectThread,connectThread2; //连接线程
int[] WaveCounts = new int[2];
int[] TPoseCounts = new int[2];
public Queuestring queueClient1 = new Queuestring();
public Queuestring queueClient2 = new Queuestring();
private System.Object thisLock = new System.Object ();
//初始化
public void InitSocket()
{
//定义侦听端口,侦听任何IP
ipEnd=new IPEndPoint(IPAddress.Any,2000);
//定义套接字类型,在主线程中定义
socket=new Socket(AddressFamily.InterNetwork,SocketType.Dgram,ProtocolType.Udp);
//服务端需要绑定ip
try{
socket.Bind(ipEnd);
}
catch (System.Exception ex)
{
socket.Close ();
Debug.LogError(ex.Message + "\n" + ex.StackTrace);
}
//定义侦听端口,侦听任何IP
ipEnd2=new IPEndPoint(IPAddress.Any,3000);
//定义套接字类型,在主线程中定义
socket2=new Socket(AddressFamily.InterNetwork,SocketType.Dgram,ProtocolType.Udp);
//服务端需要绑定ip
try{
socket2.Bind(ipEnd2);
}
catch (System.Exception ex)
{
socket2.Close ();
Debug.LogError(ex.Message + "\n" + ex.StackTrace);
}
//定义客户端
IPEndPoint sender=new IPEndPoint(IPAddress.Any,0);
clientEnd=(EndPoint)sender;
print("waiting for UDP dgram");
//开启一个线程连接,必须的,否则主线程卡死
connectThread=new Thread(new ThreadStart(SocketReceive));
connectThread.Start();
//开启一个线程连接,必须的,否则主线程卡死
connectThread2=new Thread(new ThreadStart(SocketReceive2));
connectThread2.Start();
}
void SocketSend(string sendStr)
{
//清空发送缓存
sendData=new byte[1024];
//数据类型转换
sendData=Encoding.ASCII.GetBytes(sendStr);
//发送给指定客户端
socket.SendTo(sendData,sendData.Length,SocketFlags.None,clientEnd);
}
//服务器接收
void SocketReceive()
{
//进入接收循环
while(true)
{
//对data清零
recvData=new byte[1024];
//获取客户端,获取客户端数据,用引用给客户端赋值
recvLen=socket.ReceiveFrom(recvData,ref clientEnd);
//输出接收到的数据
recvStr=Encoding.ASCII.GetString(recvData,0,recvLen);
char[] msgDelim = { '|' };
string[] asMessages = recvStr.Split(msgDelim);
if (asMessages.Length 7) {
queueClient1.Enqueue (recvStr);
if (int.Parse (asMessages [0]) == 2) {
if (int.Parse (asMessages [6]) == 6) { //wave
SetWaveCountsClient1 (2);
}
} else if (int.Parse (asMessages [0]) == 3) {
if (int.Parse (asMessages [6]) == 6) { //wave
SetWaveCountsClient2 (3);
}
}
}
}
}
//服务器接收
void SocketReceive2()
{
//进入接收循环
while(true)
{
//对data清零
recvData2=new byte[1024];
//获取客户端,获取客户端数据,用引用给客户端赋值
recvLen2=socket2.ReceiveFrom(recvData2,ref clientEnd);
//输出接收到的数据
recvStr2=Encoding.ASCII.GetString(recvData2,0,recvLen2);
char[] msgDelim = { '|' };
string[] asMessages = recvStr2.Split(msgDelim);
if (asMessages.Length 7)
{
queueClient2.Enqueue (recvStr2);
if (int.Parse(asMessages[0]) == 2)
{
if(int.Parse(asMessages[6]) == 6) //wave
{
SetWaveCountsClient1(2);
}
}
else if (int.Parse(asMessages[0]) == 3)
{
if (int.Parse(asMessages[6]) == 6) //wave
{
SetWaveCountsClient2(3);
}
}
}
}
}
public void SetWaveCountsClient1(int index)
{
if (index == 2)
{
WaveCounts[0]++;
}
}
public void SetWaveCountsClient2(int index)
{
if (index == 3)
WaveCounts[1]++;
}
public void SetTposeCounts(int index)
{
if (index == 2)
TPoseCounts[0]++;
else if (index == 3)
TPoseCounts[1]++;
}
public int GetWaveCounts(int index)
{
int ret = 0;
if (index == 2)
{
if (WaveCounts[0] 0)
ret = WaveCounts[0]--;
}
else if (index == 3)
{
if (WaveCounts[1] 0)
ret = WaveCounts[1]--;
}
return ret;
}
public int GetTposeCounts(int index)
{
int ret = 0;
if (index == 2)
{
if (TPoseCounts[0] 0)
ret = TPoseCounts[0]--;
}
else if (index == 3)
{
if (TPoseCounts[1] 0)
ret = TPoseCounts[1]--;
}
return ret;
}
//返回接收到的字符串
public string GetRecvStr()
{
string returnStr="";
//加锁防止字符串被改
if (queueClient1.Count 0)
{
lock (/*thisLock*/queueClient1) {
//returnStr=recvStr;
returnStr = queueClient1.Dequeue ();
}
}
return returnStr;
}
//返回接收到的字符串
public void setRecvStr()
{
//加锁防止字符串被改
lock(thisLock)
{
recvStr = null;
}
}
//返回接收到的字符串
public string GetRecvStr2()
{
string returnStr="";
if (queueClient2.Count 0)
{
lock (/*thisLock*/queueClient2) {
//returnStr=recvStr;
returnStr = queueClient2.Dequeue ();
}
}
return returnStr;
}
//返回接收到的字符串
public void setRecvStr2()
{
//加锁防止字符串被改
lock(thisLock)
{
recvStr2 = null;
}
}
//连接关闭
public void SocketQuit()
{
//关闭线程
if(connectThread!=null)
{
connectThread.Interrupt();
connectThread.Abort();
}
if(connectThread2!=null)
{
connectThread2.Interrupt();
connectThread2.Abort();
}
//最后关闭socket
if(socket!=null)
socket.Close();
//最后关闭socket
if(socket2!=null)
socket2.Close();
print("disconnect");
}
}
客户端代码如下:
using UnityEngine;
using System.Collections;
//引入库
using System.Net;
using System.Net.Sockets;
using System.Text;
using System.Threading;
using System.Xml;
//客户端
public class UdpHelpHandler : MonoBehaviour {
//以下默认都是私有的成员
Socket socket; //目标socket
EndPoint serverEnd; //服务端
IPEndPoint ipEnd; //服务端端口
string recvStr; //接收的字符串
string sendStr; //发送的字符串
byte[] recvData=new byte[1024]; //接收的数据,必须为字节
byte[] sendData=new byte[1024]; //发送的数据,必须为字节
int recvLen; //接收的数据长度
Thread connectThread; //连接线程
public bool isClient =true;
//初始化
public void InitSocket(string ipHostString,int port)
{
//定义连接的服务器ip和端口,可以是本机ip,局域网,互联网
ipEnd=new IPEndPoint(IPAddress.Parse(ipHostString),port);
//定义套接字类型,在主线程中定义
socket=new Socket(AddressFamily.InterNetwork,SocketType.Dgram,ProtocolType.Udp);
//定义服务端
IPEndPoint sender=new IPEndPoint(IPAddress.Any,0);
serverEnd=(EndPoint)sender;
print("waiting for sending UDP dgram....");
//建立初始连接,这句非常重要,第一次连接初始化了serverEnd后面才能收到消息
//开启一个线程连接,必须的,否则主线程卡死
connectThread=new Thread(new ThreadStart(SocketReceive));
connectThread.Start();
}
public void SocketSend(string sendStr)
{
//清空发送缓存
sendData=new byte[1024];
//数据类型转换
sendData=Encoding.ASCII.GetBytes(sendStr);
//发送给指定服务端
socket.SendTo(sendData,sendData.Length,SocketFlags.None,ipEnd);
}
//服务器接收
void SocketReceive()
{
//进入接收循环
while(true)
{
// print("recv thread");
//对data清零
recvData=new byte[1024];
//获取客户端,获取服务端端数据,用引用给服务端赋值,实际上服务端已经定义好并不需要赋值
recvLen=socket.ReceiveFrom(recvData,ref serverEnd);
// print("message from: "+serverEnd.ToString()); //打印服务端信息
//输出接收到的数据
recvStr=Encoding.ASCII.GetString(recvData,0,recvLen);
// print(recvStr);
}
}
//连接关闭
public void SocketQuit()
{
//关闭线程
if(connectThread!=null)
{
connectThread.Interrupt();
connectThread.Abort();
}
//最后关闭socket
if(socket!=null)
socket.Close();
}
}
文章知识点与官方知识档案匹配
网络技能树首页概览
21577 人正在系统学习中
点击阅读全文
打开CSDN,阅读体验更佳
QT多线程,使用串口接收数据通过UDP端口进行数据转发_是小峰呀的博客-CS...
ui(newUi::Widget){ui-setupUi(this);socket=newQUdpSocket();localThread=newmyThread();timer=newQTimer();socket-bind(3080);//删除注释后,是由按钮控制数据发送,此时需要将带定时器的connet注释。
UDP数据通信,使用一个DatagramSocket实现向多个地址发送数据和接收各个...
往不同的服务器发送数据,只需要启动多个线程,调用上面的方法,替换地址和端口即可 //connect方法的意思是将socket与指定地址绑定,绑定成功后只能往该地址发送数据。并不是建立连接,因为udp是面向非连接的 mSocket.connect(address, hostPort...
c#向指定端口发送数据,监听指定端口
c#向指定端口发送数据,监听指定端口,使用端口监听获取数据信息,向指定端口发送需要的数据
最新发布 C# UDP发送和接收数据类
C# UDP发送和接收数据类
继续访问
UDP端口传递接收数据_wei395107171的博客
UDP端口传递接收数据 package com.udp.test; import java.io.BufferedReader; import java.io.IOException; import java.io.InputStreamReader; import java.net.DatagramPacket; import java.net.DatagramSocket;...
...解决端口复用的问题)_酷侠一剑绝ggh的博客_udp端口复用
UDP组播通信(解决端口复用的问题) 最近在写一个组播通信的功能,结果发现接受同一台电脑上只能运行一个接收端,如果运行两个时,第二个运行的程序不能收到数据。查找原因是因为没有设置端口数据复用的功能(setsockpot),setsockpot的调用...
NIO之UDP监听多个端口获取请求信息
最近需要继承一个udp服务,需求是这样的,服务端接收消息,并且支持多个udp端口。 例如: 客户端:port 11112 port 11113 port 11114 服务端:要可以同时监听这三个端口,接收发送的报文。 Select监听端口,然后获取请求数据 附代码 @Override public void run(String... args) throws Exception {...
继续访问
UDP客户端实现在不同端口上发送和接收数据
普通udp通信,客户端在发送完数据后,只需要在相同socket上,recvfrom即可 服务端给的回应,可以是同一端口,也可以是不同端口,客户端在接收时,需要指点一个本地端口进行接收,此端口也可以用bind和创建的socket绑定。 但是bind必须是在通过这个socket发送数据前绑定,在发送数据后再bind会失败。 下面给出代码: #define SEND_PORT 8000
继续访问
发送方 获取 绑定 端口 linux c,多播报文的发送和接收
1实验目的掌握多播的原理及如何进行多播报文的发送和接受2注意事项需包括ws2tcpip.h文件发送者和所有接受者在同一网内不考虑TTL值,回环状态通过setsockopt( )函数设置选项来实现多播数据的发送和接收3试验流程3.1多播数据发送端流程l创建一个数据报套接口l设置多播地址(例:239.192.1.2)和端口号(例:12345)l调用setsockopt( )函数设置发送的数据报本地接口...
继续访问
网络编程之 Udp接收数据
udp接收数据,网络调试助手担任发送方,但发送时需要对方的也就是虚拟机的ip 和端口,ip可以通过config获取,那么如何让一个程序拥有一个固定端口呢? 创建套接字的时候是没有端口号的,好比买了手机没有手机号,别...
继续访问
C语言实现UDP服务器,客户端
服务器 #includestdio.h #include "unistd.h" #include "sys/socket.h" #include "netinet/in.h" #include "arpa/inet.h" #include "string.h" #include "stdlib.h" #define IP "127.0.0.1" #define PORT 8888 int main() { int fb=0,len=0; char buf[512]=
继续访问
c udp服务器端一对多持续接收消息,C - 使用select在多个端口上侦听的简单ipv6 udp服务器。从一个端口接收消息,而不是另一个...
#include #include #include #include #include int max(int socket_handle[]);int main(void){int max_clients_allowed = 2;int socket_handle[max_clients_allowed];int client_handle[max_clients_allowed];st...
继续访问
C# 简单的UDP服务器,实现异步接收UDP消息
C# 异步接收UDP消息 源代码 主要方法 async Task ListenForUdp(int port, ActionUdpReceiveResult receivedHandle) { using (var udpClient = new UdpClient(port)) { while (true) { try { receivedHandle(await
继续访问
UDP数据通信,使用一个DatagramSocket实现向多个地址发送数据和接收各个地址的数据返回
有时候需要一个客户端向多个地址发送数据并接收返回的需求 1、创建DatagramSocket DatagramSocket 有多个构造方法 DatagramSocket():创建一个DatagramSocket实例,并将该对象绑定到本机默认IP地址、本机所有可用端口中随机选择的某个端口。 DatagramSocket(int prot):创建一个DatagramSocket实例,并将该对象绑定到本机默认IP地址、指定端口。 DatagramSocket(int port, InetAddre.
继续访问
Python知识点——TCP和UDP的区别
相同点 UDP协议和TCP协议都是传输层协议。 TCP(Transmission Control Protocol,传输控制协议)提供的是面向连接,可靠的字节流服务。即客户和服务器交换数据前,必须现在双方之间建立一个TCP连接,之后才能传输数据。并且提供超时重发,丢弃重复数据,检验数据,流量控制等功能,保证数据能从一端传到另一端。 UDP(User Data Protocol,用户数据报协议)是一个简单的面向数据报的运输层协议。它不提供可靠性,只是把应用程序传给IP层的数据报发送出去,但是不能保证它们能到达
继续访问
UDP多线程同时建立多个通信端口
1.需要注意的是:::bind(serSocket, (sockaddr*)serAddr, sizeof(serAddr)) == SOCKET_ERROR) ,bind()函数前必须添加::,否则,在使用thread头文件后,使用了using namespace std的情况下,会被默认成std::bind,导致编译失败 (1)server #includeWinS...
继续访问
C#winform UDP通信 发送和接收信息
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;
继续访问
udp多线程 java_多线程以从多个UDP客户端接收数据
我想从不同的客户端接收数据(客户端数量是固定的,比如10),并且每个客户端在5个不同的预定义端口上发送数据,这些端口不会改变 . (例如,客户端1端口5000,5001,5002等) . 所有客户端都可以同时发送数据 . (以上都是固定的)在TCP中说,我可以为我们接受的每个连接创建多个线程,如下所示 . UDP is connectionless,So how can we create ...
继续访问
不同端口间的信息交换-使用udp协议
本文主要内容: 1.套接字(socket)简介; 2.udp简介; 3.udp发送数据及接收数据; 4.模拟qq聊天。 1.套接字(socket)简介 本地可以通过进程PID来唯一标识一个进程,但在网络中这是行不通的。ip地址可以唯一标识网络中的主机,传输层的“协议+端口号”可以唯一标识主机...
继续访问
c语言udp监听多个端口号,多个UDP监听同一个端口
测试结果:客户端的数据总是发给最后一个打开的服务器服务器代码:socket()-setsockopt()-bind()-recvfrom()/sendto()1 #include 2 #include 3 #include 4 #include 5 #include 6 #include 7 #include 8 #include 91011 int main(int ar...
继续访问
udp接收多个端口的数据
在windows下用C语言如何实现socket网络编程,需要用到哪些头文件或者库?
需要用到的头文件包含:
#include winsock2.h
#include windows.h
与Linux环境下socket编程相比,windows环境多了一个步骤:启动或者初始化winsock库
Winsock,一种标准API,一种网络编程接口,用于两个或多个应用程序(或进程)之间通过网络进行数据通信。具有两个版本:
Winsock 1:
Windows CE平台支持。
头文件:WinSock.h
库:wsock32.lib
Winsock 2:
部分平台如Windows CE貌似不支持。通过前缀WSA可以区别于Winsock 1版本。个别函数如WSAStartup、WSACleanup、WSARecvEx、WSAGetLastError都属于Winsock 1.1规范的函数;
头文件:WinSock2.h
库:ws2_32.lib
mswsock.h用于编程扩展,使用时必须链接mswsock.dll
扩展资料
winsock库的加载与卸载:
加载:int WSAStartup(WORD wVersionRequested, LPWSADATA lpWSAData);
加载成功,返回值为0。
WORD wVersionRequested:加载的winsock版本,使用宏MAKEWORD(x, y),x表示高字节,y表示低字节。然而使用时MAKEWORD(2, 2)。高字节与低字节相同~~
LPWSADATA lpWSAData:WSADATA结构的指针,传入参数后,系统帮助我们填充版本信息。有兴趣的可以看看结构体内容,不过基本用不着。
卸载:int WSACleanup(void);比起加载,卸载的函数真是轻松愉快。
用c语言socket编程服务器和客户端能相互传文件,请问怎样在服务器端设置帐号和密码,在下载时能显示进度条
1、可以在client端登入时write(发送)帐号和密码给server端,当server端接受到内容时判断是否是你预设的帐号密码,是则允许下载,否则关闭其socket。
2、是要客户端看到进度条? 这样就要要求在下载文件时server端要先发这个文件的大小给client端,client端就可以通过这个大小和接受到的字节数比较后打印进度条(printf("#");).
文件大小可用int stat(const char *restrict path, struct stat *restrict buf);函数获取。
C语言 Socket 编程中 ipv4 和 ipv6 可以相互连接么
在windows下用C语言如何实现socket网络编程,需要用到以下头文件和库:头文件 winsock2.h,静态库文件 Ws2_32.lib动态DLL文件 Ws2_32.dll写一个UDP发送程序的步骤如下:1. 用WSAStartup函数初始化Socket环境;2. 用socket函数创建一个套接字;3. 用setsockopt函数设置套接字的属性,例如设置为广播类型;很多时候该步骤可以省略;4. 创建一个sockaddr_in,并指定其IP地址和端口号;5. 用sendto函数向指定地址发送数据,这里的目标地址就是广播地址;注意这里不需要绑定,即使绑定了,其地址也会被sendto中的参数覆盖;若使用send函数则会出错,因为send是面向连接的,而UDP是非连接的,只能使用sendto发送数据;6. 用closesocket函数关闭套接字;7. 用WSACleanup函数关闭Socket环境。与之类似,一个UDP接收程序的步骤如下,注意接收方一定要bind套接字:1. 用WSAStartup函数初始化Socket环境;2. 用socket函数创建一个套接字;3. 用setsockopt函数设置套接字的属性,例如设置为广播类型;4. 创建一个sockaddr_in,并指定其IP地址和端口号;5. 用bind函数将套接字与接收的地址绑定起来,然后调用recvfrom函数或者recv接收数据; 注意这里一定要绑定,因为接收报文的套接字必须在网络上有一个绑定的名称才能保证正确接收数据;6. 用closesocket函数关闭套接字;7. 用WSACleanup函数关闭Socket环境。参考资料地址:6161217
c#网络编程UDP例子
using?System;?
using?System.Net;?
using?System.Net.Sockets;?
using?System.Text;?
using?System.Threading;?
using?System.Windows.Forms;?
?namespace?UDPClient?
{?
????public?partial?class?frmUdp?:?Form?
????{?
????????private?UdpClient?sendUdpClient;?
????????private?UdpClient?receiveUpdClient;?
????????public?frmUdp()?
????????{?
????????????InitializeComponent();?
????????????IPAddress[]?ips?=?Dns.GetHostAddresses("");?
????????????tbxlocalip.Text?=?ips[2].ToString();?
????????????int?port?=?51883;?
????????????tbxlocalPort.Text?=?port.ToString();?
????????????tbxSendtoIp.Text?=?ips[2].ToString();?
????????????tbxSendtoport.Text?=?port.ToString();?
????????}?
?
????????//?接受消息?
????????private?void?btnReceive_Click(object?sender,?EventArgs?e)?
????????{?
????????????//?创建接收套接字?
????????????IPAddress?localIp?=?IPAddress.Parse(tbxlocalip.Text);?
????????????IPEndPoint?localIpEndPoint?=?new?IPEndPoint(localIp,?int.Parse(tbxlocalPort.Text));?
????????????receiveUpdClient?=?new?UdpClient(localIpEndPoint);?
?
?
????????????Thread?receiveThread?=?new?Thread(ReceiveMessage);?
????????????receiveThread.Start();?
????????}?
?
????????//?接收消息方法?
????????private?void?ReceiveMessage()?
????????{?
????????????IPEndPoint?remoteIpEndPoint?=?new?IPEndPoint(IPAddress.Any,?0);?
????????????while?(true)?
????????????{?
????????????????try?
????????????????{?
????????????????????//?关闭receiveUdpClient时此时会产生异常?
????????????????????byte[]?receiveBytes?=?receiveUpdClient.Receive(ref?remoteIpEndPoint);?
?
????????????????????string?message?=?Encoding.Unicode.GetString(receiveBytes);?
?
????????????????????//?显示消息内容?
????????????????????ShowMessageforView(lstbxMessageView,?string.Format("{0}[{1}]",?remoteIpEndPoint,?message));?
????????????????}?
????????????????catch?
????????????????{?
????????????????????break;?
????????????????}?
????????????}?
????????}?
?
????????//?利用委托回调机制实现界面上消息内容显示?
????????delegate?void?ShowMessageforViewCallBack(ListBox?listbox,?string?text);?
????????private?void?ShowMessageforView(ListBox?listbox,?string?text)?
????????{?
????????????if?(listbox.InvokeRequired)?
????????????{?
????????????????ShowMessageforViewCallBack?showMessageforViewCallback?=?ShowMessageforView;?
????????????????listbox.Invoke(showMessageforViewCallback,?new?object[]?{?listbox,?text?});?
????????????}?
????????????else?
????????????{?
????????????????lstbxMessageView.Items.Add(text);?
????????????????lstbxMessageView.SelectedIndex?=?lstbxMessageView.Items.Count?-?1;?
????????????????lstbxMessageView.ClearSelected();?
????????????}?
????????}?
????????private?void?btnSend_Click(object?sender,?EventArgs?e)?
????????{?
????????????if?(tbxMessageSend.Text?==?string.Empty)?
????????????{?
????????????????MessageBox.Show("发送内容不能为空","提示");?
????????????????return;?
????????????}?
?
????????????//?选择发送模式?
????????????if?(chkbxAnonymous.Checked?==?true)?
????????????{?
????????????????//?匿名模式(套接字绑定的端口由系统随机分配)?
????????????????sendUdpClient?=?new?UdpClient(0);?
????????????}?
????????????else?
????????????{?
????????????????//?实名模式(套接字绑定到本地指定的端口)?
????????????????IPAddress?localIp?=?IPAddress.Parse(tbxlocalip.Text);?
????????????????IPEndPoint?localIpEndPoint?=?new?IPEndPoint(localIp,?int.Parse(tbxlocalPort.Text));?
????????????????sendUdpClient?=?new?UdpClient(localIpEndPoint);?
????????????}?
?
????????????Thread?sendThread?=?new?Thread(SendMessage);?
????????????sendThread.Start(tbxMessageSend.Text);?
????????}?
?
????????//?发送消息方法?
????????private?void?SendMessage(object?obj)?
????????{?
????????????string?message?=?(string)obj;?
????????????byte[]?sendbytes?=?Encoding.Unicode.GetBytes(message);?
????????????IPAddress?remoteIp?=?IPAddress.Parse(tbxSendtoIp.Text);?
????????????IPEndPoint?remoteIpEndPoint?=?new?IPEndPoint(remoteIp,?int.Parse(tbxSendtoport.Text));?
????????????sendUdpClient.Send(sendbytes,?sendbytes.Length,?remoteIpEndPoint);?
???????????
????????????sendUdpClient.Close();?
????????????
????????????//?清空发送消息框?
????????????ResetMessageText(tbxMessageSend);?
????????}?
?
????????//?采用了回调机制?
????????//?使用委托实现跨线程界面的操作方式?
????????delegate?void?ResetMessageCallback(TextBox?textbox);?
????????private?void?ResetMessageText(TextBox?textbox)?
????????{?
????????????//?Control.InvokeRequired属性代表?
????????????//?如果空间的处理与调用线程在不同线程上创建的,则为true,否则为false?
????????????if?(textbox.InvokeRequired)?
????????????{?
????????????????ResetMessageCallback?resetMessagecallback?=?ResetMessageText;?
????????????????textbox.Invoke(resetMessagecallback,?new?object[]?{?textbox?});?
????????????}?
????????????else?
????????????{?
????????????????textbox.Clear();?
????????????????textbox.Focus();?
????????????}?
????????}?
?
????????//?停止接收?
????????private?void?btnStop_Click(object?sender,?EventArgs?e)?
????????{?
????????????receiveUpdClient.Close();?
????????}?
?
????????//?清空接受消息框?
????????private?void?btnClear_Click(object?sender,?EventArgs?e)?
????????{?
????????????this.lstbxMessageView.Items.Clear();?
????????}?
????}?
}