客户端-服务器套接字

Question

我试图用java实现一个客户端服务器，在这里我读取客户端中的输入并在服务器中执行UperCase，然后返回客户端并打印UperCase。我使用ObjectOutputStream和ObjectInputStream进行读写，但是当我在客户机中键入一个msg时，程序会显示以下错误：

Digite uma msg casa java.io.eofexception位于java.io.datainputstream.readunsignedshort（未知源）位于java.io.objectinputstream$blockdatainputstream.readunsignedshort（未知源）位于java.io.objectinputstream$blockdatainputstream.readutf（未知源）位于java.io.objectinputstream$blockdatainputstream.readutf（未知源）位于

我的客户端是这样的：

package Client.java;

import java.io.IOException;
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
import java.net.Socket;
import java.net.UnknownHostException;
import java.util.Scanner;

public class Client {

    public static void main(String[] args) {

        //estabelece conexao 
        // trocar msg com o server

        try {
            //cria conexao entre  client e servidor
            Socket socket = new Socket("localhost",5558);

            //cria input and output
            ObjectOutputStream output = new ObjectOutputStream(socket.getOutputStream());
            ObjectInputStream input = new ObjectInputStream(socket.getInputStream());

            Scanner scan = new Scanner(System.in);
            System.out.println("Digite uma msg");
            String word = scan.nextLine();
            output.writeUTF(word);
            output.flush();
            word = input.readUTF();
            System.out.println("Upercase"+ word);

            input.close();
            output.close();
            socket.close();

        } catch (UnknownHostException e) {
            e.printStackTrace();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

这是我的服务器端：

package Server;

import java.io.IOException;
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
import java.net.Socket;
import java.net.ServerSocket;

public class Servidor {

    private ServerSocket servidor;

    private void criarServerSocket(int porta) throws IOException {
        servidor = new ServerSocket(porta);
    }

    private Socket esperaConexao() throws IOException
    {
        Socket socket = servidor.accept();
        return socket;
    }

    private void fechaSocket(Socket s) throws IOException {
        s.close();
    }

    private void trataConexao(Socket socket) throws IOException {
        //*recebe e envia msg */

        try {
            ObjectOutputStream output = new ObjectOutputStream(socket.getOutputStream());
            ObjectInputStream input = new ObjectInputStream(socket.getInputStream());

            String msg = input.readUTF();
            output.writeObject(msg.toUpperCase());
            output.flush();

            input.close();
            output.close();
        } catch (IOException e) {
            // TODO Auto-generated catch block
        }

        fechaSocket(socket);
    }

    public static void main(String[] args) throws IOException {
        // TODO Auto-generated method stub

        Servidor server = new Servidor();
        System.out.println("Wait for a connection");
        server.criarServerSocket(5558);
        System.out.println("Conectado ");
        Socket socket = server.esperaConexao();
        server.trataConexao(socket);
    }
}

我的服务器要关闭流了吗？我怎么能修复它，还在关闭溪流？谢谢你的帮助。

Answer 1

您应该在Servidor中使用

output.writeUTF(msg.toUpperCase());

而不是

output.writeObject(msg.toUpperCase());