ReSQL.ru
     
powered by simpleCommunicator - 2.0.61     © 2026 Programmizd 02
Мобильная версия    Контакт    Правила    FAQ    Помощь
Целевая тема:
Создать новую тему:
Автор:
Закрыть
Цитировать
Доб. в избранное | Игнор. тему | Прикреп. тему | Пометить прочит. / непрочит. | Фильтр
Форумы / Java [игнор отключен] [закрыт для гостей] / Spring websocket user notifications
25 сообщений из 36, страница 1 из 2
  1  все
Spring websocket user notifications
    #38953279
Atum1
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Atum1
Участник
Доброе утро !

Возникло два вопроса , и две задачки с которыми я только начал разбираться, поэтому нужна помощь и совет :)

1) у нас есть 100_000 онлайн пользователей - которых нужно оповестить - передать им сообщение . Пользователи ничего не отправляют ,им нужно только получать данные в браузере .

2) Хочется делать это через WS , точнее через wss как я понимаю это гарантия того что данный обмен пройдет через любой прокси .

Теперь задача :

Есть два типа сообщений :
первое - это {"status":"ok" , "message":"text"} его приоритет 1
....
второе - это {blob ~10kb} его приоритет 10


раз в 1 секунду отправлять всем пользователям первое сообщение .
Как реализовать ?

простой цикл по всем пользователям которые приконектилсь ?
Допустим что for по 100_000 быстро .... но можно как то уровнять всех пользователей ?

как распараллелить или форнуть такой цикл ?

Второе

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

И начать рассылать сообщение с большим приоритетом ... опять же таки с форком - на всех .... чтобы все пользователи получали сообщения одновременно ...

Идеи ...

1) создать некую очередь с приоритетом,(какую коллекцию выбрать?)
2) создать ExecutorService - потоков на 500 чтобы распараллелить for на 100_000 для быстрой отправки ....
3) как то протестировать все это,чтобы убедиться что ExecutorService и форк будет быстрее это делать,
чем простой цикл от 1 до 100_000 ?
...
Рейтинг: 0 / 0
07.05.2015, 10:01
| Ответить | Цитировать | Написать  
Spring websocket user notifications
    #38953306
Фотография Blazkowicz
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Blazkowicz
Участник
Если у вас 100К пользователей, то начните с того что у вас это всё должно крутится в кластере и прикиньте сколько клиентов сможет обслуживать одна нода. 100К на ноду звучит маловероятно.
И когда будет примерно понятно сколько держит одна нода, тогда и можно задуматься, действительно ли есть смысл форкать нотификацию, ведь это займет больше CPU ресурсов, отнимая их у других задач пользователей, либо достаточно одного цикла в потоке.


Atum1Допустим что for по 100_000 быстро .... но можно как то уровнять всех пользователей ?
Да - UDP

Atum1как распараллелить или форнуть такой цикл ?
Java 7 ForkJoin ?

Atum11) создать некую очередь с приоритетом,(какую коллекцию выбрать?)
java.util.PriorityQueue ? Только я бы ещё подумал над тем не взять ли полноценную MQ? Нужно ли персистить очередь, например?

Atum12) создать ExecutorService - потоков на 500 чтобы распараллелить for на 100_000 для быстрой отправки ....

А сколько ядер будет у сервера?

Atum13) как то протестировать все это,чтобы убедиться что ExecutorService и форк будет быстрее это делать,
чем простой цикл от 1 до 100_000 ?
На выделеном сервере. Можно в облаке десяток машин поднять, например, в качестве клиентов.
...
Рейтинг: 0 / 0
07.05.2015, 10:43
| Ответить | Цитировать | Написать  
Spring websocket user notifications
    #38953391
Atum1
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Atum1
Участник
Blazkowicz, спасибо :)

с самого малого - как в примере изменить логику - чтобы отправка шла от сервера в клиентов - и к примеру каждую секунду возвращала время всем клиентам кто зашел на страницу ?

http://spring-projects.ru/guides/messaging-stomp-websocket/
...
Рейтинг: 0 / 0
07.05.2015, 12:02
| Ответить | Цитировать | Написать  
Spring websocket user notifications
    #38953508
