UDP 接続オブジェクトの原理分析と使用例

パッケージ udp; 
 
java.net.* をインポートします。 
 
/** 
 * @Description UDP クライアント プログラム。サーバーにデータを送信し、サーバーの応答情報を受信するために使用されます。* @author cuisuqiang 
 * @バージョン 1.0 
 * @since <a href="mailto:[email protected]" rel="external nofollow" >[email protected]</a> 
 */ 
パブリッククラス UdpClientSocket { 
  /** 
   * 接続オブジェクト */ 
  プライベート静的 DatagramSocket ds = null; 
  /** 
   * アドレスオブジェクト */ 
  プライベート静的SocketAddressアドレス = null; 
   
  /** 
   * クライアントのパケット送信方法と応答情報の受信方法をテストします*/ 
  パブリック静的void main(String[] args)は例外をスローします{ 
    初期化(); 
    while(true){ 
      UdpClientSocket.send(address,"こんにちは、親愛なる!".getBytes()); 
      UdpClientSocket を受信します。 
      試す { 
        スレッドをスリープ状態にします(3 * 1000); 
      } キャッチ (例外 e) { 
        e.printStackTrace(); 
      } 
    } 
  } 
   
  /** 
   * 接続とアドレスを初期化します */ 
  パブリック静的void init(){ 
    試す { 
      ds = new DatagramSocket(8899); // クライアントとしてローカルポートにバインド ds.setSoTimeout(2 * 1000); 
      アドレス = 新しい InetSocketAddress("127.0.0.1",3344); 
    } キャッチ (例外 e) { 
      e.printStackTrace(); 
    } 
  } 
   
  /** 
   * 指定されたサーバーにデータ情報を送信します */ 
  パブリック静的void送信(SocketAddressアドレス、byte[]バイト){ 
    試す { 
      DatagramPacket dp = 新しい DatagramPacket(バイト、バイト長、アドレス); 
      ds.send(dp); 
    } キャッチ (例外 e) { 
      e.printStackTrace(); 
    } 
  } 
 
  /** 
   * 指定されたサーバーから送り返されたデータを受信します*/ 
  パブリック静的void受信(){ 
    試す { 
      byte[] buffer = 新しいbyte[1024]; 
      DatagramPacket dp = 新しい DatagramPacket(バッファ、バッファ長); 
      ds.receive(dp);    
      byte[]データ = new byte[dp.getLength()]; 
      System.arraycopy(dp.getData(), 0, データ, 0, dp.getLength());  
      System.out.println("サーバー応答データ: " + new String(data)); 
    } キャッチ (例外 e) { 
      e.printStackTrace(); 
    } 
  } 
}

パッケージ udp;

java.net.DatagramPacket をインポートします。
java.net.DatagramSocket をインポートします。
java.net.InetSocketAddress をインポートします。
java.net.SocketAddress をインポートします。

/**
 * @UDP サービスクラスの説明 * @author cuisuqiang
 * @バージョン 1.0
 * @since [email protected]
 */
パブリッククラス UdpServerSocket {
	
	プライベート静的 DatagramSocket ds = null;
	プライベート静的SocketAddressアドレス = null;
	
	/**
	 * テスト方法 */
	パブリック静的void main(String[] args)は例外をスローします{
		初期化();
		System.out.println("---->サービスがリッスンを開始します!<----");
		（真）の間{
			UdpServerSocket.receive();
			UdpServerSocket.response(address,"こんにちは、食事はしましたか?");
		}		
	}
	
	パブリック静的void init(){
		試す {
			ds = 新しいデータグラムソケット(3344);
			ds.setSoTimeout(0);
			アドレス = 新しい InetSocketAddress("127.0.0.1",8899);
		} キャッチ (例外 e) {
			e.printStackTrace();
		}
	}

	/**
	 * データパケットを受信します。このメソッドはスレッドをブロックします */
	パブリック静的void受信() {
		試す {
			byte[] buffer = 新しいbyte[1024];
			DatagramPacket パケット = 新しい DatagramPacket(バッファ、バッファ長);
			ds.receive(パケット);
			文字列情報 = 新しい文字列(packet.getData(), 0, packet.getLength());
			System.out.println("情報を受信: " + info);
		} キャッチ (例外 e) {
			e.printStackTrace();
		}
	}

	/**
	 * 応答パケットを要求元に送信する */
	パブリック静的void応答(SocketAddressアドレス、文字列情報){
		試す {
			DatagramPacket dp = 新しい DatagramPacket(info.getBytes(), info.getBytes().length, address);
			dp.setData(info.getBytes());
			ds.send(dp);
		} キャッチ (例外 e) {
			e.printStackTrace();
		}		
	}
}