UDP

(KAB-studioからのおしらせです)

// Sample.java
import java.net.DatagramSocket;
import java.net.DatagramPacket;
import java.net.InetAddress;
import java.net.UnknownHostException;
import java.io.IOException;

public class Sample
{
    public static void main( String[] args )
    {
        // ポート番号12345で通信します。
        // ……もし、ポート番号12345が空いてないとダメです。
        // その場合はこの数字を他のにしてください。
        final int PORT = 12345;
        // 対象のホスト名。自分自身なのでlocalhostです。
        final String HOST = "localhost";

        // サーバーは別スレッドで。
        // もちろん、普通は「別のプログラム」をサーバーにします。
        ServerThread thread = new ServerThread( PORT );
        thread.start();

        try
        {
            // このスレッドを3秒止めます。
            // サーバー側の準備ができるのを待つためです。
            Thread.sleep( 3 * 1000 );
        }
        catch( InterruptedException e )
        {
            // sleep()メソッドを呼んでいる間に割り込みが入ると
            // InterruptedException例外が投げられます。
            e.printStackTrace();
        }

        // 以下、クライアント側の処理。

        // finallyでclose()するためここで宣言します。
        DatagramSocket datagramSocket = null;
        try
        {
            // localhostを示すInetAddressクラスです。
            InetAddress inetAddress = InetAddress.getByName( HOST );

            // UDPで接続するためのDatagramSocketクラスを作ります。
            // ポート番号等は指定しません。
            datagramSocket = new DatagramSocket();

            // 送信用文字列です。
            // UDPなので、byte型の配列にします。
            String string = "あいうえお";
            byte[] bytes = string.getBytes();
            // データを送信するためのDatagramPacketクラスを用意します。
            // ここで送信先ホスト名やポート番号を指定します。
            DatagramPacket datagramPacket = new DatagramPacket( bytes, bytes.length, inetAddress, PORT );

            // 文字列をサーバー側に出力します。
            System.out.println( "[クライアント]「あいうえお」を出力します。" );
            datagramSocket.send( datagramPacket );
            System.out.println( "[クライアント]「あいうえお」を出力しました。" );
            // [サーバー]待機開始！
            // [クライアント]「あいうえお」を出力します。
            // [サーバー]待機終了。
            // [サーバー]出力開始。
            // [クライアント]「あいうえお」を出力しました。
            // あいうえお
            // [サーバー]出力完了。
        }
        catch( UnknownHostException e )
        {
            // InetAddressクラスのgetByName()メソッドを呼び出して、
            // ホストからIPアドレスを取得できない場合は
            // UnknownHostException例外が投げられます。
            e.printStackTrace();
        }
        catch( IOException e )
        {
            // 出力時に問題があったらIOException例外が投げられます。
            e.printStackTrace();
        }
        finally
        {
            if( datagramSocket != null )
            {
                // ソケットを閉じます。
                datagramSocket.close();
            }
        }
    }
}

/**
*   サーバー側。
*/
class ServerThread extends Thread
{
    /** ポート番号 */
    private int port;

    /**
    *   コンストラクタ。
    */
    public ServerThread( int port )
    {
        this.port = port;
    }
    
    /**
    *   サーバーを起動します。
    */
    public void run()
    {
        // finallyでclose()するためここで宣言します。
        DatagramSocket  datagramSocket  = null;
        try
        {
            // データを受け取るためのDatagramPacketクラスを用意します。
            byte[] bytes = new byte[256];
            DatagramPacket datagramPacket = new DatagramPacket( bytes, bytes.length );

            // ポート番号を指定して、UDPサーバーを作ります。
            datagramSocket = new DatagramSocket( port );

            // クライアントからのアクセスを待機開始！
            System.out.println( "[サーバー]待機開始！" );
            datagramSocket.receive( datagramPacket );
            System.out.println( "[サーバー]待機終了。" );

            // 受け取った文字列を出力します。
            // 受け取った文字列はbyte型配列に入れられています。
            // ただし、実際に受信したバイト数はDatagramPacketクラスの
            // getLength()メソッドで取得します。
            System.out.println( "[サーバー]出力開始。" );
            String string = new String( bytes, 0, datagramPacket.getLength() );
            System.out.println( string );
            System.out.println( "[サーバー]出力完了。" );
        }
        catch( IOException e )
        {
            // 出力時に問題があったらIOException例外が投げられます。
            e.printStackTrace();
        }
        finally
        {
            if( datagramSocket != null )
            {
                datagramSocket.close();
            }
        }
    }
}