вадя
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
вадя
Участник
Atum1,
посмотри как вариант https://github.com/TooTallNate/Java-WebSocket
но рассылать каждую секунду время - это не правильно - на каждой машине есть свои часы и довольно стабильные , достаточно один раз при соединении послать время и на каждом клиенте при получении времени выводит его с учётом разницы
при 100к клиентах ты не сможещь гарантировать точность отправки в 1 сек.
даи напрягать сервер такой бессмысленной нагрузкой не верно
...
Рейтинг: 0 / 0
07.05.2015, 13:25
| Ответить | Цитировать | Написать  
Spring websocket user notifications
    #38953535
Atum1
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Atum1
Участник
вадя,
спасибо !

по поводу PriorityQueue

что то я сломал видимо :

просто поменял порядок- и все - [9, 8, 6, 7, 3, 2, 5, 1, 4] как такое может быть???

Код: java
1.
2.
3.
4.
5.
6.
testPriorityQueue
[10, 9, 6, 7, 8, 2, 5, 1, 4, 3]
poll : 10
[9, 8, 6, 7, 3, 2, 5, 1, 4]
peek : 9
[9, 8, 6, 7, 3, 2, 5, 1, 4]





Код: java
1.
2.
3.
4.
5.
6.
7.
8.
9.
10.
11.
12.
13.
14.
15.
    @Test
    public void testPriorityQueue() {
        System.out.println("testPriorityQueue");
         List<Integer> list =  IntStream.rangeClosed(1, 10).boxed().collect(Collectors.toList());
        
         
         PriorityBlockingQueue<Integer> integerPriorityQueue = new PriorityBlockingQueue<>(list.size(), ( i1,  i2) -> i2.compareTo(i1) );
         integerPriorityQueue.addAll(list);
         
        
        System.out.println(integerPriorityQueue);
        System.out.println("poll : "+integerPriorityQueue.poll());//Удаление
        System.out.println("peek : "+integerPriorityQueue.peek());//Получение 
        System.out.println(integerPriorityQueue);
    }
...
Рейтинг: 0 / 0
07.05.2015, 13:43
| Ответить | Цитировать | Написать  
Spring websocket user notifications
    #38953574
Atum1
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Atum1
Участник
вадяно рассылать каждую секунду время - это не правильно - на каждой машине есть свои часы и довольно стабильные , достаточно один раз при соединении послать время и на каждом клиенте при получении времени выводит его с учётом разницы
при 100к клиентах ты не сможещь гарантировать точность отправки в 1 сек.
даи напрягать сервер такой бессмысленной нагрузкой не верно

Это как самый простой тест - который пришел в голову - чтобы видеть лаг ...

а так конечно - при коннекте я буду отправлять серверное время и раз 10 секунд буду его синхронизировать с серверным .
...
Рейтинг: 0 / 0
07.05.2015, 14:02
| Ответить | Цитировать | Написать  
Spring websocket user notifications
    #38953735
вадя
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
вадя
Участник
автора так конечно - при коннекте я буду отправлять серверное время и раз 10 секунд буду его синхронизировать с серверным .
ты думаешь , что за десять сек изменится стабильность часов?
достаточно 1 раз при коннекте и всё, или один раз в сутки, если подключение клиентов постояное.
...
Рейтинг: 0 / 0
07.05.2015, 15:46
| Ответить | Цитировать | Написать  
Spring websocket user notifications
    #38953744
вадя
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
вадя
Участник
при 100к клиентаху тебя не получится отправлять время на любого клиента с с переодичностью 10 сек. этот период будет иметь большую погрешность чем уход часов клиента за 10 сек. и поэтому у тебя время на клиенте будет скакать.
если тебя важно фиксировать время прихода сообщения клиенту- ты можешь к сообщению добавлять время сервера (т.е. всремя отправки сообщения) а на клиенте и корректировать или ещё как использовать.
стабильность времени на клиенте и сервере одинаковое. может отличаться только абсолютная величина , а она будет постоянна если клиент не переведёт время
...
Рейтинг: 0 / 0
07.05.2015, 15:54
| Ответить | Цитировать | Написать  
Spring websocket user notifications
    #38953827
