UDP DUP タイムアウト UPD ポート状態検出コード例

UDP DUP タイムアウト UPD ポート状態検出コード例

以前、単純な UDP サーバーとクライアントの例を書きましたが、その中で、自分自身をクライアントと見なすと、クライアントはデータを送信するために独自のポートを指定できると書きました。

ds.setSoTimeout(5000); はデータ収集のタイムアウトです。設定されていない場合は待機を意味します。これはテレビドラマの恋愛映画の待機時間よりも長く、結果は同じです。つまり、死ぬまで待ってから待機を停止します。ただし、このタイムアウト期間は、リクエストのタイムアウト期間と見なすことはできません。この概念に注意してください。このタイムアウト期間は、この期間中にネットワークからデータが取得されなかったことを示すためだけに使用され、データが取得されたとしても、それがあなたのものではない可能性があります。以下の例を見ると、これがわかります。

次にポートの問題があります。前述のように、ポートを自分で指定することも、自分自身をクライアントとして扱うこともできます。データを送信する必要がある場合は、接続オブジェクトを作成してからデータを送信します。このように、ポートは動的です。つまり、DatagramSocket オブジェクトが再初期化されたり消えたりしない限り、ローカルで開かれた UDP ポートは閉じられません。

次に、UDP ステータスの問題があります。実際、これについては以前、「UDP 接続オブジェクトの理解と使用」という記事があります。ステートレスとは、この接続に状態がないことを意味します。サーバーが存在するかどうかは誰にもわかりませんし、サーバーが停止しているかどうかも誰にもわかりません。しかし、ローカルの場合、DatagramSocket オブジェクトが常に存在する場合、ローカル ポートはステートフルであり、アクティブです。

次に例を挙げます。

パッケージテスト;
java.io.* をインポートします。
java.net.* をインポートします。
java.util.Arrays をインポートします。
/**
 * UDP クライアント プログラム。サーバーにデータを送信し、サーバーの応答情報を受信するために使用されます。*/
パブリッククラス UdpClientSocket {
	プライベートbyte[]バッファ = 新しいbyte[1024];
	プライベート静的 DatagramSocket ds = null;
	/**
	 * クライアントのパケット送信方法と応答情報の受信方法をテストします */
	パブリック静的void main(String[] args)は例外をスローします{
		UdpClientSocket クライアント = 新しい UdpClientSocket();
		文字列 serverHost = "127.0.0.1";
		int サーバーポート = 10002;
		client.send(serverHost、serverPort、新しいバイト[]{1,2,3,4,5});
		while(true){
			バイト[] bt = client.receive();
			if(null != bt && bt.length > 0)
				System.out.println("受信データ: " + Arrays.toString(bt));
			スレッドをスリープ状態にします(1000);
		}
	}
	/**
	 * コンストラクター、UDPクライアントの作成 */
	パブリック UdpClientSocket() は例外をスローします {
		ds = new DatagramSocket(8899); // クライアントとしてローカルポートにバインド ds.setSoTimeout(5000);
	}
	/**
	 * 指定されたサーバーにデータ情報を送信します */
	パブリックファイナルボイドセンド(ファイナルストリングホスト、ファイナルインタポート、ファイナルバイト[]バイト)は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());		
			データを返します。
		} キャッチ (例外 e) {
			e.printStackTrace();
			null を返します。
		}
	}
}

実行すると常にエラーが報告されます:

java.net.SocketTimeoutException: 受信がタイムアウトしました
java.net.PlainDatagramSocketImpl.receive0(ネイティブメソッド)
java.net.PlainDatagramSocketImpl.receive(PlainDatagramSocketImpl.java:136) で
java.net.DatagramSocket.receive(DatagramSocket.java:712) で
test.UdpClientSocket.receive(UdpClientSocket.java:46) で
test.UdpClientSocket.main(UdpClientSocket.java:20) で
java.net.SocketTimeoutException: 受信がタイムアウトしました
java.net.PlainDatagramSocketImpl.receive0(ネイティブメソッド)
java.net.PlainDatagramSocketImpl.receive(PlainDatagramSocketImpl.java:136) で
java.net.DatagramSocket.receive(DatagramSocket.java:712) で
test.UdpClientSocket.receive(UdpClientSocket.java:46) で
test.UdpClientSocket.main(UdpClientSocket.java:20) で

