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

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

以前、UDP を使い始めるために簡単な UDP サーバーとクライアントの例を作成しましたが、実際に使用してみると問題が発生しました。

前回使用したときも、接続オブジェクト DatagramSocket を static として記述し、クラスの初期化時に使用していました。しかし、システム内の多くの場所で使用されています。このクラスのオブジェクトを作成し続ける必要がありますか?

これを実行することは可能ですが、メモリ オーバーフローという結果を招く可能性があります。

UDP はステートレスです。DatagramSocket は、特定のアドレスのポートを指すために、毎回作成する必要はなく、一度作成するだけで済みます。

UDP はステートレスなので、DatagramSocket オブジェクトを作成すると、ネットワークを指すオブジェクトのみが作成されます。これは、特定の方向を向いた大きなスピーカーを設置しても、その方向で聞いている人がいるかどうかはわからないのと同じです。

サーバーが稼働していなくても、接続オブジェクトを作成してこのアドレスにデータを送信しても問題はありません。拡声器で特定の方向に向かって叫んでも、誰も聞いてくれなければ意味がありません。ただし、必要なときに応答が受信されない場合は、タイムアウト後にエラーが報告されます。

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

コードを実行した結果は次のとおりです。

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

操作はタイムアウトしましたが、エラーはオブジェクトの作成とデータの送信によって発生したのではなく、データ受信時のタイムアウトによって発生しました。

このプログラムは実行し続けますので、サーバーを作成しましょう。

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

実行後、クライアントは正常にデータを送受信できるようになります。

実際に使用する場合は、システム スタートアップ項目を設定して、init 接続オブジェクトとアドレスを初期化し、使用時に例外をキャプチャします。

接続オブジェクトが毎回作成され、頻繁に使用される場合、通常、システムは数分以内にクラッシュします。

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

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

<<:  JavaScript 配列重複排除ソリューション

>>:  2 つの MySQL ユーザー削除ステートメント (delete user と drop user) の違い

推薦する

mysql 簡単な操作例を表示

この記事では、例を挙げて mysql show 操作について説明します。ご参考までに、詳細は以下の通...

ウェブページに埋め込まれた Flash と IE、FF、Maxthon の互換性の問題

いろいろ苦労した後、インターネットで検索したり、以前の会社のプロジェクトを探したり、他の人のプロジェ...

シンプルなページカウントダウンを実現するJavaScript

この記事では、参考までに、シンプルなページカウントダウンを実装するためのJavaScriptの具体的...

ウェブページの読み込み進捗状況バーの詳細な説明(推奨)

(Web ページの読み込み中に、コンテンツが多すぎて読み込みと待機が続くことがあります。このとき、...

Linuxでディレクトリを効率的に切り替える方法

Linux でディレクトリを切り替えるとなると、誰もが間違いなくcdコマンドを思い浮かべるでしょう。...

ウェブページをデザインする際に注意すべきいくつかの問題

Web デザインは、個人の好みや Web ページの内容に応じて、デザインのレイアウトが常に変化します...

MySQLデータベースの追加、削除、変更操作の詳細な説明

データの挿入テーブル名(列名1、列名2、列名3)の値(値1、値2、値3)に挿入します。ユーザーに(u...

CSS3 FlexBox の伸縮自在なレイアウトを 10 分で理解する

基本的な紹介特徴Flexbox は、よりシンプルで効率的なレイアウト方法を提供する CSS 表示タイ...

MySQLでトリガーを作成する方法

この記事の例では、参考のためにMySQLトリガーを作成するための具体的なコードを共有しています。具体...

vue+tp5はシンプルなログイン機能を実現

この記事では、参考までに、簡単なログイン機能を実装するためのvue+tp5の具体的なコードを紹介しま...

js 基本構文と Maven プロジェクト構成チュートリアル ケース

目次1. jsステートメント2番目、js配列3. js関数4. メイヴンV. 結論1. jsステート...

Mysql general_log をクリーンアップする方法の概要

方法1: グローバル general_log を 'OFF' に設定します。 テーブ...

Nginx http を https にアップグレードする手順を完了する

httpとhttpsの違いは一部のウェブサイトでは、http を開くと、安全ではないというメッセージ...

Docker コンテナを他のサーバーに移行する 5 つの方法

多くの場合、移行は避けられません。ハードウェアのアップグレード、データ センターの変更、古いオペレー...

VM VirtualBox 仮想マシンのマウント共有フォルダ

一つの環境CentOS 7にVMware Toolsをインストールしてホストの共有フォルダへのアクセ...