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

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

UDP の理論については詳しく説明しません。UDP に関する HelloWorld プログラムを紹介します。コードはわかりやすいので、初心者の皆さんのお役に立てれば幸いです。

もちろん、実際のところ、私はこの分野でまだ始めたばかりです!

まず、サーバー コードを記述します。サーバーは、アクセスをリッスンするためにローカル IP とポートをバインドします。

パッケージ 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);
	}
}

実行後、サーバーが正常に実行され、プログラムがポートのリッスンを開始し、受信方法がブロックされ、アクセスがある場合にのみ続行されるというメッセージが表示されます。

アクセスするためのクライアントを作成すると、インターネット上の例はすべて DatagramSocket オブジェクトを直接作成しますが、実際にはどのポートを使用しているかはわかりません。ここでは、作成時にバインドするポートを指定します。実際、非常に簡単です。オブジェクトを初期化するときにポート パラメーターを渡すだけです。

ここでクライアントにアクセスすると、クライアントは IP とポートを印刷します。

クライアントコードを見てみましょう:

パッケージ 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());		
		データを返します。
	}
}

プログラムを直接実行して効果を確認してください。

以上がこの記事の全内容です。皆様の勉強のお役に立てれば幸いです。また、123WORDPRESS.COM を応援していただければ幸いです。

以下もご興味があるかもしれません:
  • Python UDPプログラミングの詳細な説明
  • TCP/UDP プロトコルを使用した C# サンプル コード
  • UDP チャット プログラムに基づく Java ネットワークの例の分析
  • Java シミュレーション UDP 通信サンプル コード
  • PythonはUDPプログラム通信プロセス図を実装します
  • PythonはUDPプロトコルによるファイル転送を実装する
  • Java UDP 通信クライアントとサーバーの例の分析
  • UDP 接続オブジェクトの原理分析と使用例

<<:  生年月日を年齢に変換し、グループ化して人数を数えるMySQLの例

>>:  MySQL 並列レプリケーションの簡単な分析

推薦する

Docker ベースの Etcd 分散デプロイメントの方法と手順

1. 環境整備1.1 基本環境NTP設定: 省略 #時間の一貫性を確保するためにNTPサービスを設定...

コマンドを使用してMySQLデータベース(de1)を作成する方法

1. MYSQLに接続するフォーマット: mysql -h ホストアドレス -u ユーザー名 -p ...

SSH接続を介してXshellを使用したUbuntu 20.04で報告されたサービス問題の詳細な説明

1. 最近、Ubuntu の新しいバージョンをインストールしました。/etc/ssh/sshd_co...

ノードイベントループにおけるイベント実行の順序

目次イベントループブラウザ環境イベントループノード環境イベントループ6つのステージ(1)setTim...

Vue-pdfはPDFファイルのオンラインプレビューを実装します

序文ほとんどのプロジェクトでは、PDF ファイルのオンライン プレビューに遭遇するでしょう。このプロ...

CentOS に MySQL をインストールしてリモート アクセスを設定する方法

1. MySQLリポジトリソースをダウンロードする$ wget http://repo.mysql....

Linux システムをバックアップする docker コマンドの詳細な説明

tar バックアップ システム sudo tar cvpzf backup.tgz --exclud...

Dockerのデフォルトネットワークセグメントの正しい変更手順

背景同僚がセキュリティ プロジェクトに取り組んでおり、AWS サーバーに秘密兵器を展開する必要があり...

MySQLの一般的なメモリ不足による起動失敗に対する完璧な解決策

1. MySQLが正常に起動しない場合は、エラーログ/var/log/mysql/error.log...

SQLシリアル番号取得コード例

この記事は主にSQLシリアル番号取得コード例を紹介します。記事ではサンプルコードを詳細に紹介しており...

CentOS 7 で Apache (httpd) サービスをインストールおよびアンインストールする詳細な手順

アンインストールまず、次のコマンドを使用して、httpd サービスがインストールされているかどうか、...

Linux プログラムの実行中に動的ライブラリをロードできない場合の解決策

Linux でダイナミック ライブラリをロードできません次のような異常事態が発生した場合./test...

MySQL 5.7 zip アーカイブ バージョンのインストール チュートリアル

この記事では、MySQL 5.7 zipアーカイブ版のインストールチュートリアルを参考までに紹介しま...

Spring jdbc のデータベース操作オブジェクト モデルの詳細な例

Spring jdbc のデータベース操作オブジェクト モデルの詳細な例Spring Jdbc デー...

コードレイン効果を実現するjQueryプラグイン

この記事では、コードレイン特殊効果を実現するためのjQueryプラグインの具体的なコードを参考までに...