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

@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 **[ТС]**

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

Новые блоги и статьи Все статьи Все блоги /
Thinkpad X220 Tablet — это лучший бюджетный ноутбук для учёбы, точка. Programma_Boinc 23.12.2025 Thinkpad X220 Tablet — это лучший бюджетный ноутбук для учёбы, точка. Рецензия / Мнение/ Перевод Сайт называется reddit: The Thinkpad X220 Tablet is the best budget school laptop period. Это. . .	PhpStorm 2025.3: WSL Terminal всегда стартует в ~ and_y87 14.12.2025 PhpStorm 2025. 3: WSL Terminal всегда стартует в ~ (home), игнорируя директорию проекта Симптом: После обновления до PhpStorm 2025. 3 встроенный терминал WSL открывается в домашней директории. . .	Как объединить две одинаковые БД Access с разными данными VikBal 11.12.2025 Помогите пожалуйста !! Как объединить 2 одинаковые БД Access с разными данными.	Новый ноутбук volvo 07.12.2025 Всем привет. По скидке в "черную пятницу" взял себе новый ноутбук Lenovo ThinkBook 16 G7 на Амазоне: Ryzen 5 7533HS 64 Gb DDR5 1Tb NVMe 16" Full HD Display Win11 Pro	Музыка, написанная Искусственным Интеллектом volvo 04.12.2025 Всем привет. Некоторое время назад меня заинтересовало, что уже умеет ИИ в плане написания музыки для песен, и, собственно, исполнения этих самых песен. Стихов у нас много, уже вышли 4 книги, еще 3. . .
От async/await к виртуальным потокам в Python IndentationError 23.11.2025 Армин Ронахер поставил под сомнение async/ await. Создатель Flask заявляет: цветные функции - провал, виртуальные потоки - решение. Не threading-динозавры, а новое поколение лёгких потоков. Откат?. . .	Поиск "дружественных имён" СОМ портов Argus19 22.11.2025 Поиск "дружественных имён" СОМ портов На странице: https:/ / norseev. ru/ 2018/ 01/ 04/ comportlist_windows/ нашёл схожую тему. Там приведён код на С++, который показывает только имена СОМ портов, типа,. . .	Сколько Государство потратило денег на меня, обеспечивая инсулином. Programma_Boinc 20.11.2025 Сколько Государство потратило денег на меня, обеспечивая инсулином. Вот решила сделать интересный приблизительный подсчет, сколько государство потратило на меня денег на покупку инсулинов. . . .	Ломающие изменения в C#.NStar Alpha Etyuhibosecyu 20.11.2025 Уже можно не только тестировать, но и пользоваться C#. NStar - писать оконные приложения, содержащие надписи, кнопки, текстовые поля и даже изображения, например, моя игра "Три в ряд" написана на этом. . .	Мысли в слух kumehtar 18.11.2025 Кстати, совсем недавно имел разговор на тему медитаций с людьми. И обнаружил, что они вообще не понимают что такое медитация и зачем она нужна. Самые базовые вещи. Для них это - когда просто люди. . .

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