Фотография Petro123
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Petro123
Участник
вадя,
у него время чисто как тест вместо сообщения. Чтобы не слать Привет Мир! ))
...
Рейтинг: 0 / 0
07.05.2015, 16:52
| Ответить | Цитировать | Написать  
Spring websocket user notifications
    #38953834
Фотография Petro123
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Petro123
Участник
Atum1это гарантия того что данный обмен пройдет через любой прокси .
порт должны будут открыть админы, т.к. протокол работает не на обычном порту.
...
Рейтинг: 0 / 0
07.05.2015, 16:58
| Ответить | Цитировать | Написать  
Spring websocket user notifications
    #38953841
вадя
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
вадя
Участник
Petro123вадя,
у него время чисто как тест вместо сообщения. Чтобы не слать Привет Мир! ))
вообще интересно если б проект Flightradar24 перевели на ws какой бы стала нагрузка на него?
потому как по https://ru.wikipedia.org/wiki/Flightradar24 ajax не справляется
...
Рейтинг: 0 / 0
07.05.2015, 17:03
| Ответить | Цитировать | Написать  
Spring websocket user notifications
    #38953867
Фотография Petro123
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Petro123
Участник
вадяajax не справляется
AJAX это чисто клиент. Поэтому фраза не справляется сервер не катит.
...
Рейтинг: 0 / 0
07.05.2015, 17:27
| Ответить | Цитировать | Написать  
Spring websocket user notifications
    #38953875
Фотография Petro123
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Petro123
Участник
вадя,
UPS я понял твою фразу. По ссылке написано))
IMHO самое неудобное - порты для WS.
...
Рейтинг: 0 / 0
07.05.2015, 17:30
| Ответить | Цитировать | Написать  
Spring websocket user notifications
    #38953878
Фотография Petro123
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Petro123
Участник
вадя,
зашёл на сайт. Там же ГУГЛ - API.
Это конечно, тяжеловесно и не чистое WS\AJAX.
У меня на сайте такое же от Оракла
...
Рейтинг: 0 / 0
07.05.2015, 17:35
| Ответить | Цитировать | Написать  
Spring websocket user notifications
    #38953918
Atum1
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Atum1
Участник
AJAX я думаю для меня не катит ...
а вот пример с stomp + MessageBroker
http://spring-projects.ru/guides/messaging-stomp-websocket/

понравился ,

прочитал про проект

http://habrahabr.ru/post/187822/

вроде в пером приближении подходит ...

главное набросать макетик ...
...
Рейтинг: 0 / 0
07.05.2015, 18:01
| Ответить | Цитировать | Написать  
Spring websocket user notifications
    #38953934
вадя
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
вадя
Участник
Petro123вадя,
IMHO самое неудобное - порты для WS.
расскрой смысл написанного...
...
Рейтинг: 0 / 0
07.05.2015, 18:18
| Ответить | Цитировать | Написать  
Spring websocket user notifications
    #38953936
Фотография Blazkowicz
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Blazkowicz
Участник
вадяPetro123вадя,
IMHO самое неудобное - порты для WS.
расскрой смысл написанного...
17614123
...
Рейтинг: 0 / 0
07.05.2015, 18:21
| Ответить | Цитировать | Написать  
Spring websocket user notifications
    #38953939
Фотография Blazkowicz
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Blazkowicz
Участник
Petro123Atum1это гарантия того что данный обмен пройдет через любой прокси .
порт должны будут открыть админы, т.к. протокол работает не на обычном порту.
Где почитать? Википедия пишет что по 80му.
...
Рейтинг: 0 / 0
07.05.2015, 18:22
| Ответить | Цитировать | Написать  
Spring websocket user notifications
    #38953946
вадя
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
вадя
Участник
Blazkowiczвадяпропущено...

расскрой смысл написанного...
17614123

да, с этим соглашусь. тут надо оценить затраты и преимущества. в общем открыть один порт не является большой дырой в безопасности.
...
Рейтинг: 0 / 0
07.05.2015, 18:26
| Ответить | Цитировать | Написать  
Spring websocket user notifications
    #38953952
