public static void main(String[] args) throws IOException, InterruptedException {

		// 定义队列用于存储接收到的包 received packet queue
		final BlockingQueue<byte[]> queue = new LinkedBlockingQueue<>();

		// 通过 rxtx 获取设备的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;




		/* *********************************************************************************************************************** */

		// 开始读取包，读到的包将放入BlockingQueue队列中
		// 这个方法是立即返回的(无阻塞)
		// 非线程安全, 如用于多线程场景，请做好加锁同步
		// receive packet into the queue
		RxdUtil.register(ins, queue);


		/* *********************************************************************************************************************** */

    // 新开线程处理接收到的包
		// 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();


		/* *********************************************************************************************************************** */

		// 发送包，不保证对方一定接收到包，但如果接收到，则能保证包的数据完整性
   	 	// chksumlength: 校验和字节，可以设置为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);


	}