Форум программистов, компьютерный форум, киберфорум
Java SE (J2SE)
Войти
Регистрация
Восстановить пароль
Блоги Сообщество Поиск Заказать работу  
 
Рейтинг 4.73/11: Рейтинг темы: голосов - 11, средняя оценка - 4.73
10 / 10 / 6
Регистрация: 14.03.2011
Сообщений: 392

Сокеты и передача разных данных, разным клиентам

06.02.2014, 20:32. Показов 2230. Ответов 7
Метки нет (Все метки)

Студворк — интернет-сервис помощи студентам
Добрый день уважаемые форумчане.

У меня есть сервер:
Кликните здесь для просмотра всего текста
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 org.poker.main;
 
 
import java.io.*;
import java.net.*;
 
import org.poker.calculating.StartGame;
import org.poker.utils.CheckPlayersCount;
 
public class MainPokerServer {
    public static Integer PlayerCount = 0;
    public static void main(String[] args) throws IOException, ClassNotFoundException {
        
        new CheckPlayersCount().start(); //Поток проверки игроков
        
        new MainPokerServer().start(); //Главный поток 
 
    }
    
    @SuppressWarnings("resource")
    public void start() {
        ServerSocket ss = null;
        try {
            ss = new ServerSocket(4444);
        } catch (Exception e) {
            e.printStackTrace();
            System.exit(0);
        }
        while (true) {
            try {
                new ServerTask(ss.accept()).start();
            } catch (Exception e) {
                e.printStackTrace();
                System.exit(0);
            }
            
        }
    }
 
    private class ServerTask implements Runnable {
 
        private Socket s;
        private Thread self;
        private String message;
 
        public ServerTask(Socket s) {
            this.s = s;
            self = new Thread(this);
        }
 
        public void start() {
            this.self.start();
        }
 
        public void run() {
            try {
                ObjectInputStream ois = new ObjectInputStream(s.getInputStream());
                ObjectOutputStream oos = new ObjectOutputStream(s.getOutputStream());
                while(true){
                   message = (String)ois.readObject();
                   PlayerCount++;
                   System.out.println("Client->"+message);
                   if (message.equals("exit")) break;
                   oos.writeObject(StartGame.player);
                }
                s.close();
                System.out.println("Socket closed");
            } catch (Exception e) {  //Возникает при закрытии по крестику консольки
                try {
                    PlayerCount=PlayerCount-1; 
                    s.close();
                } catch (IOException e1) {
                    e1.printStackTrace();
                }
                if (!s.isClosed()) {
                    try {//При написании exit в консольке
                        PlayerCount=PlayerCount-1;
                        s.close();
                    } catch (Exception ee) {
                        e.printStackTrace();
                    }
                }
            }
        }
    }
}

Клиент:
Кликните здесь для просмотра всего текста
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
package org.poker.client.main;
 
import java.io.*;
import java.net.*;
 
public class MainPokerClient {
 
static String qw;
public static void main(String[] args) throws IOException, ClassNotFoundException {
 
 
      
        BufferedReader br = new BufferedReader(new InputStreamReader(System.in));
        @SuppressWarnings("resource")
        Socket s = new Socket();
        s.connect(new InetSocketAddress("localhost", 4444));
        ObjectOutputStream oos = new ObjectOutputStream(s.getOutputStream());
        ObjectInputStream ois = new ObjectInputStream(s.getInputStream());
       // String qw;
        while(true){
            qw = br.readLine();
            oos.writeObject(qw);
            
            //oos.flush();
            if (qw.equals("exit")) break;
            String obj = (String) ois.readObject();
            System.out.println("Server->" + obj);            
        }
        oos.close();
        ois.close();
 
    
      
      
     /*     Socket socket = new Socket("localhost",4444);
 
 
        ObjectOutputStream oos = new ObjectOutputStream(socket.getOutputStream());
        String[] player1={"Булат"};
        oos.writeObject(player1);
        System.out.println("Send Done");
        oos.close();
        socket.close();*/
 
  }
}


Работает это дело так. Когда подключается клиент и пишет что то, PlayerCount, тоесть количество клиентов, прибавляется на 1. Как только подкл. два клиента, начинает работать сторонний поток. В этом потоке, в определенный момент времени я хочу передавать клиентам различные данные. Как такое можно сделать ?

Получается так что у меня для каждого клиента создается свой поток. Вот как мне из другого потока передавать данные определенному клиенту ?

Будьте так любезны, объясните пожалуйста. Если нужно больше кода, предоставлю...

Добавлено через 4 часа 7 минут
Все еще актуально...
0
Лучшие ответы (1)
IT_Exp
Эксперт
34794 / 4073 / 2104
Регистрация: 17.06.2006
Сообщений: 32,602
Блог
06.02.2014, 20:32
Ответы с готовыми решениями:

Сокеты: отправка результата нескольким клиентам
Здравствуйте. Как реализовать отправку результата с сервера на два клиента? Проблема в том, что отправка идёт только тому, кто последний...

Сокеты: передача данных
И так есть сервер, и в нем прослушка для приема файлов: Socket sListener; Socket fileHandler; .... ...

Передача данных через сокеты. Унификация
Такое дело: Искал как через сокеты отправить данные (файлы, строки и т.д.), но унифицированног способа передачи не нашел. Нашел как...

7
 Аватар для KuKu
1563 / 1041 / 94
Регистрация: 17.04.2009
Сообщений: 2,995
06.02.2014, 22:27
Лучший ответ Сообщение было отмечено Critically как решение

Решение

