logo标签列表

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

javapythonsockets
6
我的目标是从Python套接字向Java套接字发送消息。我查看了上面提到的资源，但我在让Python客户端与Java服务器通信方面遇到了困难，主要是因为Python中的(行末)与Java中的不同。例如：如果我从Python客户端写入：消息1:abcd 消息2:efgh 消息3:q (退出)，那么Java服务器将接收到消息1:abcdefghq，后跟异常，因为Python客户端已从其一端关闭了套接字。请问是否有人能提供一个解决方案，以实现Java和Python之间的一致对话。 我使用的参考文献是：http://www.prasannatech.net/2008/07/socket-programming-tutorial.html。更新：我忘记添加了，我正在使用TCP协议。我的Java代码如下（服务器套接字）。
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（按回车键）

发送（输入q或Q退出）：efgh（按回车键）

发送（输入q或Q退出）：q（按回车键）

在Java控制台（服务器）:

TCPServer正在端口5000上等待客户端连接

客户端/127.0.0.1:1335已连接

已接收：abcdefghq

EOL 指的是换行符 ('\n') - 我想你需要发布创建错误的最小代码。 - KevinDTimm
我忘记添加了，我正在处理TCP。 - Amandeep Chugh
只是一个建议：在那里分配String fromclient;的效率较低。在这里分配它：String fromclient = inFromClient.readLine(); 除此之外，代码真的很好。 - Chris Dennett
@AmandeepChugh 如果有任何答案解决了您的问题，请接受它。 - PhoneixS
5个回答
8
将data的末尾添加\n：
client_socket.send(data + '\n')
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服务器

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
0
0

对于那些正在苦苦挣扎的人，

data = raw_input ( "SEND( TYPE q or Q to Quit):" )

你也可以使用.encode()来发送数据

网页内容由stack overflow 提供, 点击上面的
可以查看英文原文，
原文链接