PrintWriter出现Java错误[重复]

Question

我有这段代码来连接服务器和客户端，我需要将json对象发送到android studio客户端，但是printwriter行中描述的方法有错误，我不知道问题出在哪里，请查看代码并帮助我

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)

我在通过套接字将数据写入客户端时出错，错误在getOutputStream中

Answer 1

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

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

下面的代码应该从

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

到

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

您需要更改leer（）方法的签名以接受socket作为参数：public void leer（socket socket）

编辑：

3）在对其采取行动之前，确保Socket处于相关方法的正确状态。您可以通过跨方法传递Socket或传递一些唯一的Id来实现它，这可以检索Socket。

e、 g.如果用唯一字符串Id（键）和套接字（值）的ConcurrentNHashmap替换主类中的套接字，并通过跨类和方法传递套接字Id来检索套接字。

看看Socket编程的工作示例

Answer 2

套接字是null，因为您没有设置它。

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