Передача сообщения всем подключенным клиентам

@Yosido · Регистрация: 23.02.2009

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

есть класс сервера

Java
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
package simplenetserver;
 
/*
 * To change this template, choose Tools | Templates
 * and open the template in the editor.
 */
 
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.ArrayList;
import java.util.Scanner;
import java.util.logging.Level;
import java.util.logging.Logger;
 
/**
 *
 * @author Yosido */
public class Main extends Thread {
 
    private static ServerSocket ServSock;
    private ArrayList<InputStream> m_is_is = null;
    private ArrayList<OutputStream> m_ou_out = null;
    private int clientCount = 0;
    public Main()
    {
            m_is_is= new ArrayList<InputStream>();
            m_ou_out=new ArrayList<OutputStream>();
    }
 
    public void spam(String arg) throws IOException
    {
     for(int i=0;i<m_ou_out.size();i++)
        {
           DataOutputStream send= new DataOutputStream(m_ou_out.get(i));
           send.writeUTF(arg);
           System.out.println("send");
           System.out.println(i);
        }
    }
 
public void run(){
        try {
            Socket Sock = ServSock.accept();
            System.out.print("client connectec ");
            clientCount++;
            System.out.println(clientCount);
            System.out.println(Sock.getInetAddress().toString());
            InputStream m_is = Sock.getInputStream();
            OutputStream m_out = Sock.getOutputStream();
            DataInputStream qwe = new DataInputStream(m_is);
            DataOutputStream toClient= new DataOutputStream(m_out);
            m_is_is.add(m_is);
            m_ou_out.add(m_out);
            System.out.println(m_ou_out.size());
            new Main().start();
 
            while(true)
            {
                Scanner in=new Scanner(System.in);
                String send=in.nextLine();
                spam(send);
            }
        } catch (IOException ex) {
            Logger.getLogger(Main.class.getName()).log(Level.SEVERE, null, ex);
        }
}
    /**
     * @param args the command line arguments
     */
    public static void main(String[] args) {
        try {
            // TODO code application logic here
            ServSock = new ServerSocket(3333);
        } catch (IOException ex) {
            Logger.getLogger(Main.class.getName()).log(Level.SEVERE, null, ex);
        }
        new Main().start();
 
    }
 
}

функция spam(String arg) должна отправлять сообщение всем клиентам, выгребая их OutputStream из списка всех OutputStream. Кроме того размер этого списка равен 1 при любом количестве подключенных клиентов.

клиенты подключаются через telnet localhost 3333

Подскажите пожалуйста.

@XHelp · 22.06.2011, 03:15

Уж очень странная архитектура и с ней ты намучаешся, даже если найдёш какое нибудь решение поставленной задачи.
Ооооочень упращённый вариант и не самый элегантный:

Java
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
class SuperServer extends Thread {
  List<ServerWorker> workerList;
  ....
  public void run() {
    while (isRunning) {
      Socket client = serverSocket.accept();
      ServerWorker worker = new ServerWorker(client, this);
      workerList.add(worker);
      worker.start();
    }
  }
  public void sendToAll(String text) {
    for (ServerWorker currentWorker: workerList) {
      currentWorker.sendText(text);
    }
  }
}

Java
1
2
3
4
5
6
class ServerWorker extends Thread {
  private SuperServer superServer;
  private Socket socket;
......
    superServer.sendToAll("test 12345");
}

Суть должны быть видна - разбить всё на конкретные части, а не сервер пораждающий сам себя с static переменными.

@Yosido · 23.06.2011, 12:16 **[ТС]**

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

Добавлено через 10 часов 29 минут

Java
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
/*
 * To change this template, choose Tools | Templates
 * and open the template in the editor.
 */
 
package newpackage;
 
/**
 *
 * @author Yosido
 */
/*
 * To change this template, choose Tools | Templates
 * and open the template in the editor.
 */
 
import java.io.*;
import java.net.*;
 
class SServer extends Thread {
   private Socket socket;
   private DataInputStream in;
   private DataOutputStream out;
 
   public SServer(Socket s) throws IOException {
      socket = s;
      in = new DataInputStream(socket.getInputStream());
      out = new DataOutputStream(socket.getOutputStream());
      start();
   }
 
   public void run() {
      try {
         while (true) {
            String str = in.readLine();
            if (str.equals("END"))
               break;
            System.out.println("Echoing: " + str);
            out.writeUTF(str);
            out.flush();
         }
         System.out.println("closing...");
      }
      catch (IOException e) {
         System.err.println("IO Exception");
      }
      finally {
         try {
            socket.close();
         }
         catch (IOException e) {
            System.err.println("Socket not closed");
         }
      }
   }
}
 
public class MultiServer {
   static final int PORT = 3434 ;
   static int clientCount = 0 ;
   public static void main(String[] args) throws IOException {
      ServerSocket s = new ServerSocket(PORT);
      System.out.println("Server Started");
      try {
         while (true) {
            Socket socket = s.accept();
            try {
               new SServer(socket);
               clientCount++;
               System.out.println(clientCount+" клиентов");
            }
            catch (IOException e) {
               socket.close();
            }
         }
      }
      finally {
         s.close();
      }
   }
}

Создание эхо-сервера не составляет проблем. Как поступить чтобы сервер слушал ввод с клавиатуры, и отправлял строку всем клиентам?

Если в этом фрагменте