TCPUDPDbg を使用して 8899 にデータを送信すると、次のものを受信できます。

受信データ: [16, 17, 18, 19, 20]

この例は次のように書かれています

1. ローカルポートは8899です

2. データ受信のタイムアウトは5秒です

3. データ セットがローカル ポート 10002 に送信されました。受信されたかどうかはだれが知っていますか?

4. ローカルポート8899で受信したUDPデータを継続的に取得する

そして発見した

1. データ送信時にエラーが報告されない

2. 「データ収集タイムアウト」というエラーメッセージが常に表示される

3. TCPUDPDbgを使用して8899にデータを送信すると、受信できるようになります。

要約:

1.UDPはデータ受信のタイムアウトを指定できますが、リクエストごとのタイムアウトは自分で制御する必要があります。

2.UDPはローカルポート番号をバインドすることができ、このポートは状態を維持することができる。

3.UDPには状態がないが、ローカルには状態がある

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

以下もご興味があるかもしれません:
  • MySQL での重複キー更新時の replace into と insert into の使用法と相違点の分析
  • Java 並行性 AtomicLongFieldUpdater アトミッククラス_PowerNode Java アカデミー
  • 重複キー更新におけるMySQLのReplace intoとInsert intoの本当の違い
  • MySQL ON DUPLICATE KEY UPDATE ステートメントの例
  • 重複キーの挿入…更新/置換複数行データの概要
  • MySQLの「ON DUPLICATE KEY UPDATE」構文の詳細な分析
  • mysql 挿入のいくつかの操作 (DELAYED、IGNORE、ON DUPLICATE KEY UPDATE)

<<:  削除、切り捨て、ドロップの違いと選択方法

>>:  js における浅いコピーと深いコピーの詳細な説明

推薦する

Vueはキー表示のショートカットキー効果を取得する入力コンポーネントを実装します

ページ上でショートカットキーをカスタマイズする要件に遭遇し、ショートカットキーを設定して表示する場所...

数百万のデータに対して MySQL クエリを最適化する 4 つの方法

目次1. 時間が経つにつれて限界が遅くなる理由2. 百万データシミュレーション1. 従業員テーブルと...

CSSを使用してHTMLテキストボックス内のテキストの垂直方向の中央を制御する

Text の height 属性が定義されている場合、Text に入力されたテキストは垂直方向に中央...

React コンポーネントのコンストラクタとスーパーの知識ポイントのまとめ

1. Reactでクラス宣言する際のヒント 上記のように、Child クラスは class キーワー...

Vue の自動書式設定の改行保存の詳細な説明

ネットで変更方法をいろいろ調べたのですが、うまくいきませんでした。後で大物から見て削除しました。フォ...

Linuxのアラーム機能の例の説明

Linuxアラーム機能の紹介上記のコード: #include <stdio.h> #in...

MySQL の結合テーブルにインデックスを作成する方法

この記事では、MySQL で 2 つのテーブルを関連付ける結合テーブルにインデックスを作成する方法を...

Docker ディスク領域クリーニングのソリューション

少し前に、docker ディスク容量が小さすぎてデータを書き込めないという問題が発生しました。理由は...

MySQL セキュリティ管理の詳細

目次1. 順番に紹介する2. ユーザーを作成する3. ユーザーアカウントを削除する4. アクセス権5...

Vue.jsフレームワークはショッピングカート機能を実装します

この記事では、ショッピングカートを実装するためのVue.jsフレームワークの具体的なコードを参考まで...

MySQL kill コマンドの使用ガイド

KILL [接続 | クエリ] processlist_id MySQL では、各接続は個別のスレ...

Dockerfile をベースに Zabbix 監視システムのコード例を作成する

forループを使用してZabbixイメージをコンテナにインポートします。 n を `ls *.tar...

Baotaパネルを再起動すると、「-ModuleNotFoundError: No module named 'geventwebsocket'」というメッセージが表示されます。

背景:サーバーがFlaskプロジェクトをデプロイし、python3をインストールしたため、再起動時に...

Linux で crond ツールを使用してスケジュールされたタスクを作成する方法

序文Crond は Linux のスケジュール実行ツール (Windows のスケジュールされたタス...

SQL インジェクション脆弱性プロセスの例と解決策

コード例: パブリッククラスJDBCDemo3 { パブリック静的voiddemo3_1(){ bo...