以前、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(); } } } コードを実行した結果は次のとおりです。
操作はタイムアウトしましたが、エラーはオブジェクトの作成とデータの送信によって発生したのではなく、データ受信時のタイムアウトによって発生しました。 このプログラムは実行し続けますので、サーバーを作成しましょう。 パッケージ 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 を応援していただければ幸いです。 以下もご興味があるかもしれません:
|
>>: 2 つの MySQL ユーザー削除ステートメント (delete user と drop user) の違い
この記事では、例を挙げて mysql show 操作について説明します。ご参考までに、詳細は以下の通...
いろいろ苦労した後、インターネットで検索したり、以前の会社のプロジェクトを探したり、他の人のプロジェ...
この記事では、参考までに、シンプルなページカウントダウンを実装するためのJavaScriptの具体的...
(Web ページの読み込み中に、コンテンツが多すぎて読み込みと待機が続くことがあります。このとき、...
Linux でディレクトリを切り替えるとなると、誰もが間違いなくcdコマンドを思い浮かべるでしょう。...
Web デザインは、個人の好みや Web ページの内容に応じて、デザインのレイアウトが常に変化します...
データの挿入テーブル名(列名1、列名2、列名3)の値(値1、値2、値3)に挿入します。ユーザーに(u...
基本的な紹介特徴Flexbox は、よりシンプルで効率的なレイアウト方法を提供する CSS 表示タイ...
この記事の例では、参考のためにMySQLトリガーを作成するための具体的なコードを共有しています。具体...
この記事では、参考までに、簡単なログイン機能を実装するためのvue+tp5の具体的なコードを紹介しま...
目次1. jsステートメント2番目、js配列3. js関数4. メイヴンV. 結論1. jsステート...
方法1: グローバル general_log を 'OFF' に設定します。 テーブ...
httpとhttpsの違いは一部のウェブサイトでは、http を開くと、安全ではないというメッセージ...
多くの場合、移行は避けられません。ハードウェアのアップグレード、データ センターの変更、古いオペレー...
一つの環境CentOS 7にVMware Toolsをインストールしてホストの共有フォルダへのアクセ...