2

Linux でサーバー ソケットを使用しています。time_wait TCP ステータスが期限切れになる前に、それを閉じて再度開く必要があります。バインディングの前にサーバー ソケットの再利用アドレス オプションを設定しましたが、まだ BindException がスローされます。これも試しましたhttp://meteatamel.wordpress.com/2010/12/01/socket-reuseaddress-property-and-linux/しかし、それでも機能しません。

サーバーソケットを開くには、次を使用します。

ServerSocket ss = new ServerSocket();
ss.setReuseAddress(true);
ss.bind(new InetSocketAddress(12345));

そして閉じる：

ss.close();

バインド呼び出しで「アドレスは既に使用されています」BindException がスローされます。

このコードは例外を生成します:

for (int i = 0; i < 2; i++) {
        new Thread(new Runnable() {
            @Override
            public void run() {
                try {
                    final ServerSocket ss = new ServerSocket();
                    ss.setReuseAddress(true);
                    ss.bind(new InetSocketAddress(12345));
                    Socket s = ss.accept();
                    System.out.println((char) s.getInputStream().read());
                    ss.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
        }).start();
        Thread.sleep(500);
        Socket s = new Socket("localhost", 12345);
        s.getOutputStream().write('c');
    }
4

2 に答える 2

11

例外を受け取った後ではなく、バインドする前に再利用を設定します。

ServerSocket ss = new ServerSocket(); // don't bind just yet
ss.setReuseAddress(true);
ss.bind(new InetSocketAddress(12345)); // can bind with reuse= true

これは、Windows 7 および RHEL 5.x でエラーなしで実行されます。

for (int i = 0; i < 1000; i++) {
    Thread t = new Thread(new Runnable() {
        @Override
        public void run() {
            try {
                final ServerSocket ss = new ServerSocket();
                ss.setReuseAddress(true);
                ss.bind(new InetSocketAddress(12345));
                Socket s = ss.accept();
                System.out.println((char) s.getInputStream().read());
                ss.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    });
    t.start();
    Thread.sleep(50);
    Socket s = new Socket("localhost", 12345);
    s.getOutputStream().write('c');
    t.join();
}
于 2012-05-09T12:33:57.800 に答える