Сообщение не отправлено на сервер от клиента - Java

Question

У меня есть программа Server-Client, где я отправляю небольшую почту клиенту с помощью JLabel. Когда это сообщение получает от сервера, тот конкретный клиент должен немедленно отправить ответ. Но он не отправляет никаких сообщений. Может кто-нибудь посмотреть на мой код и рассказать мне, где моя ошибка?

// SERVER

void connect_clients() 
    { 
     try { 
      ServerSocket listener = new ServerSocket(7700); 
      jButton1.setText("Server Running!"); 
      jButton1.setEnabled(false); 
       while (true) { 

        socket = listener.accept(); 
        socketList.add(socket); 
        //socketList.add(listener.accept()); 
        BufferedReader ed = new BufferedReader(new InputStreamReader(socket.getInputStream())); 
      String tmp = ed.readLine(); 
      System.out.print("I Recieved :"+tmp); 

       } 

      } 
     catch(IOException ex) 
     { 
      JOptionPane.showMessageDialog(null,ex); 
     } 
    } 

// КЛИЕНТ

void connect_server() throws IOException 
    { 
     try { 
      // TODO code application logic here 
      String serverAddress = JOptionPane.showInputDialog(
        "Enter IP Address of a machine that is\n" + 
          "running the date service on port 9090:"); 
      s = new Socket(serverAddress, 7700); 

      while(true){ 
      BufferedReader input = 
      new BufferedReader(new InputStreamReader(s.getInputStream())); 
      String answer = input.readLine(); 
      System.out.println(answer); 
       if(answer != null) 
       { 
        PrintStream pr = new PrintStream(s.getOutputStream()); 
        InputStreamReader rd = new InputStreamReader(System.in); 
        BufferedReader ed = new BufferedReader(rd); 
        String temp = ed.readLine(); 
        pr.println(temp); 

        JOptionPane.showMessageDialog(null,"Answer is not null"); //THIS WORKS 
       } 

      } 

      } 
     catch (ConnectException e) { 

      JOptionPane.showMessageDialog(null, e); 
     } 
     catch (SocketException e) { 

      JOptionPane.showMessageDialog(null, e); 
     } 
    } 

Answer 1

Некоторые моменты, которые вы пропустили в своей реализации:

• потоки и розетки никогда не закрыты
• в клиент я не вижу точки бесконечного цикла
• клиент должен инициализировать связь, отправив сообщение через выходной поток (не пытаться прочитать первый)

Для простого примера шаги должны быть:

1. Начало разъединить слушать и после того, как установлено соединение для чтения сообщения (вы сделали)
2. Клиент должен отправить сообщение через выходной поток и закрыть пары и розетку
3. Отверстия должны закрыть потоки и опору для эста blished соединение

Пример:

//Server 
socket = listener.accept(); 
BufferedReader ed = new BufferedReader(new InputStreamReader(socket.getInputStream())); 
BufferedWriter pr = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream()); 
String tmp = ed.readLine(); 
System.out.print("I Recieved :"+tmp); 
String msg = "Message received"; 
pr.write(msg,0,msg.length()); 
pr.newLine(); 
ed.close(); 
pr.close(); 
socket.close(); 

//Client 
BufferedWriter pr = new BufferedWriter(new OutputStreamWriter(s.getOutputStream()); 
BufferedReader input = new BufferedReader(new InputStreamReader(s.getInputStream())); 
String sendMessage = "Send Message"; 
pr.write(msg,0,msg.length()); 
pr.newLine(); 
String answer = input.readLine(); 
System.out.println(answer); 
JOptionPane.showMessageDialog(null,"Answer is not null"); 
input.close(); 
pr.close(); 
s.close(); 

ОБНОВЛЕНИЕ

чтения из входного потока непрерывно:

BufferedReader input = new BufferedReader(new InputStreamReader(s.getInputStream())); 
String line; 
while((line=input.readLine())!=null){ 
    //do something with line 
} 

Answer 2

я предложить простой подход, при котором сервер посылает привет Сообщ к клиенту.

Для сервера:

//Server 
ServerSocket ss=new ServerSocket(3554); 
socket = ss.accept(); 
BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream())); 
BufferedReader br = new BufferedReader(new InputStreamReader(socket.getOutputStream())); 
String msg ="Hi from server" 
bw.write(msg); 
String msgFromClient=br.readLine(); 
System.out.println(msgFromClient); 
bw.close(); 
socket.close(); 

Для клиентов:

//Client 
Socket socket=new Socket("localhost",3554) 
BufferedReader br = new BufferedReader(new InputStreamReader(socket.getInputStream())); 
BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream())); 
String received = input.readLine(); 
System.out.println(received); 
bw.write("Client recieve :"+received); 
br.close(); 
bw.close(); 
socket.close();