java - Twisted python 服务器和 Java 聊天

Question

我在 raywenderlich.com 上找到了这个很棒的教程:

http://www.raywenderlich.com/3932/how-to-create-a-socket-based-iphone-app-and-server

它创建一个 Twisted Python 服务器，并与应用程序 iphone 聊天交谈，我会让服务器也与 Java 聊天交谈，现在我编写一些代码，这是 python 服务器:

from twisted.internet.protocol import Protocol, Factory
from twisted.internet import reactor


class IphoneChat(Protocol):
def connectionMade(self):
    #self.transport.write("""connected""")
    self.factory.clients.append(self)
    print "clients are ", self.factory.clients

def connectionLost(self, reason):
    self.factory.clients.remove(self)

def dataReceived(self, data):
    #print "data is ", data
    a = data.split(':')
    if len(a) > 1:
        command = a[0]
        content = a[1]

        msg = ""
        if command == "iam":
            self.name = content
            msg = self.name + " has joined"

        elif command == "msg":
            msg = self.name + ": " + content

        print msg

        for c in self.factory.clients:
            c.message(msg)

def message(self, message):
    self.transport.write(message + '\n')


factory = Factory()
factory.protocol = IphoneChat
factory.clients = []

reactor.listenTCP(1025, factory)
print "Chat server started"
reactor.run()

然后我创建一个简单的 java 示例来连接到服务器:

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

public class MyClassSocket  {

private ObjectInputStream sInput;       // to read from the socket
private ObjectOutputStream sOutput;     // to write on the socket
private Socket socket;

private String server, username;
private int port;

MyClassSocket(String server, int port, String username) {
    this.server = server;
    this.port = port;
    this.username = username;
}

private void display(String msg) {

    System.out.println(msg);      // println in console mode

}

public boolean start() {

    try {
        socket = new Socket(server, port);
    }
    // if it failed not much I can so
    catch(Exception ec) {
        display("Error connectiong to server:" + ec);
        return false;
    }

    String msg = "Connection accepted " + socket.getInetAddress() + ":" + socket.getPort();
    display(msg);

    try
    {

        sInput  = new ObjectInputStream(socket.getInputStream()); //<-------- block here
        sOutput = new ObjectOutputStream(socket.getOutputStream());
    }
    catch (IOException eIO) {
        display("Exception creating new Input/output Streams: " + eIO);
        return false;
    }

    return true;

}

public static void main(String[] args) {

    MyClassSocket client = new MyClassSocket("localhost",1025,"PieroJava");
    client.start();
}

}

代码卡住在我在上面代码中注释的地方，我可以在服务器终端中看到有一个新连接，并且我可以在客户端中看到我连接但不要在这里:

sInput  = new ObjectInputStream(socket.getInputStream());

我该怎么办？

Answer 1

我建议不要使用ObjectInputStream和ObjectOutputStream。无论如何，让它们与 Python 服务器良好地交互可能是具有挑战性的，而且它们无论如何也没有实现非常好的协议(protocol)。我推荐一个更简单的协议(protocol)，具有更好的跨语言支持，例如 AMP .

无论如何，new ObjectInputStream 似乎会阻塞，直到它可以从连接读取字节。如果您想让它成功，您的基于 Twisted 的服务器将需要将 Java 对象流的开头写入连接。