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 における浅いコピーと深いコピーの詳細な説明

推薦する

CentOs でノード バージョンを手動でアップグレードする方法

1. 対応するNode.jsパッケージを見つけます。https://nodejs.org/downl...

Linux での JDK と Tomcat のアップロードと設定に関する詳細なチュートリアル

準備1. 仮想マシンを起動する2. gitツールルートアカウントでログインルートアカウントを使用して...

CSS3で実装された炎のアニメーション

成果を達成する実装コードhtml <div class="コンテナ">...

WeChatミニプログラムがいいねサービスを実装

この記事では、WeChatアプレットの具体的なコードを参考までに紹介します。具体的な内容は次のとおり...

SQL 実践演習: オンライン モール データベース ユーザー情報データ操作

オンラインショッピングモールデータベース - ユーザー情報データ運用プロジェクトの説明電子商取引の台...

小規模プログラムへのデータキャッシュ機構の応用と実装

ミニプログラムデータキャッシュ関連知識データ キャッシュ: データをキャッシュして、アプレットを終了...

Dockerを使用してgitlabコミュニティの中国語版を構築する詳細なプロセスを教えます

1. Docker Composeを使用して起動を構成するDocker Compose を知らない場...

エコー後に要素編集フォームel-radioが選択できない問題を解決します

目次序文質問オンラインソリューション序文この記事の内容は私がこの業界に入ったときのメモを元にしている...

Nginx プロセス管理とリロードの原則の詳細な説明

プロセス構造図Nginx はマルチプロセス構造です。マルチプロセス構造は、次のような Nginx の...

onfocus="this.blur()" は視覚障害のあるウェブマスターに嫌われている

スクリーン リーダー ソフトウェアの操作ページについて話しているとき、彼はフロントエンドの学生たちに...

さまざまなMySQLインデックスの使用方法の詳細な説明

1. 遅いクエリログ1.1 MySQL ログの種類ログは、データベースの操作や、ユーザーがデータベー...

W3C 検証に合格するにはどうすればいいですか?

W3C では、さまざまなタグの規定を設定するだけでなく、Web ページの作成者が実際に W3C 規...

面接では、select...for update がテーブルをロックするのか、それとも行をロックするのか尋ねられました。

目次確認する:例の検証と組み合わせるselect クエリ ステートメントはロックされませんが、sel...

HTMLページの文字セットを指定する2つの方法

1. HTMLページの文字セットを指定する2つの方法方法1: <メタ文字セット="u...

Bootstrapはカルーセルの効果を実現します

この記事では、カルーセルマップの効果を実現するためのBootstrapの具体的なコードを参考までに共...