Python客户端与Java服务器的通信

6 投票
5 回答
28280 浏览
提问于 2025-04-16 07:05

我的目标是让Python的socket和Java的socket之间发送消息。我查看了上面提到的资源,但我在让Python客户端和Java服务器沟通时遇到了困难。主要是因为Python中的换行符和Java中的换行符不一样。

比如我在Python客户端写:消息1:abcd 消息2:efgh 消息3:q(表示退出)

在Java服务器上,我收到的消息是:消息1:abcdefghq,接着就出现了异常,因为Python客户端已经关闭了socket。

有没有人能建议一个解决方案,让Java和Python之间的通信更加一致呢?

我参考的链接是:http://www.prasannatech.net/2008/07/socket-programming-tutorial.html

更新:我忘了说,我是在做TCP通信。

我的Java代码是这样的:(服务器socket)

String fromclient;

ServerSocket Server = new ServerSocket (5000);

System.out.println ("TCPServer Waiting for client on port 5000");

while(true) 
{
    Socket connected = Server.accept();
    System.out.println( " THE CLIENT"+" "+ connected.getInetAddress() +":"+connected.getPort()+" IS CONNECTED ");

    BufferedReader inFromClient = new BufferedReader(new InputStreamReader (connected.getInputStream()));

    while ( true )
    {
        fromclient = inFromClient.readLine();

        if ( fromclient.equals("q") || fromclient.equals("Q") )
        {
            connected.close();
            break;
        }
        else
        {
            System.out.println( "RECIEVED:" + fromclient );
        } 
    }
}

我的Python代码:(客户端socket)

client_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
client_socket.connect(("localhost", 5000))

while 1:

    data = raw_input ( "SEND( TYPE q or Q to Quit):" )
    if (data <> 'Q' and data <> 'q'):
        client_socket.send(data)
    else:
        client_socket.send(data)
        client_socket.close()
        break;

输出结果:

在Python控制台(客户端):

发送(输入q或Q退出):abcd(按下ENTER键)

发送(输入q或Q退出):efgh(按下ENTER键)

发送(输入q或Q退出):q(按下ENTER键)

在Java控制台(服务器):

TCP服务器在5000端口等待客户端连接

客户端/127.0.0.1:1335已连接

接收到:abcdefghq

5 个回答

1

这里有一段可以正常运行的代码:

Jserver.java

import java.io.*;
import java.net.*;
import java.util.*;
public class Jserver{
public static void main(String args[]) throws IOException{
    ServerSocket s=new ServerSocket(5000);

    try{
        Socket ss=s.accept();
        PrintWriter pw = new PrintWriter(ss.getOutputStream(),true);
        BufferedReader br = new BufferedReader(new InputStreamReader(System.in));
        BufferedReader br1 = new BufferedReader(new InputStreamReader(ss.getInputStream()));
        //String str[20];
        //String msg[20];
        System.out.println("Client connected..");
        while(true)
        {
            System.out.println("Enter command:");
            pw.println(br.readLine());
            //System.out.println(br1.readLine());
        }
    }
    finally{}
    }
}

Client.py

import socket               # Import socket module

s = socket.socket()         # Create a socket object
host = socket.gethostname() # Get local machine name
port = 5000                # Reserve a port for your service.

s.connect((host, port))
while 1:
    print s.recv(5000)
    s.send("message processed.."+'\n')

s.close 
2

是的,你需要在Python客户端的字符串末尾加上'\n'。下面是一个例子:

PythonTCPClient.py

`

#!/usr/bin/env python

import socket

HOST = "localhost"
PORT = 8080

sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
sock.connect((HOST, PORT))

sock.sendall("Hello\n")
data = sock.recv(1024)
print "1)", data

if ( data == "olleH\n" ):
    sock.sendall("Bye\n")
    data = sock.recv(1024)
    print "2)", data

    if (data == "eyB}\n"):
        sock.close()
        print "Socket closed"

`

现在这是Java代码:

JavaServer.java

`

 import java.io.*;
import java.net.*;

class JavaServer {
    public static void main(String args[]) throws Exception {
        String fromClient;
        String toClient;

        ServerSocket server = new ServerSocket(8080);
        System.out.println("wait for connection on port 8080");

        boolean run = true;
        while(run) {
            Socket client = server.accept();
            System.out.println("got connection on port 8080");
            BufferedReader in = new BufferedReader(new InputStreamReader(client.getInputStream()));
            PrintWriter out = new PrintWriter(client.getOutputStream(),true);

            fromClient = in.readLine();
            System.out.println("received: " + fromClient);

            if(fromClient.equals("Hello")) {
                toClient = "olleH";
                System.out.println("send olleH");
                out.println(toClient);
                fromClient = in.readLine();
                System.out.println("received: " + fromClient);

                if(fromClient.equals("Bye")) {
                    toClient = "eyB";
                    System.out.println("send eyB");
                    out.println(toClient);
                    client.close();
                    run = false;
                    System.out.println("socket closed");
                }
            }
        }
        System.exit(0);
    }
}

`

参考链接:Python TCP客户端与Java TCP服务器的连接

8

data 的末尾加上 \n

client_socket.send(data + '\n')

撰写回答