udp緩存
❶ windows下怎麼修改UDP緩存
要不然你就用win32api重寫一遍
要不然你就去裝一個cygwin來編譯（比較推薦這個選擇
否則這一類的代碼你只能在linux環境下使用了（考慮下用虛擬機吧……
❷ 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組成的數據緩沖區
❸ udp Socket 發送緩沖區 最大可以為多大
internet上的標准mtu值為576位元組,所以我建議在進行internet的udp編程時.最好將udp的數據長度控制項在548位元組(576-8-20)以內.
ipv4協議規定ip層的最小重組緩沖區大小為576！所以，建議udp包不要超過這個大小，而不是因為internet的標准mtu是576！
❹ 求助如何清空udpclient發送的緩存區
通過Socket 發送接收消息遇到個問題C# codeSocket newSocket = socket.Accept();newSocket.Receive(messages);獲取消息沒問題 但是總有緩存區無法清空的問題比如說我先發一句: 我是中國人服務端能正確接收到這句消息: 我是中國人這邊再發送一個...
❺ 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 生效
❻ 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個拿出來用，就是准確的數據。
❼ tcp和udp的特點和區別
TCP協議的主要特點
（1）TCP是面向連接的運輸層協議；
（2）每一條TCP連接只能有兩個端點（即兩個套接字），只能是點對點的；
（3）TCP提供可靠的傳輸服務。傳送的數據無差錯、不丟失、不重復、按序到達；
（4）TCP提供全雙工通信。允許通信雙方的應用進程在任何時候都可以發送數據，因為兩端都設有發送緩存和接受緩存；
（5）面向位元組流。雖然應用程序與TCP交互是一次一個大小不等的數據塊，但TCP把這些數據看成一連串無結構的位元組流，它不保證接收方收到的數據塊和發送方發送的數據塊具有對應大小關系，例如，發送方應用程序交給發送方的TCP10個數據塊，但就受訪的TCP可能只用了4個數據塊久保收到的位元組流交付給上層的應用程序，但位元組流完全一樣。
UDP協議特點
（1）UDP是無連接的傳輸層協議；
（2）UDP使用盡最大努力交付，不保證可靠交付；
（3）UDP是面向報文的，對應用層交下來的報文，不合並，不拆分，保留原報文的邊界；
（4）UDP沒有擁塞控制，因此即使網路出現擁塞也不會降低發送速率；
（5）UDP支持一對一一對多多對多的交互通信；
（6）UDP的首部開銷小，只有8位元組。
TCP和UDP的區別
(1)TCP是可靠傳輸,UDP是不可靠傳輸;
(2)TCP面向連接,UDP無連接;
(3)TCP傳輸數據有序,UDP不保證數據的有序性;
(4)TCP不保存數據邊界,UDP保留數據邊界;
(5)TCP傳輸速度相對UDP較慢;
(6)TCP有流量控制和擁塞控制,UDP沒有;
(7)TCP是重量級協議,UDP是輕量級協議;
(8)TCP首部較長20位元組,UDP首部較短8位元組;
(7)udp緩存擴展閱讀：
TCP的可靠性原理
可靠傳輸有如下兩個特點:
a.傳輸信道無差錯,保證傳輸數據正確;
b.不管發送方以多快的速度發送數據,接收方總是來得及處理收到的數據;
（1）首先，採用三次握手來建立TCP連接，四次握手來釋放TCP連接，從而保證建立的傳輸信道是可靠的。
（2）其次，TCP採用了連續ARQ協議（回退N，Go-back-N；超時自動重傳）來保證數據傳輸的正確性，使用滑動窗口協議來保證接方能夠及時處理所接收到的數據，進行流量控制。
（3）最後，TCP使用慢開始、擁塞避免、快重傳和快恢復來進行擁塞控制，避免網路擁塞。
基於TCP和UDP的常用協議
HTTP、HTTPS、FTP、TELNET、SMTP(簡單郵件傳輸協議)協議基於可靠的TCP協議。TFTP、DNS、DHCP、TFTP、SNMP(簡單網路管理協議)、RIP基於不可靠的UDP協議
常見協議的埠號
FTP的20、21埠，21埠用來偵聽用戶的連接請求，而20埠用來傳送用戶的文件數據。
TELNET 23
SMTP25
DNS53
TFTP 69
HTTP 80
SNMP的161、162埠。SNMP的161埠用於SNMP管理進程獲取SNMP代理的數據，而162埠用於SNMP代理主動向SNMP管理進程發送數據
❽ 請教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，由內核的宏決定
❾ ehcache rmi 的udp方式同步緩存，他的廣播地址怎麼確認
Ehcache緩存同步有幾種方式：（1）RMI （2）Terrocotta （3）JMS （4）JGroups
先介紹下，利用RMI進行緩存同步。
測試類1：在sampleDistributedCache2緩存中查找是否存在ehcache鍵，如果沒找到，則列印NotFound；如果找到了，則列印相應值
[java] view plain
package my.test.ehcache1;
import java.io.InputStream;
import java.lang.management.ManagementFactory;
import javax.management.MBeanServer;
import net.sf.ehcache.Cache;
import net.sf.ehcache.CacheManager;
import net.sf.ehcache.Element;
import net.sf.ehcache.management.ManagementService;
public class EHCacheTest {
public static void main(String[] args) {
InputStream is = EHCacheTest.class
.getResourceAsStream("/my/test/ehcache1/ehcache.xml");
//讀入配置
CacheManager cacheManager = new CacheManager(is);
//列印初始緩存
String[] cacheNames = cacheManager.getCacheNames();
printNames(cacheNames);
//移除緩存
cacheManager.removeCache("sampleDistributedCache1");
cacheNames = cacheManager.getCacheNames();
printNames(cacheNames);
//新建緩存
Cache cache = new Cache("Test1", 100, true, false, 10, 10);
cacheManager.addCache(cache);
cacheNames = cacheManager.getCacheNames();
printNames(cacheNames);
cache.put(new Element("test1", "value1"));
//得到緩存並插入值（這里監聽器被調用）
cache = cacheManager.getCache("sampleCache3");
for (int i = 0; i < 20; i++) {
cache.put(new Element("key" + i, "value" + i));
}
cache.get("key10");
// distributed -- rmi同步
cache = cacheManager.getCache("sampleDistributedCache2");
for (int i = 0; i < 100; i++) {
cache.put(new Element("key" + i , "value" + i));
}
//注冊被管理的Bean
// JMX -- jconsole(MBeanServer)
MBeanServer mBeanServer = ManagementFactory.getPlatformMBeanServer();
ManagementService.registerMBeans(cacheManager, mBeanServer, true, true,
true, true);
for (int i = 0; i < 10; i++) {
Element temp = cache.get("ehcache");
if (temp != null) {
System.out.println(temp.getValue());
} else {
System.out.println("NotFound");
}
try {
Thread.sleep(10000);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
// distributed cache using RMI
// 1.Peer Discovery --
// 2.CacheManager --
// 3.cache replication -- cacheEventListenerFactory
// 4.Bootstrap -- 啟動後同步
}
private static void printNames(String[] names) {
System.out.println("=======================");
for (int i = 0; i < names.length; i++) {
System.out.println(names[i]);
}
}
}
配置文件1：將官方樣例文件中相應位置替換即可
（1）其他JVM提供緩存的rmiUrl地址
[java] view plain
<
class="net.sf.ehcache.distribution."
properties="peerDiscovery=manual,
rmiUrls=//localhost:40002/sampleDistributedCache2"
propertySeparator=","
/>
（2）監聽來自於其他復制節點消息的本JVM的host,port
[xhtml] view plain
<
class="net.sf.ehcache.distribution."
properties="hostName=localhost, port=40001, socketTimeoutMillis=2000"
/>
（3）配置復制選項，啟動時同步等
[xhtml] view plain
<cache name="sampleDistributedCache2"
maxElementsInMemory="10"
eternal="false"
timeToIdleSeconds="100"
timeToLiveSeconds="100"
overflowToDisk="false">
<cacheEventListenerFactory
class="net.sf.ehcache.distribution.RMICacheReplicatorFactory"
properties="replicateAsynchronously=true, replicatePuts=true,
replicatePutsViaCopy=true, replicateUpdates=true,
replicateUpdatesViaCopy=true, replicateRemovals=true,
=200"/>
<bootstrapCacheLoaderFactory
class="net.sf.ehcache.distribution."/>
</cache>
測試類2：向sampleDistributedCache2緩存中添加ehcache鍵
[java] view plain
package my.test.ehcache2;
import java.io.InputStream;
import java.lang.management.ManagementFactory;
import javax.management.MBeanServer;
import net.sf.ehcache.Cache;
import net.sf.ehcache.CacheManager;
import net.sf.ehcache.Element;
import net.sf.ehcache.Statistics;
import net.sf.ehcache.management.ManagementService;
import net.sf.ehcache.statistics.LiveCacheStatistics;
public class EHCacheTest {
public static void main(String[] args) {
try {
Thread.sleep(3 * 1000);
} catch (InterruptedException e) {
e.printStackTrace();
}
//讀入配置
InputStream is = EHCacheTest.class.getResourceAsStream("/my/test/ehcache2/ehcache.xml");
CacheManager cacheManager = new CacheManager(is);
//列印初始緩存
String[] cacheNames = cacheManager.getCacheNames();
printNames(cacheNames);
//注冊管理Bean
MBeanServer mBeanServer = ManagementFactory.getPlatformMBeanServer();
ManagementService.registerMBeans(cacheManager, mBeanServer, true, true, true, true);
//distributed
Cache cache = cacheManager.getCache("sampleDistributedCache2");
printCache(cache);
//添加值後另一個虛擬機的緩存通過RMI會同步緩存，並讀到這個值
cache.put(new Element("ehcache", "newaddvalue"));
}
private static void printNames(String[] names) {
System.out.println("=======================");
for (int i = 0; i < names.length; i++) {
System.out.println(names[i]);
}
}
private static void printCache(Cache cache) {
int size = cache.getSize();
long memSize = cache.getMemoryStoreSize();
long diskSize = cache.getDiskStoreSize();
Statistics stat = cache.getStatistics();
LiveCacheStatistics liveStat = cache.getLiveCacheStatistics();
long hits = stat.getCacheHits();
long missed = stat.getCacheMisses();
long hitsOnDisk = stat.getOnDiskHits();
long liveHits = liveStat.getCacheHitCount();
long liveMissed = liveStat.getCacheMissCount();
StringBuilder sb = new StringBuilder();
sb.append("size=" + size + ";memsize=" + memSize);
sb.append(";diskSize=" + diskSize + ";hits=" + hits);
sb.append(";missed=" + missed + ";liveHits=" + liveHits);
sb.append(";liveMissed=" + liveMissed + ";hitsOnDisk=" + hitsOnDisk);
System.out.println(sb.toString());
}
}
配置文件：將官方樣例文件中相應位置替換即可
[xhtml] view plain
<
class="net.sf.ehcache.distribution."
properties="peerDiscovery=manual,
rmiUrls=//localhost:40001/sampleDistributedCache2"
propertySeparator=","
/>
[xhtml] view plain
<
class="net.sf.ehcache.distribution."
properties="hostName=localhost, port=40002, socketTimeoutMillis=2000"
/>
[xhtml] view plain
<cache name="sampleDistributedCache2"
maxElementsInMemory="10"
eternal="false"
timeToIdleSeconds="100"
timeToLiveSeconds="100"
overflowToDisk="false">
<cacheEventListenerFactory
class="net.sf.ehcache.distribution.RMICacheReplicatorFactory"
properties="replicateAsynchronously=true, replicatePuts=true,
replicatePutsViaCopy=true, replicateUpdates=true,
replicateUpdatesViaCopy=true, replicateRemovals=true,
=200"/>
<bootstrapCacheLoaderFactory
class="net.sf.ehcache.distribution."/>
</cache>
❿ 如何清空udp的接收緩沖區
實際上處理這種問題時應該這樣，客戶端和服務端都加上自己定義的報文，在報文中加個包頭包尾，這樣就可以避免這個問題了，當接收到數據後，放入緩沖區，然後一個一個數據包的取出來進行分析。