Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- package Server;
- import java.io.BufferedReader;
- import java.io.IOException;
- import java.io.InputStreamReader;
- import java.io.PrintWriter;
- import java.net.ServerSocket;
- import java.net.Socket;
- import java.util.ArrayList;
- public class Server
- {
- final int PORT = 3547;
- ServerSocket serverSocket;
- Socket socket;
- ArrayList<ComputerConnections> comCon = new ArrayList<ComputerConnections>();
- public static void main(String[] args) throws IOException
- {
- new Server().start();
- }
- public void start() throws IOException
- {
- serverSocket = new ServerSocket(PORT);
- while (true)
- {
- try {
- socket = serverSocket.accept();
- comCon.add(new ComputerConnections(socket));
- new Thread(new ServerHandler()).start();
- } catch (IOException ex) {
- ex.printStackTrace();
- }
- }
- }
- private class ServerHandler implements Runnable
- {
- public void run()
- {
- String message = null;
- try {
- BufferedReader bufferedReader = new BufferedReader(new InputStreamReader(socket.getInputStream()));
- while ((message = bufferedReader.readLine()) != null)
- {
- for (ComputerConnections ccc: comCon)
- {
- ccc.printWriter.println(message);
- ccc.printWriter.flush();
- }
- }
- bufferedReader.close();
- } catch (IOException ex) {
- ex.printStackTrace();
- }
- }
- }
- private class ComputerConnections
- {
- Socket socket;
- PrintWriter printWriter;
- public ComputerConnections(Socket socket)
- {
- this.socket = socket;
- go();
- }
- public void go()
- {
- try {
- printWriter = new PrintWriter(socket.getOutputStream(), true);
- } catch (IOException ex) {
- ex.printStackTrace();
- }
- }
- }
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement