PrintWriter 的 Java 错误 [重复]

Question

我有这段代码来连接服务器和客户端，我需要将 json 对象发送到 android studio 客户端，但是 printwriter 行中的方法 escribir 有错误，我不知道是什么问题，请参阅代码并帮助我

public class Servidor {
ServerSocket servidor=null;
Socket socket=null;
BufferedReader lector=null;
PrintWriter escritor=null;
Gson gson = new Gson();
public Servidor(){

}
public static void main(String[] args) {
    Servidor Server=new Servidor();
    Server.iniciarHilo();
}
public void iniciarHilo(){

Thread principal=new Thread(new Runnable(){
    public void run(){
        try{
        servidor=new ServerSocket(8080);
        while(true){
            socket=servidor.accept();
            leer();
        }
        }catch(Exception ex){
            ex.printStackTrace();
        }
    }
});
principal.start();
System.out.println("Servidor iniciado......");
}
public void leer(){
    Thread leer_hilo=new Thread(new Runnable(){
    public void run(){
        RegUser registrar=new RegUser();
        try{
            lector=new BufferedReader(new InputStreamReader(socket.getInputStream()));
            while(true){
                JsonParser parser = new JsonParser();
                String mensaje= lector.readLine();
                JsonElement elemento = parser.parse(mensaje);
                String mensaje_in=elemento.getAsJsonObject().get("tipo").getAsString();
                if (lector==null){
                    System.out.println("Conexion Interrumpida....");
                }
                if (mensaje_in.equals("registrar")){
                    System.out.println("Solicitud de Registro");
                    registrar.newUser(elemento);
                }
                else if (mensaje_in.equals("ingresar")){
                    System.out.println("Solicitud de Ingreso");
                }


            }
        }catch(Exception ex){
            ex.printStackTrace();
        }
    }

});
    leer_hilo.start();
}
public void escribir(final String dato){
    Thread escribir_hilo=new Thread(new Runnable(){
        public void run(){
            try{
                escritor= new PrintWriter(socket.getOutputStream());
                escritor.println(dato);
            }catch(Exception ex){
                ex.printStackTrace();
            }
        }
    });
escribir_hilo.start();
}

还有这个

public class RegUser {
Gson gson = new Gson();
ListaEnlazada listaUsuarios;
Comparar comparar=new Comparar();
public RegUser(){

}
public void newUser(JsonElement elemento) throws IOException{
    Servidor respuesta=new Servidor();
    //respuesta=new Servidor();
    String user=elemento.getAsJsonObject().get("nombre").getAsString();
    //boolean result=comparar.UserComp(user);
    if(true){
        listaUsuarios=new ListaEnlazada();
        listaUsuarios.add(elemento);
        System.out.println(listaUsuarios.get(0)); 
        JsonObject o = new JsonObject();
        o.addProperty("tipo", String.valueOf("registro"));
        o.addProperty("estado", String.valueOf("completo"));
        String enviar_mensaje = gson.toJson(o);
        respuesta.escribir(enviar_mensaje);

        }

错误是

  java.lang.NullPointerException

  at Servidor$3.run(Servidor.java:81)
  at java.lang.Thread.run(Thread.java:745)

我通过socket向客户端写入数据时出错，错误在getOutputStream中

Answer 1

socket 是 null，因为您没有设置它。

在尝试使用之前，您需要确保已创建套接字。

Answer 2

1) 一旦服务器套接字接受连接，就会为客户端创建新的套接字。

2) 现在将此套接字作为参数传递给 leer() 方法。不要将它作为成员变量存储在 Servidor 中。您必须在服务器端的许多套接字上进行操作。把这项工作留给 leer() 方法

下面的代码应该改成

socket=servidor.accept();
 leer();

到

 socket=servidor.accept();
 leer(socket);

并且您已经更改了 leer() 方法的签名以接受套接字作为参数：public void leer(Socket socket)

编辑：

3) 在对相关方法执行操作之前，请确保 Socket 在正确的状态下可用。您可以通过跨方法传递 Socket 来实现它，或者传递一些唯一的 Id，它可以检索 Socket。

例如如果将主类中的 Socket 替换为唯一字符串 Id (key) 和 Socket(value) 的 ConcurretnHashMap 并通过跨类和方法传递套接字 id 来检索套接字。

看看工作示例Socket programming