java 鏈路層封包協(xié)議, 實(shí)現(xiàn)數(shù)據(jù)包完整性校驗(yàn) 可用于無線模塊(紅外/zigbee/433Mhz)實(shí)現(xiàn)TCP/IP通信

說明

• 沒有重傳確認(rèn)功能, 發(fā)送不保證對方一定收到包，亦不保證順序。需要結(jié)合 tun/tap 才能實(shí)現(xiàn)TCP通信

• 如果收到包，則可保證包數(shù)據(jù)完整性(使用md5算法校驗(yàn)和)

• 配合 tun/tap 使用，可實(shí)現(xiàn)多終端全雙工通信, 建議MTU設(shè)置為256以下，惡劣環(huán)境下需設(shè)置更低的值

• 雖然433Mhz, 紅外功耗低，但傳輸速率也較低，因此不適合用來瀏覽互聯(lián)網(wǎng)，建議用在物聯(lián)網(wǎng)少量數(shù)據(jù)傳輸場景

user-program -> tun/tap -> rawip4j -> wireless(zigbee, 433Mhz, Infrared-ray) -> (THE AIR) -> wireless -> rawip4j -> tun/tap -> user-program

public?static?void?main(String[]?args)?throws?IOException,?InterruptedException?{
		
		//?定義隊(duì)列用于存儲接收到的包?received?packet?queue
		final?LinkedBlockingQueue?queue?=?new?LinkedBlockingQueue<>();
				
		//?通過?rxtx?獲取設(shè)備的InputStream?和?OutputStream
		//TODO?get?the?InputStream?&?OutputStream?from?SerialPort?devices
		//?you?can?use?librxtx-java?(aptitude?install?librxtx-java)
		//?or?http://mvnrepository.com/artifact/org.rxtx/rxtx?(untested)
		InputStream?ins?=?null;
		OutputStream?outs?=?null;
		
		
		

		/*?***********************************************************************************************************************?*/
		
		//?開始讀取包，讀到的包將放入隊(duì)列中，這個方法是永不返回的，因此要新開線程執(zhí)行
		//?start?a?thread?to?receive?packet?into?the?queue
		new?Thread(new?Runnable()?{
			
			@Override
			public?void?run()?{
				try?{
					RxdUtil.readloop(ins,?queue);
				}?catch?(IOException?|?InterruptedException?e)?{
					e.printStackTrace();
				}
			}
		}).start();
		
		
		/*?***********************************************************************************************************************?*/
		
????//?新開線程處理接收到的包
		//?start?a?received?packet?handler?thread
		new?Thread(new?Runnable()?{
			
			@Override
			public?void?run()?{
				while(true){
					try?{
						final?byte[]?data?=?queue.take();
						System.out.println("received?packet:?"?+?new?String(data));
					}?catch?(InterruptedException?e)?{
						e.printStackTrace();
					}
				}
			}
		}).start();
		
		
		/*?***********************************************************************************************************************?*/
		
		//?發(fā)送包，不保證對方一定接收到包，但如果接收到，則能保證包的數(shù)據(jù)完整性
???	?	//?chksumlength:?校驗(yàn)和字節(jié)，可以設(shè)置為2-16，越大越安全,?建議8
		//?send?a?data?packet
		//?chksumlength:?use?md5?to?checksum?a?packet,?the?value?can?be?2-16,?recommend?8
		new?PacketFrame((byte)8,?"hello,?rawip4j".getBytes()).write(outs);
		
		
		/*?***********************************************************************************************************************?*/
		
		
		TimeUnit.SECONDS.sleep(Long.MAX_VALUE);
		
		
	}

效果圖

433MHz模塊9600波特率, 距離20米，隔2墻1窗1門，ping丟包率5%, wget 600bytes/s

?