Skip to main content
データを逐次的に送ることを想定しているためコードの改修、ser'b'erのスペルミス修正、定数の大文字化
ソース リンク
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.InetSocketAddress;
import java.net.ServerSocket;
import java.net.Socket;

/**
 * ソケット通信(サーバー側)
 */
class SocketServer {

    public static void main(String[] args) {

        ServerSocket sSocket = null;
        Socket socket = null;
        BufferedReader reader = null;
        PrintWriter writer = null;
        final String serberIpSERVER_IP = "127.0.0.1";
        final int serberPortSERVER_PORT = 10000;
        try {
            sSocket = new ServerSocket();
            sSocket.bind(new InetSocketAddress(serberIpSERVER_IP, serberPortSERVER_PORT));
            System.out.println("クライアントからの接続待ち");
            socket = sSocket.accept();
            System.out.println("クライアントからの接続完了");
            //クライアントからのデータ受信用
            reader = new BufferedReader(new InputStreamReader(socket.getInputStream()));
            //クライアントへの応答送信用
            writer = new PrintWriter(socket.getOutputStream(), true);

            String line = null;
            System.out.println("クライアントからの入力データ待ち");
            while ((line = reader.readLine();) != null) {
                System.out.println("クライアントからの入力データ:" + line);

                //クライアントからの入力データに応じたJava側の処理
                System.out.println("クライアントからの入力データに応じたJava側の処理を実行");
                //処理結果をサーバへ送信
                writer.println("Java側の処理結果" + line.charAt(0));
                System.out.println("Java側の処理結果をクライアントへ送信");
            }

            try {
                reader.close();
                writer.close();
                socket.close();
                sSocket.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}
# coding: utf-8
# ソケット通信(クライアント)
import socket

if __name__ == '__main__':
    serber_ipSERVER_IP = '127.0.0.1'
    serber_portSERVER_PORT = 10000
    server = (serber_ipSERVER_IP, serber_portSERVER_PORT)

    socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    socket.connect(server) 

    count = 0
    while True:
        line = 'Pythonstr(count) + ': Python側からJava側への送信データ\n'
        # サーバに送信
        socket.send(line.encode("UTF-8"))
        print('サーバーへ処理依頼: '+str(count))

        # サーバからの処理結果受信
        result = socket.recv(4096).decode()
        print('サーバーからの処理結果: ' + str(result)) 

        count = count+1
        time.sleep(200)


    socket.close()
クライアントからの接続待ち
クライアントからの接続完了
クライアントからの入力データ待ち
クライアントからの入力データ:0: Python側からJava側への送信データ
クライアントからの入力データに応じたJava側の処理を実行
Java側の処理結果をクライアントへ送信
 
プロセスは終了コード 0クライアントからの入力データ:1: で終了しましPython側からJava側への送信データ
クライアントからの入力データに応じJava側の処理を実行
Java側の処理結果をクライアントへ送信
サーバーへ処理依頼: 0
サーバーからの処理結果: Java側の処理結果
 0

プロセスは終了コードサーバーへ処理依頼: 01
サーバーからの処理結果: で終了しましたJava側の処理結果1

(質問者による)注意
コード例はリクエスト1回に対しPython側から永遠にデータを送っレスポンス1回ですますが、必要があればPython側とJava側で終了の依頼を取り決めをして、処理を繰り返してください。

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.InetSocketAddress;
import java.net.ServerSocket;
import java.net.Socket;

/**
 * ソケット通信(サーバー側)
 */
class SocketServer {

    public static void main(String[] args) {

        ServerSocket sSocket = null;
        Socket socket = null;
        BufferedReader reader = null;
        PrintWriter writer = null;
        String serberIp = "127.0.0.1";
        int serberPort = 10000;
        try {
            sSocket = new ServerSocket();
            sSocket.bind(new InetSocketAddress(serberIp, serberPort));
            System.out.println("クライアントからの接続待ち");
            socket = sSocket.accept();
            System.out.println("クライアントからの接続完了");
            //クライアントからのデータ受信用
            reader = new BufferedReader(new InputStreamReader(socket.getInputStream()));
            //クライアントへの応答送信用
            writer = new PrintWriter(socket.getOutputStream(), true);

            String line = null;
            System.out.println("クライアントからの入力データ待ち");
            line = reader.readLine();
            System.out.println("クライアントからの入力データ:" + line);

            //クライアントからの入力データに応じたJava側の処理
            System.out.println("クライアントからの入力データに応じたJava側の処理を実行");
            //処理結果をサーバへ送信
            writer.println("Java側の処理結果");
            System.out.println("Java側の処理結果をクライアントへ送信");
            try {
                reader.close();
                writer.close();
                socket.close();
                sSocket.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}
# coding: utf-8
# ソケット通信(クライアント)
import socket

if __name__ == '__main__':
    serber_ip = '127.0.0.1'
    serber_port = 10000
    server = (serber_ip, serber_port)

    socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    socket.connect(server)

    line = 'Python側からJava側への送信データ\n'
    # サーバに送信
    socket.send(line.encode("UTF-8"))
    print('サーバーへ処理依頼: ')

    # サーバからの処理結果受信
    result = socket.recv(4096).decode()
    print('サーバーからの処理結果: ' + str(result))

    socket.close()
クライアントからの接続待ち
クライアントからの接続完了
クライアントからの入力データ待ち
クライアントからの入力データ:Python側からJava側への送信データ
クライアントからの入力データに応じたJava側の処理を実行
Java側の処理結果をクライアントへ送信
 
プロセスは終了コード 0 で終了しまし
サーバーへ処理依頼: 
サーバーからの処理結果: Java側の処理結果
 

プロセスは終了コード 0 で終了しました

注意
コード例はリクエスト1回に対しレスポンス1回ですが、必要があればPython側とJava側で終了の依頼を取り決めをして、処理を繰り返してください。

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.InetSocketAddress;
import java.net.ServerSocket;
import java.net.Socket;

/**
 * ソケット通信(サーバー側)
 */
class SocketServer {

    public static void main(String[] args) {

        ServerSocket sSocket = null;
        Socket socket = null;
        BufferedReader reader = null;
        PrintWriter writer = null;
        final String SERVER_IP = "127.0.0.1";
        final int SERVER_PORT = 10000;
        try {
            sSocket = new ServerSocket();
            sSocket.bind(new InetSocketAddress(SERVER_IP, SERVER_PORT));
            System.out.println("クライアントからの接続待ち");
            socket = sSocket.accept();
            System.out.println("クライアントからの接続完了");
            //クライアントからのデータ受信用
            reader = new BufferedReader(new InputStreamReader(socket.getInputStream()));
            //クライアントへの応答送信用
            writer = new PrintWriter(socket.getOutputStream(), true);

            String line = null;
            System.out.println("クライアントからの入力データ待ち");
            while ((line = reader.readLine()) != null) {
                System.out.println("クライアントからの入力データ:" + line);

                //クライアントからの入力データに応じたJava側の処理
                System.out.println("クライアントからの入力データに応じたJava側の処理を実行");
                //処理結果をサーバへ送信
                writer.println("Java側の処理結果" + line.charAt(0));
                System.out.println("Java側の処理結果をクライアントへ送信");
            }

            try {
                reader.close();
                writer.close();
                socket.close();
                sSocket.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}
# coding: utf-8
# ソケット通信(クライアント)
import socket

if __name__ == '__main__':
    SERVER_IP = '127.0.0.1'
    SERVER_PORT = 10000
    server = (SERVER_IP, SERVER_PORT)

    socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    socket.connect(server) 

    count = 0
    while True:
        line = str(count) + ': Python側からJava側への送信データ\n'
        # サーバに送信
        socket.send(line.encode("UTF-8"))
        print('サーバーへ処理依頼: '+str(count))

        # サーバからの処理結果受信
        result = socket.recv(4096).decode()
        print('サーバーからの処理結果: ' + str(result)) 

        count = count+1
        time.sleep(200)


    socket.close()
クライアントからの接続待ち
クライアントからの接続完了
クライアントからの入力データ待ち
クライアントからの入力データ:0: Python側からJava側への送信データ
クライアントからの入力データに応じたJava側の処理を実行
Java側の処理結果をクライアントへ送信
クライアントからの入力データ:1: Python側からJava側への送信データ
クライアントからの入力データに応じJava側の処理を実行
Java側の処理結果をクライアントへ送信
サーバーへ処理依頼: 0
サーバーからの処理結果: Java側の処理結果0

サーバーへ処理依頼: 1
サーバーからの処理結果: Java側の処理結果1

(質問者による)注意
コード例はPython側から永遠にデータを送っますが、必要があればPython側とJava側で終了の依頼を取り決めをして、処理を繰り返してください。

本文に 1 文字追加
ソース リンク
akira ejiri
  • 5,096
  • 2
  • 12
  • 29

実行結果(Java側)

クライアントからの接続待ち
クライアントからの接続完了
クライアントからの入力データ待ち
クライアントからの入力データ:Python側からJava側への送信データ
クライアントからの入力データに応じたJava側の処理を実行
Java側の処理結果をクライアントへ送信

プロセスは終了コード 0 で終了しました

実行結果(Python側)

サーバーへ処理依頼: 
サーバーからの処理結果: Java側の処理結果


プロセスは終了コード 0 で終了しました

注意
コード例はリクエスト1回に対してレスポンス1回ですが、必要があればPython側とJava側で終了の依頼を取り決めをして、処理を繰り返してください。

注意
コード例はリクエスト1回に対してレスポンス1回ですが、必要があればPython側とJava側で終了の依頼を取り決めをして、処理を繰り返してください。

実行結果(Java側)

クライアントからの接続待ち
クライアントからの接続完了
クライアントからの入力データ待ち
クライアントからの入力データ:Python側からJava側への送信データ
クライアントからの入力データに応じたJava側の処理を実行
Java側の処理結果をクライアントへ送信

プロセスは終了コード 0 で終了しました

実行結果(Python側)

サーバーへ処理依頼: 
サーバーからの処理結果: Java側の処理結果


プロセスは終了コード 0 で終了しました

注意
コード例はリクエスト1回に対してレスポンス1回ですが、必要があればPython側とJava側で終了の依頼を取り決めをして、処理を繰り返してください。

本文に 1 文字追加
ソース リンク
akira ejiri
  • 5,096
  • 2
  • 12
  • 29
  1. あらかじめJava側のTCP/IP(socket)サーバを立ち上げておく
  2. Python側からavaJava側へ、なんらかの処理依頼を送信する
  3. Java側で依頼されたなんらかの処理を実行し、処理結果をPython側へ送信する
  4. Python側で処理結果を受信する
  1. あらかじめJava側のTCP/IP(socket)サーバを立ち上げておく
  2. Python側からava側へ、なんらかの処理依頼を送信する
  3. Java側で依頼されたなんらかの処理を実行し、処理結果をPython側へ送信する
  4. Python側で処理結果を受信する
  1. あらかじめJava側のTCP/IP(socket)サーバを立ち上げておく
  2. Python側からJava側へ、なんらかの処理依頼を送信する
  3. Java側で依頼されたなんらかの処理を実行し、処理結果をPython側へ送信する
  4. Python側で処理結果を受信する
ソース リンク
akira ejiri
  • 5,096
  • 2
  • 12
  • 29
読み込んでいます