JavaとPerlでTCPソケット通信

use 5.26.0;
use IO::Select;
use IO::Socket;

# コマンドライン引数からサーバソケットポート番号を設定
#（指定が無ければ5001番ポート使用）
my $port = shift || 5001;

my $listener = IO::Socket::INET->new(
    LocalPort => $port,
    Listen    => SOMAXCONN,
    Proto     => 'tcp',
    Reuse     => 1,
);

if ( !$listener ) {
    die "can't listen $!\n";
} else {
    print "listening $port\n";
}

my $selector = IO::Select->new( $listener );

while( my @ready = $selector->can_read() ) {
    foreach my $sock ( @ready ) {
        if( $sock == $listener ) {
            # Create a new socket
            my $new_sock = $listener->accept;
            $selector->add( $new_sock );
        }
        else {
            # クライアントソケットから行数分の電文読み込み
            while ( my $line = <$sock> ) {
                if ( $line ) {
                    say "message from client : ", $line;

                    # netstatを実行して結果をファイルハンドルに詰め込む
                    open( FH, "netstat -an |" ) or die "can't exec netstat $!";

                    # 結果行数分回してソケットにwrite
                    while ( <FH> ) {
                        print $sock $_;
                    }

                    $sock->flush();

                    # セレクタからソケット削除
                    $selector->remove( $sock );
                    $sock->close();
                }
            }
        }
    }
}

package com.sample.snippet;

import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.Socket;

public class NetstatClient {

	public static void main(String[] args) throws Exception {
        String server = "localhost";
        int port = 5001;

        // perlのサーバソケットに接続
        Socket socket = new Socket(server, port);

        // ソケット入力
        BufferedReader in =
            new BufferedReader(new InputStreamReader(socket.getInputStream()));

        // ソケット出力
        PrintWriter out =
            new PrintWriter(socket.getOutputStream(), true);

        // 電文送信
        out.println("give me netstat results");

        // ソケットから返却されたnetstat結果を行数分読み込み
        String line = null;
        while((line = in.readLine()) != null) {
            System.out.println("受信：" + line);
        }

        in.close();
        socket.close();

        System.out.println("完了");

    }
}

C:\src\perl>perl netstat-server.pl 5001
listening 5001

受信：
受信：アクティブな接続
受信：
受信：  プロトコル  ローカル アドレス      外部アドレス           状態
受信：  TCP         0.0.0.0:80             0.0.0.0:0              LISTENING
受信：  TCP         0.0.0.0:135            0.0.0.0:0              LISTENING
受信：  TCP         0.0.0.0:445            0.0.0.0:0              LISTENING
受信：  TCP         0.0.0.0:623            0.0.0.0:0              LISTENING
受信：  TCP         0.0.0.0:1801           0.0.0.0:0              LISTENING
受信：  TCP         0.0.0.0:2103           0.0.0.0:0              LISTENING
受信：  TCP         0.0.0.0:2105           0.0.0.0:0              LISTENING

    (snip)

受信：  UDP         [::]:65086             *:*                    
受信：  UDP         [::1]:1900             *:*                    
受信：  UDP         [::1]:5353             *:*                    
受信：  UDP         [::1]:60416            *:*                    
受信：  UDP         [fe80::4881:bab0:17bf:1336%12]:1900  *:*                    
受信：  UDP         [fe80::4881:bab0:17bf:1336%12]:60414  *:*                    
受信：  UDP         [fe80::90fe:ec81:9d44:c68f%15]:1900  *:*                    
受信：  UDP         [fe80::90fe:ec81:9d44:c68f%15]:60415  *:*                    
完了