服务器-客户端通信与套接字Java

Question

我有这个代码可以在eclipse中与android Studio中的客户端通信服务器，我使用套接字，客户端向服务器发送消息，服务器读取该消息并确定一切正常，但当服务器向客户端发送消息时，客户端不强制任何东西；这是代码

public class Servidor {
ServerSocket servidor=null;
String funcion;
public static Socket socket;
BufferedReader lector=null;
RegUser registrar=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();
            escribir();
        }

        }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(){
        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")){
                    RegUser registrar=new RegUser();
                    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(){
    Thread escribir_hilo=new Thread(new Runnable(){
        public void run(){
                try{
                    escritor= new PrintWriter(socket.getOutputStream(),true);
                    escritor.println(funcion);
                    System.out.println(funcion);
                }catch(Exception ex){
                    ex.printStackTrace();
                }


        }
    });
    escribir_hilo.start();
}

还有这个

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

}
public void newUser(JsonElement elemento){
    Servidor respuesta=new Servidor();
    //respuesta=new Servidor();
    String user=elemento.getAsJsonObject().get("nombre").getAsString();
    if(comparar.UserComp(user)){
        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);
        funcion=enviar_mensaje.toString();
        escribir();

        }
    else
    {
        JsonObject comp = new JsonObject();
        comp.addProperty("tipo","registro");
        comp.addProperty("estado","existe");
        String comparar=gson.toJson(comp);
        funcion=comparar.toString();
        escribir();
    }

}

此代码是服务器代码的一部分，如果您需要客户端代码（Android Studio），请告诉我。

我需要帮助拜托

Answer 1

如果您能够在C#服务中托管您的服务器，我已经创建了一个支持1000个连接的开源项目，包括一个保活协议（AKA心跳协议）、一个可以轻松扩展的身份验证模型以及Java、Objective-C和C#API。留档包括Android、iOS和Windows Mobile的示例。您可以在这里找到它。

Answer 2

你不可能

多客户端服务器架构中服务器上的公共静态套接字。服务器在“接受”方法中创建客户端套接字。

想想多个客户端连接到单个服务器的场景。如果您在服务器上有静态Socket，它只能服务器套接字。那么如何处理连接到服务器的“N”个客户端？

>

删除Servidor中的静态套接字

在接受（）方法后创建套接字时，将套接字传递给需要套接字的leer（）和escribir（）方法。