UDP シンプル サーバー クライアント コード例

パッケージ udp;

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

/**
 * UDP サービスクラス */
パブリッククラス UdpServerSocket {
	
	プライベートbyte[]バッファ = 新しいbyte[1024];
	プライベート静的 DatagramSocket ds = null;
	プライベート DatagramPacket パケット = null;
	プライベート InetSocketAddress socketAddress = null;
	
	/**
	 * テスト方法 */
	パブリック静的void main(String[] args)は例外をスローします{
		文字列 serverHost = "127.0.0.1";
		int サーバーポート = 3344;
		UdpServerSocket udpServerSocket = 新しい UdpServerSocket(serverHost,
				サーバーポート);
		（真）の間{
			udpServerSocket.receive();
			udpServerSocket.response("こんにちは、食事はしましたか?");
		}		
	}

	/**
	 * コンストラクター、ホストとポートをバインド */
	パブリック UdpServerSocket(String ホスト、int ポート) 例外をスローします {
		socketAddress = 新しいInetSocketAddress(ホスト、ポート);
		ds = 新しい DatagramSocket(ソケットアドレス);
		System.out.println("サーバーが起動しました!");
	}

	/**
	 * データパケットを受信します。このメソッドはスレッドをブロックします */
	パブリックファイナル文字列受信()はIOExceptionをスローします{
		パケット = 新しい DatagramPacket(バッファ、バッファ長);
		ds.receive(パケット);
		文字列情報 = 新しい文字列(packet.getData(), 0, packet.getLength());
		System.out.println("情報を受信: " + info);
		情報を返します。
	}

	/**
	 * 応答パケットを要求元に送信する */
	パブリック最終voidレスポンス(String info)はIOExceptionをスローします{
		System.out.println("クライアントアドレス: " + packet.getAddress().getHostAddress()
				+ ",ポート:" + packet.getPort());
		DatagramPacket dp = 新しいDatagramPacket(バッファ、バッファ長、パケット
				.getAddress()、パケット.getPort());
		dp.setData(info.getBytes());
		ds.send(dp);
	}
}

パッケージ udp;

java.io.* をインポートします。
java.net.* をインポートします。

/**
 * UDP クライアント プログラム。サーバーにデータを送信し、サーバーの応答情報を受信するために使用されます。*/
パブリッククラス UdpClientSocket {
	プライベートbyte[]バッファ = 新しいbyte[1024];

	プライベート静的 DatagramSocket ds = null;
	
	/**
	 * クライアントのパケット送信方法と応答情報の受信方法をテストします */
	パブリック静的void main(String[] args)は例外をスローします{
		UdpClientSocket クライアント = 新しい UdpClientSocket();
		文字列 serverHost = "127.0.0.1";
		int サーバーポート = 3344;
		client.send(serverHost, serverPort, ("こんにちは！").getBytes());
		バイト[] bt = client.receive();
		System.out.println("サーバー応答データ: " + new String(bt));
		// 接続を閉じる try {
			ds.close();
		} catch (例外例) {
			例:printStackTrace();
		}
	}

	/**
	 * コンストラクター、UDPクライアントの作成 */
	パブリック UdpClientSocket() は例外をスローします {
		ds = new DatagramSocket(8899); // クライアントとしてローカルポートにバインドする }
	
	/**
	 * 指定されたサーバーにデータ情報を送信します */
	パブリックファイナルボイド送信(ファイナルストリングホスト、ファイナルイントポート、
			最終byte[]バイト)はIOExceptionをスローします{
		DatagramPacket dp = 新しい DatagramPacket(bytes, bytes.length, InetAddress.getByName(host), port);
		ds.send(dp);
	}

	/**
	 * 指定されたサーバーから送り返されたデータを受信します */
	パブリックファイナルバイト[]受信()
			例外をスローします {
		DatagramPacket dp = 新しい DatagramPacket(バッファ、バッファ長);
		ds.receive(dp);		
		byte[]データ = new byte[dp.getLength()];
		System.arraycopy(dp.getData(), 0, データ, 0, dp.getLength());		
		データを返します。
	}
}