java - 套接字编程 - Java 服务器,C(或其他)客户端 - 服务器给出 "invalid stream header"

标签 java sockets socketserver

服务器(java):

public static void main(String[] args) {


//single threaded for now

try {

    //very magic #
    ServerSocket service = new ServerSocket(33000); 

    while(true) {

    debug("Begin waiting for connection");

    //this spins
    Socket connection = service.accept();

    debug("Connection received from " + connection.getInetAddress().getHostName());

    ObjectOutputStream out = new ObjectOutputStream(connection.getOutputStream());
    ObjectInputStream in = new ObjectInputStream(connection.getInputStream());

// ...

客户端 (C) - 这正是 http://www.linuxhowtos.org/data/6/client.c 中的示例代码

int main(int argc, char *argv[])
{
int sockfd, portno, n;
struct sockaddr_in serv_addr;
struct hostent *server;

char buffer[256];
if (argc < 3) {
   fprintf(stderr,"usage %s hostname port\n", argv[0]);
   exit(0);
}
portno = atoi(argv[2]);
sockfd = socket(AF_INET, SOCK_STREAM, 0);
if (sockfd < 0)
    error("ERROR opening socket");
server = gethostbyname(argv[1]);
if (server == NULL) {
    fprintf(stderr,"ERROR, no such host\n");
    exit(0);
}
bzero((char *) &serv_addr, sizeof(serv_addr));
serv_addr.sin_family = AF_INET;
bcopy((char *)server->h_addr,
     (char *)&serv_addr.sin_addr.s_addr,
     server->h_length);
serv_addr.sin_port = htons(portno);
if (connect(sockfd,(struct sockaddr *) &serv_addr,sizeof(serv_addr)) < 0)
    error("ERROR connecting");
printf("Please enter the message: ");
bzero(buffer,256);
fgets(buffer,255,stdin);
n = write(sockfd,buffer,strlen(buffer));
if (n < 0)
     error("ERROR writing to socket");
bzero(buffer,256);
n = read(sockfd,buffer,255);
if (n < 0)
     error("ERROR reading from socket");
printf("%s\n",buffer);
close(sockfd);
return 0;
}

Java 不高兴:

Begin waiting for connection
Connection received from localhost
Fatal Exception: invalid stream header: 68657920
java.io.StreamCorruptedException: invalid stream header: 68657920
        at java.io.ObjectInputStream.readStreamHeader(ObjectInputStream.java:801)
        at java.io.ObjectInputStream.<init>(ObjectInputStream.java:298)
        at Scanner.main(Scanner.java:243)

第 243 行是:

ObjectInputStream in = new ObjectInputStream(connection.getInputStream());

C 客户端与 C 服务器一起工作,C 服务器与我的 Python 客户端一起工作。我编写的类似 Java 服务器也可以与 Java 客户端一起使用。据我所知,有一些神奇的词语可以让 Java 服务器 -> 非 Java 客户端。抱歉,我在谷歌上没有运气,尽管它显然非常基本和简单。谢谢。

最佳答案

您在 Java 端使用 ObjectInputStream,它需要一个非常特定的序列化 Java 对象协议(protocol)。除非您从 C 客户端将正确的格式写入套接字,否则这正是您将得到的错误。您还没有展示如何尝试从流中读取数据,但我怀疑您只是想要一个 BufferedInputStream 。

关于java - 套接字编程 - Java 服务器,C(或其他)客户端 - 服务器给出 "invalid stream header",我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/10201043/

相关文章:

java - 服务器启动客户端?

java - 如何在基于 Spring 的应用程序上使用所有 AspectJ 切入点指示符?

java - JPA CreateEntityManagerFactory() 方法挂起

jakarta-ee - 如何在 Java EE 中创建一个应用程序来监听 TCP/IP 套接字上的传入请求?

qt - QT套接字等待用户输入

sockets - 安装 Node http代理

python - 如何在python中使用SocketServer获取客户端的Name属性?

java - 将数据解析为 DocumentHTML

java - 在 Java 中创建方程组方法

python - SocketServer ThreadingMixIn server_thread 的用途