我有这个代码在eclipse中与服务器在android studio中的客户端进行通信,我使用套接字,客户端发送消息到服务器,服务器读取消息并确定一切正常,但是当服务器向客户端发送消息时,客户端不会收回任何东西;这是代码服务器 - 与套接字的客户端通信Java
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中),请告诉我。
我需要帮助,请
我可以使用公共Socket套接字; ?? –
这也不服务于目的。每个客户端应该有一个套接字。如果100个客户端连接到服务器,则服务器应该有100个套接字来处理每个客户端。 –
请参阅我的答案和评论http://stackoverflow.com/questions/32542152/java-error-with-a-printwriter –