Atum1
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Atum1
Участник
вадя,

думал так можно отправить время ... но что то Scheduled не вызывается ? в чем проблема?
Код: java
1.
2.
3.
4.
5.
6.
7.
8.
9.
10.
11.
12.
13.
@Controller
public class WsController {

    @Autowired
    private  MessageSendingOperations<String> messagingTemplate;
    
    @Scheduled(fixedDelay = 1000)
    public void sendQuotes() {
           System.out.println("sendQuotes");
            String destination = "/topic/greetings";
            this.messagingTemplate.convertAndSend(destination, Calendar.getInstance().getTime().toString());
        
    }
...
Рейтинг: 0 / 0
07.05.2015, 18:32
| Ответить | Цитировать | Написать  
Spring websocket user notifications
    #38953954
Atum1
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Atum1
Участник
вадя,
а можно все завернуть в wss по 443 ?

или 8080, 8081 ?
...
Рейтинг: 0 / 0
07.05.2015, 18:33
| Ответить | Цитировать | Написать  
Spring websocket user notifications
    #38953961
вадя
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
вадя
Участник
Atum1вадя,
а можно все завернуть в wss по 443 ?

или 8080, 8081 ?

можно исползовать любой порт, лишь бы он не входил в конфликт с уже имеющимися обработчиками портов
...
Рейтинг: 0 / 0
07.05.2015, 18:40
| Ответить | Цитировать | Написать  
Spring websocket user notifications
    #38953962
Фотография Petro123
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Petro123
Участник
BlazkowiczГде почитать? Википедия пишет что по 80му.
наверно ты прав. У меня разрыв мозга по данному вопросу. Имею двоякую инфу)).
...
Рейтинг: 0 / 0
07.05.2015, 18:41
| Ответить | Цитировать | Написать  
Spring websocket user notifications
    #38953964
Фотография Petro123
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Petro123
Участник
вадяможно исползовать любой порт, лишь бы он не входил в конфликт с уже имеющимися обработчиками портов
тут надо подробнее.
Т.к. админы часто всё закрывают кроме 80 (FTP\качалки торрент и т.д.)
...
Рейтинг: 0 / 0
07.05.2015, 18:43
| Ответить | Цитировать | Написать  
Spring websocket user notifications
    #38953965
вадя
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
вадя
Участник
Atum1вадя,

думал так можно отправить время ... но что то Scheduled не вызывается ? в чем проблема?
Код: java
1.
2.
3.
4.
5.
6.
7.
8.
9.
10.
11.
12.
13.
@Controller
public class WsController {

    @Autowired
    private  MessageSendingOperations<String> messagingTemplate;
    
    @Scheduled(fixedDelay = 1000)
    public void sendQuotes() {
           System.out.println("sendQuotes");
            String destination = "/topic/greetings";
            this.messagingTemplate.convertAndSend(destination, Calendar.getInstance().getTime().toString());
        
    }


а просто передать сообщение ты можешь?
сам канад работает?
...
Рейтинг: 0 / 0
07.05.2015, 18:44
| Ответить | Цитировать | Написать  
25 сообщений из 36, страница 1 из 2
  1  все
Форумы / Java [игнор отключен] [закрыт для гостей] / Spring websocket user notifications
Найденые пользователи ...
Разблокировать пользователей ...
Читали тему (0):
Читали форум (0):
Пользователи онлайн (0):
Польз. соглашение   Полит. конфиден.  
NoSQL.ru       Кролег: Проекты, Новости, Чат       РЕД ФОРУМ       Фотоальбом: Участники, Встречи
Закрыть
start [/forum/topic.php?fid=59&msg=38953306&tid=2125443]:
 0ms
get settings:
 5ms
get forum list:
 16ms
check forum access:
 3ms
check topic access:
 3ms
track hit:
 153ms
get topic data:
 8ms
get forum data:
 2ms
get page messages:
 58ms
get tp. blocked users:
 1ms
others: 228ms
total:  477ms
созд. / загр.: 477ms
x
x
Закрыть


Просмотр
0 / 0
Close
Debug Console [Select Text]