Сделайте отдельный массив для ObjectOutputStream так, чтобы этот массив видели все потоки. И когда надо написать клиенту, доставайте элемент из массива и пишите в него.
0
10 / 10 / 6
Регистрация: 14.03.2011
Сообщений: 392
06.02.2014, 23:10  [ТС]
Тоесть когда подключается новый клиент мы после
Java
1
ObjectOutputStream oos = new ObjectOutputStream(s.getOutputStream());
записываем oos в массив глобальный ? Ну и потом в нужном месте достаем из массива и делаем oos.WriteString();

Я вас правильно понял ?
0
 Аватар для KuKu
1563 / 1041 / 94
Регистрация: 17.04.2009
Сообщений: 2,995
07.02.2014, 08:55
Да, но там могут появится проблемы, что пишем в один стрим из разных потоков - может понадобится какая-то синхронизация.
1
10 / 10 / 6
Регистрация: 14.03.2011
Сообщений: 392
07.02.2014, 11:08  [ТС]
Да я об этом тоже думал. Ну можно будет использовать вот так:
Java
1
2
3
List list = Collections.synchronizedList(new ArrayList());
synchronized(list) {
}
Как думаете решит проблему ?
0
 Аватар для KuKu
1563 / 1041 / 94
Регистрация: 17.04.2009
Сообщений: 2,995
07.02.2014, 11:32
Ну по идее можно и так. Лучше блокировать элемент массива, а не весь массив.
1
10 / 10 / 6
Регистрация: 14.03.2011
Сообщений: 392
07.02.2014, 16:12  [ТС]
Допустим у меня есть массив как вы говорили. При отключении клиента, мне же нужно будет удалить из этого массива, того кто отключился.

Как я узнаю какой объект из этого списка принадлежит какому клиенту ?
0
 Аватар для KuKu
1563 / 1041 / 94
Регистрация: 17.04.2009
Сообщений: 2,995
07.02.2014, 17:14
Ну при создании ассоциируйте клиента с индексом. Или вместо листа держите мапу. Или что еще лучше поищите уже готовые реализации чата - поймите как там работает и сделайте под себя.
1
Надоела реклама? Зарегистрируйтесь и она исчезнет полностью.
BasicMan
Эксперт
29316 / 5623 / 2384
Регистрация: 17.02.2009
Сообщений: 30,364
Блог
07.02.2014, 17:14
Помогаю со студенческими работами здесь

Передача данных между программами (сокеты)
В общем, есть 2 программы, между которыми нужно передавать данные. Хотелось бы организовать это с помощью сокетов. Язык С++, пишу в...

Сокеты. Отправка сообщений всем клиентам или только одному
Здравствуйте, имеется вот такой сервер на C#: using System; using System.Collections.Generic; using System.Linq; using System.Text;...

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

Передача сообщения всем подключенным клиентам
есть класс сервера package simplenetserver; /* * To change this template, choose Tools | Templates * and open the template...

Передача в функцию данных разных типов
Нужно передать в функцию в качестве аргумента переменную типа ulong a затем переменную типа int Пробовал использовать обобщенный...


Искать еще темы с ответами

Или воспользуйтесь поиском по форуму:
8
Ответ Создать тему
Новые блоги и статьи
SDL3 для Web (WebAssembly): Обработчик клика мыши в браузере ПК и касания экрана в браузере на мобильном устройстве
8Observer8 02.02.2026
Содержание блога Для начала пошагово создадим рабочий пример для подготовки к экспериментам в браузере ПК и в браузере мобильного устройства. Потом напишем обработчик клика мыши и обработчик. . .
Философия технологии
iceja 01.02.2026
На мой взгляд у человека в технических проектах остается роль генерального директора. Все остальное нейронки делают уже лучше человека. Они не могут нести предпринимательские риски, не могут. . .
SDL3 для Web (WebAssembly): Вывод текста со шрифтом TTF с помощью SDL3_ttf
8Observer8 01.02.2026
Содержание блога В этой пошаговой инструкции создадим с нуля веб-приложение, которое выводит текст в окне браузера. Запустим на Android на локальном сервере. Загрузим Release на бесплатный. . .
SDL3 для Web (WebAssembly): Сборка C/C++ проекта из консоли
8Observer8 30.01.2026
Содержание блога Если вы откроете примеры для начинающих на официальном репозитории SDL3 в папке: examples, то вы увидите, что все примеры используют следующие четыре обязательные функции, а. . .
SDL3 для Web (WebAssembly): Установка Emscripten SDK (emsdk) и CMake для сборки C и C++ приложений в Wasm
8Observer8 30.01.2026
Содержание блога Для того чтобы скачать Emscripten SDK (emsdk) необходимо сначало скачать и уставить Git: Install for Windows. Следуйте стандартной процедуре установки Git через установщик. . . .
SDL3 для Android: Подключение Box2D v3, физика и отрисовка коллайдеров
8Observer8 29.01.2026
Содержание блога Box2D - это библиотека для 2D физики для анимаций и игр. С её помощью можно определять были ли коллизии между конкретными объектами. Версия v3 была полностью переписана на Си, в. . .
Инструменты COM: Сохранение данный из VARIANT в файл и загрузка из файла в VARIANT
bedvit 28.01.2026
Сохранение базовых типов COM и массивов (одномерных или двухмерных) любой вложенности (деревья) в файл, с возможностью выбора алгоритмов сжатия и шифрования. Часть библиотеки BedvitCOM Использованы. . .
SDL3 для Android: Загрузка PNG с альфа-каналом с помощью SDL_LoadPNG (без SDL3_image)
8Observer8 28.01.2026
Содержание блога SDL3 имеет собственные средства для загрузки и отображения PNG-файлов с альфа-каналом и базовой работы с ними. В этой инструкции используется функция SDL_LoadPNG(), которая. . .
КиберФорум - форум программистов, компьютерный форум, программирование
Powered by vBulletin
Copyright ©2000 - 2026, CyberForum.ru