Сервер на несколько клиентов

@DiViLoYs · Регистрация: 27.03.2013

Author24 — интернет-сервис помощи студентам

Здравствуйте, появилась проблема. Как из того сервера,что я сделал, который принимает только одного клиента, можно сделать много. Погуглил, немного, ответы вроде бы как и есть, но я все равно не понимаю как добавить несколько клиентов к серверу.

Код сервера

Java

package serverforgame;
import java.net.*;
import java.io.*;
 
 
/**
 *
 * @author User
 */
public class Server
{
    ServerSocket ss;
    int port = 6666;
    private String serverstatus = null;
    DataInputStream in;
    DataOutputStream out;
    String answer = null;
    Socket socket1;
    
    
    
    
    public String getStatusServer()
    {
        return serverstatus;
    }
    public void serverStart()
    {
        try
        {
        ss = new ServerSocket(port);
        }catch(Exception e){}
        
    }
    public String userConection()
    { 
        String res = null;
        try{
            
            
            
            
            System.out.println(serverstatus);
           
            socket1 = ss.accept();
          
           
           
            System.out.println(serverstatus);
            
            // Берем входной и выходной потоки сокета
            InputStream sin1 = socket1.getInputStream();
            OutputStream sout1 = socket1.getOutputStream();
 
            // Конвертируем потоки в другой тип
            in = new DataInputStream(sin1);
            out = new DataOutputStream(sout1);         
            System.out.println(serverstatus);
            
            
           
         
                res = "Client connected.....";
         
            
            
         
    
            
        }
        catch(Exception e)
        {
            e.getStackTrace();
        }
    
    return res;
    }
 
    public String serverTalker()
    {
    
        try{
            
             serverstatus = "Waiting message";
             System.out.println(serverstatus);
            answer = in.readUTF();                       
            out.writeUTF(answer);
            out.flush(); 
            serverstatus = "Answered";
            System.out.println(serverstatus);
           
           
           
           
            }catch(Exception e)
            {
                  e.getStackTrace();
             }
    
        return answer;
    }
         
   
  
   
   
}

И клиент

Java

package clientforgame;
import java.net.*;
import java.io.*;
/**
 *
 * @author User
 */
public  class Client {
    
   
   private static String address = "127.0.0.1";
   int serverPort = 6666;
   Socket socket;
   DataInputStream in;
   DataOutputStream out;
   
 
   
     
    public void createConnect (){
    
    try{
    
    
     InetAddress ipAddress = InetAddress.getByName(address);
     socket = new Socket(ipAddress, serverPort);
    
    InputStream sin = socket.getInputStream();
    OutputStream sout = socket.getOutputStream();
 
            
    in = new DataInputStream(sin);
    out = new DataOutputStream(sout);
   
    
    
    
    }catch(Exception e){}
    
    }
  
    public void sendMessage(String message){
       
    try{
            
            
            out.writeUTF(message);
            out.flush();
            
    
    
    
    }catch(Exception e){}
    
    }
    
    public String receivMessage(){
        String mesg = null;
        try{
            
            
            mesg = in.readUTF();
            
    
    
    
            }catch(Exception e){}
    return mesg;
    }
 
}

@LeX · 06.08.2016, 22:34

Самый простой вариант - обрабатывать каждое соединение в отдельном потоке, а ss.accept() завернуть в цикл (например бесконечный):

Java

            while(true) {
                socket1 = ss.accept();
                new Thread(new Runnable() {
                    @Override
                    public void run() {
                        performConnection(socket1);
                    }
                }).start();
            }

@ViktorFX · 28.02.2017, 03:55

Не подскажете как в этом бесконечном while() распараллелить потоки(буфера) ввода/вывода а то сервер посылает список из (наперед неизвестно) 10-ти(строк, элем..) а в клиента принимает всего 1 поток, и возникает разница ввода/вывода потоков.
Спасибо.

@LeX · 28.02.2017, 23:00

Ничего не понял

@ViktorFX · 01.03.2017, 02:00

К примеру вот сервер, метод run:

Java

while(true) {
                string = in1.readLine();
                
                if(string.equalsIgnoreCase("exit")) break;
                if(string.equalsIgnoreCase("help")) {
                    // на запрос "help" вывесли список строчек
                    lambd_out.lam_2().forEach(i -> out1.println(i));
                }
                System.out.println("Client : " + string);
                out1.println("Echo.. " + string);
            }

Это к нему лямбда(ы) для "другого потока" или параллельной задачи

Java

interface Lambda_server {
    void lam_1();
    default List<String> lam_2() {
        List<String> a = Arrays.asList("menu : show you menu", "help : show you all command", "exit : exit(for client)", 
                "set_name : set you names to server names system", "get_ID : shows your ID in server's system", 
                "list<get>, list<set> : it's meta command looks like : <command> , with more stream-lines, and with <end> in ends list's", 
                "send<all> : send massege to all client", "send<name> : send message to client with name's");
        return a;
    }
}

С сервером все Ок, Лямбда посылает список строк (если быть точным то один поток построчно посылает весь список но в параллельном выполнении).
Но я не могу правильно все это принять на клиенте. На клиенте надо нажимать Enter чтобы построчно выводился весь список.
Что я делаю на клиенте :

Java

while ((str1 = in_out.readLine()) != null) {
                out1.println(str1);
                if(str1.equalsIgnoreCase("exit")) break;
                if(str1.equalsIgnoreCase("help")) {
                    l_client.lam_2(in1);
                }
str2 = in1.readLine();
System.out.println(str2);
}

где

Java

interface Lambda_client {
    void lam_1();
    default void lam_2(BufferedReader a) throws IOException{
        String b = a.readLine();
        System.out.println(b);
    }
}

По всей видимости именно lam_2 неправильно реализована.
Спасибо за отклик.
П.С. как отвечать адрессно?

Добавлено через 1 час 55 минут
Пару дней я добирался к этому решению и именно теперь, после взгяда со стороны, я его нашел.
Если кому интересно, то я просто на сервере добавил out1.println("end_stack"); в конец в тело условия с хэлпом
А на клиенте добавил в условие с хэлпом, бесконечный цикл с выходом if((l_client.lam_2(in1)).equalsIgnoreCase("end_stack")) break; и конечно же поменял возвращаемый параметр лямбды.
В любом случае спасибо.

@ViktorFX 528 / 263 / 70 Регистрация: 11.12.2016 Сообщений: 1,223
	28.02.2017, 03:55	3
	Не подскажете как в этом бесконечном while() распараллелить потоки(буфера) ввода/вывода а то сервер посылает список из (наперед неизвестно) 10-ти(строк, элем..) а в клиента принимает всего 1 поток, и возникает разница ввода/вывода потоков. Спасибо. 0

@LeX 378 / 370 / 114 Регистрация: 30.06.2010 Сообщений: 1,445
	28.02.2017, 23:00	4
	Ничего не понял 0

	01.03.2017, 02:00