Serve Socket – Java – Fórum – Programujte.com

Ahoj, v jave se snažím o úplně jednoduchou komunikaci klient server pomocí socketů. Server spustím, spustím klienta, server vypíše že se klient připojil, pošlu zprávu, server jí vypíše. Můj problém nastává, když se klientů připojí víc. Klient který je první v ArrayListu muže psát kolik chce a server to vypisuje, ale pokud něco napíše klient spustěný jako druhý jeho text se vypíše až po odeslání zprávy od klienta číslo jedna. Pokud se připojí klienti tři je v tom chaos ještě větší. Mě už nic nenapadá tak bych byl vděčný za každé nakopnutí správným směrem. Předem dík.

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.ArrayList;

public class Server2 {
    
    private ServerSocket serverSocket;
    private ArrayList<BufferedReader> listOfBuffer = new ArrayList<>();
    private static int port = 9939;
    
    public Server2() {
        try {
            serverSocket = new ServerSocket(port);
            listen();
        }catch(IOException ex) {
            System.out.println(ex);
        }
    }
    
    private void clientListen() {
        try {
            Socket clientSocket = serverSocket.accept();
            listOfBuffer.add(new BufferedReader(new InputStreamReader
                    (clientSocket.getInputStream())));
            System.out.println("client: " 
                    + clientSocket.getInetAddress().getHostAddress()
                    + " has been connection");
        }catch(IOException ex) {
            System.out.println(ex);
        }
    }
    
    private synchronized void dataRead() {
        for(int i = 0; i<listOfBuffer.size(); i++) {
            try {
                BufferedReader br = listOfBuffer.get(i);
                String data = br.readLine();
                if(data == null) {               
                    listOfBuffer.remove(i);
                }else {
                    System.out.println(data);
                }
            }catch(IOException ex) {
                System.out.println(ex);
            }
        }
    }
    
    private void listen() {
        Thread vlakno1 = new Thread(new Runnable() {

            @Override
            public void run() {
                while(true) {
                    clientListen();
                }
            }
        });
        vlakno1.start();
        
        while(true) {
            dataRead();
        }
    }
    
    public static void main(String[] args) {
        Server2 server = new Server2();
    }
}

Nejspíš je to tím, že soket je blokující.

#2 liborb

Co vím tak blokující je "serverSocket.accept();" a tím bych řekl že to není, protože pokaždé když připojím dalšího klienta server okamžitě reaguje výpisem.

#3 Whowky
to muze byt zpusobeno tim, ze to mas v separatnim threadu

Vyřešeno pomocí ServerSocketChannel a nastavení jako neblokující socket. Dík za rady   

import java.io.IOException;
import java.net.InetSocketAddress;
import java.nio.ByteBuffer;
import java.nio.channels.Channel;
import java.nio.channels.SelectionKey;
import java.nio.channels.Selector;
import java.nio.channels.ServerSocketChannel;
import java.nio.channels.SocketChannel;
import java.util.Iterator;
import java.util.Set;

public class ChatServer {
    
    private ServerSocketChannel serverSocketChannel;
    private ByteBuffer buffer = ByteBuffer.allocateDirect(1024);
    private Selector selector;
    private Set<SelectionKey> keys;
    private static final int PORT = 9939;
    
    protected void start() {
        try {
            serverSocketChannel = ServerSocketChannel.open();
            serverSocketChannel.configureBlocking(false);
            serverSocketChannel.socket().bind(new InetSocketAddress(PORT));
            selector = Selector.open();
            serverSocketChannel.register(selector, SelectionKey.OP_ACCEPT);
            
            while(serverSocketChannel.isOpen()) {
                selector.select();
                keys = selector.selectedKeys();
                Iterator<SelectionKey> i = keys.iterator();
                while(i.hasNext()) {
                    SelectionKey key = i.next();
                    i.remove();
                    Channel chan = key.channel();
                    if(chan == serverSocketChannel) {
                        SocketChannel client = serverSocketChannel.accept();
                        if(client != null) {
                            client.configureBlocking(false);
                            client.register(selector, SelectionKey.OP_READ);
                        }
                    }else {
                        SocketChannel client = (SocketChannel) chan;
                        int read = 0;
                        while(read >= 0) {
                            buffer.rewind();
                            read = client.read(buffer);
                            buffer.rewind();
                            for(int j = 0; j < read; j++) {
                                System.out.print((char)buffer.get(j));
                            }
                        }
                    }
                }
            }
        }catch (IOException ex) {
            System.out.println(ex);
        }
    }
    
    public static void main(String[] args) {
        new ChatServer().start();
    }
}

Sice pozdě, ale kdyby někdo chtěl zdroják...