Java
1
2
3
4
5
6
Socket socket = s.accept();
            try {
               new SServer(socket);
               clientCount++;
               System.out.println(clientCount+" клиентов");
            }

Если создаю вектор из объектов SServer, то программа перестает работать.

@XHelp · 23.06.2011, 14:56

А что значит "перестаёт работать"?
Если ты хочеш какой нибудь пользовательский интерфейс, то тебе лучше вынести его в отдельный класс. Но у тебя и до сих пор архитектура не очень практичная. Нужно для начала сделать так, что бы в main-методе у тебя было только:

Java
1
new MultiServer().start();

@Yosido · 23.06.2011, 17:40 **[ТС]**

Это будет консольным приложением, поэтому потребности в интерфейсе нет.

Разнес все по классам.

Main.java

Java
1
2
3
4
5
public class Main {
    public static void main(String[] args) throws IOException {
        MultiServer ms=new MultiServer();
    }
}

MultiServer.java

Java
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.Vector;
 
/**
 *
 * @author Yosido
 */
public class MultiServer {
   static final int PORT = 3434 ;
   static int clientCount = 0 ;
   static Vector<SServer> m_v_theads;
   static SServer m_thread;
 
    public MultiServer() throws IOException
    {
      m_v_theads=new  Vector<SServer>();
      ServerSocket s = new ServerSocket(PORT);
      System.out.println("Server Started");
      try {
         while (true) {
            Socket socket = s.accept();
            try {
               m_thread=new SServer(socket);
               clientCount++;
               System.out.println(clientCount+" клиентов");
               //m_thread.start();
               System.out.println("2");
               m_v_theads.add(m_thread);
               //m_thread.start();
               System.out.println("added"+ m_v_theads.size());
            }
            catch (IOException e) {
               socket.close();
            }
         }
      }
      finally {
         s.close();
      }
   }
}

SServer.java

Java
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
import java.io.*;
import java.net.*;
import java.util.Vector;
/**
 *
 * @author Yosido
 */
class SServer extends Thread {
   private Socket socket;
   private DataInputStream in;
   private DataOutputStream out;
 
   public SServer(Socket s) throws IOException {
      socket = s;
      in = new DataInputStream(socket.getInputStream());
      out = new DataOutputStream(socket.getOutputStream());
      start();
   }
 
   public void run() {
      try {
         while (true) {
            String str = in.readUTF();
            if (str.equals("END"))
               break;
            System.out.println("Echoing: " + str);
            out.writeUTF(str);
            out.flush();
         }
         System.out.println("closing...");
      }
      catch (IOException e) {
         System.err.println("IO Exception");
      }
      finally {
         try {
            socket.close();
         }
         catch (IOException e) {
            System.err.println("Socket not closed");
         }
      }
   }
}

Где сделать чтение с клавиатуры строки и отправку её всем клиентам?

@Yosido · 24.06.2011, 21:13 **[ТС]**

Разобрался, всё заработало.

Новые блоги и статьи Все статьи Все блоги /
Ритм жизни kumehtar 27.02.2026 Иногда приходится жить в ритме, где дел становится всё больше, а вовлечения в происходящее — всё меньше. Плотный график не даёт вниманию закрепиться ни на одном событии. Утро начинается с быстрых,. . .	SDL3 для Web (WebAssembly): Сборка SDL3 и Box2D из исходников с помощью CMake и Emscripten 8Observer8 27.02.2026 Недавно вышла версия 3. 4. 2 библиотеки SDL3. На странице официальной релиза доступны исходники, готовые DLL (для x86, x64, arm64), а также библиотеки для разработки под Android, MinGW и Visual Studio. . . .	SDL3 для Web (WebAssembly): Реализация движения на Box2D v3 - трение и коллизии с повёрнутыми стенами 8Observer8 20.02.2026 Содержание блога Box2D позволяет легко создать главного героя, который не проходит сквозь стены и перемещается с заданным трением о препятствия, которые можно располагать под углом, как верхнее. . .	Конвертировать закладки radiotray-ng в m3u-плейлист damix 19.02.2026 Это можно сделать скриптом для PowerShell. Использование . \СonvertRadiotrayToM3U. ps1 <path_to_bookmarks. json> Рядом с файлом bookmarks. json появится файл bookmarks. m3u с результатом. # Check if. . .
Семь CDC на одном интерфейсе: 5 U[S]ARTов, 1 CAN и 1 SSI Eddy_Em 18.02.2026 Постепенно допиливаю свою "многоинтерфейсную плату". Выглядит вот так: https:/ / www. cyberforum. ru/ blog_attachment. php?attachmentid=11617&stc=1&d=1771445347 Основана на STM32F303RBT6. На борту пять. . .	Камера Toupcam IUA500KMA Eddy_Em 12.02.2026 Т. к. у всяких "хикроботов" слишком уж мелкий пиксель, для подсмотра в ESPriF они вообще плохо годятся: уже 14 величину можно рассмотреть еле-еле лишь на экспозициях под 3 секунды (а то и больше),. . .	И ясному Солнцу zbw 12.02.2026 И ясному Солнцу, и светлой Луне. В мире покоя нет и люди не могут жить в тишине. А жить им немного лет.	«Знание-Сила» zbw 12.02.2026 «Знание-Сила» «Время-Деньги» «Деньги -Пуля»

@Yosido 0 / 0 / 0 Регистрация: 23.02.2009 Сообщений: 7
	24.06.2011, 21:13 [ТС]
	Разобрался, всё заработало. 0