❶ 如何 监听,接收 所有UDP端口 数据
12端口就用12个线程去接收。 但处理都是一样的吧。
所以要有个事件 比如定义一个事件
public delegate void DataArrivalHandler(byte[] data);参数你定,或者(Stream s)之类,也可以是自定一个类(包含其它信息)继承EventArgs写个 (DataEventArgs e)
public event DataArrivalHandler OnDataArrived;
OnDataArrived+=()这里注册相应的方法,如果不同端口的处理不一样,就相应写不同的事件,当然也可以只定义一个方法,方法根据不同的端口处理。
while(true)
{
byte[] data = (获取)
这里获取数据后,直接调用
OnDataArrived(data)/OnDataArrived(stream)/OnDataArrived(new DataEventArgs (data,ip,port)之类,根据你定义的参数来。
}
而注册的方法里的具体实现,用委托异步调用. 方法体里执行
{
namedDelegate.beginEnvoke();
}
这样,数据处理就异步完成了。
避免数据丢失的话,做个保险。 把接收的数据放入定义的缓冲块里。 当接收的数据量到达一定程序后,取出部分处理,再加入新数据。
类似于TCP的的滑动窗口。 麻烦点,但实现了,效果会好的多。
--------------------------
为什么要用ThreadPool? 不便于控制状态。 当你的线程处理的业务非常单一时用它,这种情况需要不需额外的状态信息,比如就像你上面的每次有不同的byte[] data。
直接 new ThreadStart();
❷ java使用UDP 如果我定义了一个1024byte的缓存,而接收到的只有16个byte剩余的怎么处理
byte[] b = new byte[1024];
int len = 输入流.read(b)://从输入流中读取数据装填到数组b中,len保存的是读到的有效字节数
while( len != - 1 ){ //为-1表示没有数据可读
String str = new String(b, 0, len); //把装数字的数组中本次读到的数据new成string
或者
输出流.write( b, 0, len); //向输出流中写len个字节数据。剩下的你不用管它。
}
记住,len记录了每次读到的有效字节个数,如果接收的只有16个,那么你只用取16个拿出来用,就是准确的数据。
❸ 请教Linux关于UDP最大缓冲区设置
1. tcp 收发缓冲区默认值 [root@ ]# cat /proc/sys/net/ipv4/tcp_rmem 4096 87380 4161536 87380 :tcp接收缓冲区的默认值 [root@ ]# cat /proc/sys/net/ipv4/tcp_wmem 4096 16384 4161536 16384 : tcp 发送缓冲区的默认值 2. tcp 或udp收发缓冲区最大值 [root@ ]# cat /proc/sys/net/core/rmem_max 131071 131071:tcp 或 udp 接收缓冲区最大可设置值的一半。 也就是说调用 setsockopt(s, SOL_SOCKET, SO_RCVBUF, &rcv_size, &optlen); 时rcv_size 如果超过 131071,那么 getsockopt(s, SOL_SOCKET, SO_RCVBUF, &rcv_size, &optlen); 去到的值就等于 131071 * 2 = 262142 [root@ ]# cat /proc/sys/net/core/wmem_max 131071 131071:tcp 或 udp 发送缓冲区最大可设置值得一半。 跟上面同一个道理 3. udp收发缓冲区默认值 [root@ ]# cat /proc/sys/net/core/rmem_default 111616:udp接收缓冲区的默认值 [root@ ]# cat /proc/sys/net/core/wmem_default 111616 111616:udp发送缓冲区的默认值 4. tcp 或udp收发缓冲区最小值 tcp 或udp接收缓冲区的最小值为 256 bytes,由内核的宏决定; tcp 或udp发送缓冲区的最小值为 2048 bytes,由内核的宏决定
❹ linux下怎么设置udp接收缓存最大值
vi /etc/sysctl.conf
增加或修改 net.ipv4.udp_mem项
net.ipv4.udp_mem = min pressure max
再设一下 net.ipv4.udp_rmem_min
具体含义man udp 查看
完成后执行 sysctl -p 生效
❺ C# udp是什么意思啊,是干什么的啊
最普遍的介绍:
UDP 是User Datagram Protocol的简称, 中文名是用户数据包协议,是一种无连接的传输层协议,提供面向事务的简单不可靠信息传送服务。UDP是与TCP相对应的协议,它是面向非连接的协议,它不与对方连接,而直接把数据包发送过去。“面向非连接”就是正式通信前不必与对方建立连接,不管对方状态就直接发送。
特点是什么:
(1)UDP是一个无连接协议,传输数据之前,源端和终端不建立连接,当它想传送时就简单的抓取来自应用程序的数据,并尽可能快的把他扔到网络上。在发送端UDP传送的速度仅仅是受应用程序数据生成的速度、计算机能力和传输带宽限制;在接收端,UDP把每个消息段放在队列中,应用程序每次从队列中读取一个消息段。
(2)由于传输数据不建立连接,因此也就不需要维护连接状态,包括收发状态等,因此一台服务机可同时向多台客户机传输相同的信息。
(3)UDP信息包的标题很短,只有8个字节,相对于TCP的20个字节信息包的额外开销很小。
(4)吞吐量不受拥挤控制算法的调节,只受应用软件生成数据的速率、传输宽带、源端和终端主机性能的限制。
(5)UDP使用尽量最大努力交付,即不保证可靠交付,因此主机不需要维持复杂的链接状态表(该表中有许多参数)。
(6)UDP是面向报文的。发送方对应用程序交下来的报文,在添加首部后就向下交付个IP层。既不拆分,也不合并,而是保留这些报文的边界,因此,应用程序需要选择合适的报文大小。
举例说明应用场景:
一般用于实时视频通讯,例如QQ
实时音视频是可以而且应该用 UDP 的,一方面因为它常常涉及到网络穿透,另外一方面它不需要重传。——我需要实时的看到你的图像跟声音,至于中间丢一帧什么的完全不重要。而为了重传往往会造成延迟与不同步,考虑一下,某一帧因为重传,导致0.5秒以后才到,那么整个音视频就延迟了0.5秒。
考虑一下接收方看视频,如果使用 TCP 导致视频的中间延迟了0.5秒,只要我不按“快进”键,那么后续的视频全都会比发送方延迟0.5秒。这种延迟是累加的,随着持续丢帧,延迟会越来越大,达到数秒,甚至分钟级,这会严重影响实时音视频的用户体验。
因此“实时音视频聊天”功能通常都会使用 UDP 实现。
其它含义:
注:UDP比TCP更容易穿越路由器防火墙。
注:在互联网技术中,UDP常用在缓存读取,保存;用在监控或终端上报。
注:在选择使用协议的时候,选择UDP必须要谨慎。在网络质量令人十分不满意的环境下,UDP协议数据包丢失会比较严重。但是由于UDP的特性:它不属于连接型协议,因而具有资源消耗小,处理速度快的优点,所以通常音频、视频和普通数据在传送时使用UDP较多,因为它们即使偶尔丢失一两个数据包,也不会对接收结果产生太大影响。比如我们聊天用的ICQ和QQ就是使用的UDP协议。
❻ UDP中将struct skb_buff作为缓存区 具体如何使用
一. SKB_BUFF的基本概念
1. 一个完整的skb buff组成
(1) struct sk_buff--用于维护socket buffer状态和描述信息
(2) header data--独立于sk_buff结构体的数据缓冲区,用来存放报文分组,使各层协议的header存储在连续的空间中,以方便协议栈对其操作
(3) struct skb_shared_info --作为header data的补充,用于存储ip分片,其中sk_buff *frag_list是一系列子skbuff链表,而frag[]是由一组单独的page组成的数据缓冲区
❼ java 怎么用UDP实时接收数据
我自己写的代码:
importjava.io.IOException;
importjava.net.DatagramPacket;
importjava.net.DatagramSocket;
importjava.net.InetAddress;
importjava.net.SocketException;
importjava.net.UnknownHostException;
publicclassUdpRecvDemo
{
publicstaticvoidmain(String[]args)throwsIOException
{
Recv();
}
publicstaticvoidRecv()throwsIOException
{
System.out.println("接受开始......");
DatagramSocketds=newDatagramSocket(3388);
while(true)
{
byte[]buf=newbyte[1024];
DatagramPacketdp=newDatagramPacket(buf,buf.length);
ds.receive(dp);
System.out.println(ds);
Stringip=dp.getAddress().getHostAddress();
intport=dp.getPort();
Stringtext=newString(dp.getData(),0,dp.getLength());
if(text.equals("exit"))
{
System.out.println(ip+"退出会话......");
break;
}
System.out.println(ip+":"+port+"===>me"+text);
}
ds.close();
}
}
❽ 怎么给每个 UDP SOCKET 设置一个接收缓冲区,MFC/C++
用clist<SOCKET ,&> .....
❾ 请教lwip udp数据接收缓存大小如何设置
在VB中利用UDP协议编写聊天程序UDP 协议是一种无连接协议,两台计算机之间的数据传输类似于传递邮件:消息从一台计算机发送到另一台计算机,但是两者之间没有明确的连接。 由于UDP 协议不需要显式的连接,就需要在两个Winsock控件中间发送数据