ReSQL.ru
     
powered by simpleCommunicator - 2.0.61     © 2026 Programmizd 02
Мобильная версия    Контакт    Правила    FAQ    Помощь
Целевая тема:
Создать новую тему:
Автор:
Закрыть
Цитировать
Доб. в избранное | Игнор. тему | Прикреп. тему | Пометить прочит. / непрочит. | Фильтр
Форумы / Java [игнор отключен] [закрыт для гостей] / ActiveMQ, создание большого числа консюмеров
51 сообщений из 51, показаны все 3 страниц
  все  
ActiveMQ, создание большого числа консюмеров
    #37683976
livehacker
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
livehacker
Участник
Всем привет!
Столкнулся с проблемой. Есть некий продукт, который использует axis2 jms транспорт.
Данный продукт выступает в роли клиентской стороны (относительно брокера), создает до 3000 консюмеров, используя брокер - ActiveMq.
Использовал различные опции тюнинга на клиенсткой стороне..(различные опции jms кеширования, время ожидания и тд..немного даже код подправил у транспорта) В итоге добился того, что первая тысяча консюмером создается влет - около 10 секунд.
Далее начинаются проблемы, каждый новый консюмер создается всё дольше и дольше. Доходит до 1500 тысяч и дальше глухо.. , но всё же продолжает работать.
В создании консюмером исползуется пул тредов, который настраивается через проперти транспорта. В пропертях тоже выставил min и core размер пула тредов..
В JVM, в связи с большим числом тредов увеличил параметр -Xss.

в jms использую nio транспорт.
Ничего не помогает:(

В логах сервера (который создает консюмеры) вижу в конце концов такой вот лог:

Код: 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.
java.nio.channels.ClosedChannelException
        at java.nio.channels.spi.AbstractSelectableChannel.register(AbstractSele
ctableChannel.java:167)
        at org.apache.activemq.transport.nio.SelectorSelection$1.run(SelectorSel
ection.java:44)
        at org.apache.activemq.transport.nio.SelectorWorker.processIoTasks(Selec
torWorker.java:75)
        at org.apache.activemq.transport.nio.SelectorWorker.run(SelectorWorker.j
ava:91)
        at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExec
utor.java:886)
        at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor
.java:908)
        at java.lang.Thread.run(Thread.java:662)
java.lang.NullPointerException
        at org.apache.activemq.transport.nio.SelectorSelection$2.run(SelectorSel
ection.java:60)
        at org.apache.activemq.transport.nio.SelectorWorker.processIoTasks(Selec
torWorker.java:75)
        at org.apache.activemq.transport.nio.SelectorWorker.run(SelectorWorker.j
ava:91)
        at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExec
utor.java:886)
        at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor
.java:908)
        at java.lang.Thread.run(Thread.java:662)
java.lang.NullPointerException
        at org.apache.activemq.transport.nio.SelectorSelection$4.run(SelectorSel
ection.java:84)
        at org.apache.activemq.transport.nio.SelectorWorker.processIoTasks(Selec
torWorker.java:75)
        at org.apache.activemq.transport.nio.SelectorWorker.run(SelectorWorker.j
ava:91)
        at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExec
utor.java:886)
        at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor
.java:908)
        at java.lang.Thread.run(Thread.java:662)
...
Рейтинг: 0 / 0
29.02.2012, 12:51:24
| Ответить | Цитировать | Написать  
ActiveMQ, создание большого числа консюмеров
    #37683986
livehacker
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
livehacker
Участник
livehacker,

Проанализировав, куда уходит время на создание нового консюмера, выяснил, что долго создается поток для консюмера.

С чем это может быть связано?

Тестил под виндой и линуксом, результаты одинаковы.
...
Рейтинг: 0 / 0
29.02.2012, 12:53:39
| Ответить | Цитировать | Написать  
ActiveMQ, создание большого числа консюмеров
    #37684005
Фотография Blazkowicz
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Blazkowicz
Участник
Xss это же размер стека для одного потока (1Мб по дефолту?). Соответственно 1500 потоков это около 1.5Гб. Память банально заканчивается. Зачем вам столько консюмеров? Сколько выделено памяти на процесс?
...
Рейтинг: 0 / 0
29.02.2012, 13:00:24
| Ответить | Цитировать | Написать  
ActiveMQ, создание большого числа консюмеров
    #37684037
livehacker
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
livehacker
Участник
Blazkowicz,
"Сколько выделено памяти на процесс?" - что вы под этим подразумеваете?

Я выделял для jvm до 5 гигабайт памяти. Сжирала максимум 3 гига..
...
Рейтинг: 0 / 0
29.02.2012, 13:07:28
| Ответить | Цитировать | Написать  
ActiveMQ, создание большого числа консюмеров
    #37684067
Фотография Blazkowicz
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Blazkowicz
Участник
Странно что создаётся поток на каждого консюмера. Как вы это обнаружили?
...
Рейтинг: 0 / 0
29.02.2012, 13:14:52
| Ответить | Цитировать | Написать  
ActiveMQ, создание большого числа консюмеров
    #37684068
livehacker
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
livehacker
Участник
Blazkowicz,

В каком месте память заканчивается?
Я обеспечил ресурсы для данной задачи. Пул тредов большой, памяти предостаточно и ещё остается..
...
Рейтинг: 0 / 0
29.02.2012, 13:15:04
| Ответить | Цитировать | Написать  
ActiveMQ, создание большого числа консюмеров
    #37684083
livehacker
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
livehacker
Участник
Blazkowicz,

В коде AXI2 Jms транспорта.
Если интересно, org.apache.axis2.transport.jms.JMSListener, метод startEndpoint.
На каждый листнер консюмера - новый тред.
...
Рейтинг: 0 / 0
29.02.2012, 13:18:14
| Ответить | Цитировать | Написать  
ActiveMQ, создание большого числа консюмеров
    #37684112
Фотография Blazkowicz
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Blazkowicz
Участник
livehackerВ каком месте память заканчивается?
Я обеспечил ресурсы для данной задачи. Пул тредов большой, памяти предостаточно и ещё остается..
Вы выдаёте минимум информации. Я отвечаю предположением. Вы сказали что на каждого консюмера создаётся новый поток. Тысячи потоков это серьезное потребление по памяти. Отсюда предположение.
Под профайлером посмотреть, когда создание тормозит, пробовали?
...
Рейтинг: 0 / 0
29.02.2012, 13:22:41
| Ответить | Цитировать | Написать  
ActiveMQ, создание большого числа консюмеров
    #37684130
livehacker
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
livehacker
Участник
Blazkowicz,
"Под профайлером посмотреть, когда создание тормозит, пробовали?"
К сожалению, не пробовал. Но я запускал проект под дебаг левелом, натыкал в код аксиса различных логов и выяснил, что когда начинается замедление создания нового консюмера, то время уходит именно на создание треда. Ничего больше..

Ещё я пробовал создавать консюмеры просто из юнит теста. Но код был очень простой без использования того нагромождения, которое находится в сендере и рецивере аксис 2 транспорта. Идея наплодила 3000 консюмеров и листнеров и всё работало хорошо. С учетом того, что для каждого консюмера нужен ещё листнер получилось в сумме 6000 потоков. Те в самой-самой облегченной версии, всё работало удачно. Но не axis транспортом.
...
Рейтинг: 0 / 0
29.02.2012, 13:28:06
| Ответить | Цитировать | Написать  
ActiveMQ, создание большого числа консюмеров
    #37684145
Фотография Blazkowicz
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Blazkowicz
Участник
livehackerВ коде AXI2 Jms транспорта.
Если интересно, org.apache.axis2.transport.jms.JMSListener, метод startEndpoint.
На каждый листнер консюмера - новый тред.
Мда, Axis2 редкостная дрянь. Уже в третий раз убеждаюсь. Не знаю какая у вас версия, но вот тут
http://www.docjar.com/html/api/org/apache/axis2/transport/jms/JMSListener.java.html
создаётся пул на каждого слушаетеля. А это даже иногда более одного потока, если у вас 3000 этих слушателей.
А покажите stacktrace до startEndpoint. Откуда оно создаётся? Может JMSListener на каждого консюмера и не нужен?
...
Рейтинг: 0 / 0
29.02.2012, 13:30:01
| Ответить | Цитировать | Написать  
ActiveMQ, создание большого числа консюмеров
    #37684167
Фотография Blazkowicz
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Blazkowicz
Участник
Надо понять зачем столько JMSListener-ов создаётся. По-моему их не должно быть много.
...
Рейтинг: 0 / 0
29.02.2012, 13:36:01
| Ответить | Цитировать | Написать  
ActiveMQ, создание большого числа консюмеров
    #37684170
Фотография Blazkowicz
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Blazkowicz
Участник
Настройка transport.jms.CacheLevel ни на что не влияет?
...
Рейтинг: 0 / 0
29.02.2012, 13:36:48
| Ответить | Цитировать | Написать  
ActiveMQ, создание большого числа консюмеров
    #37684178
livehacker
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
livehacker
Участник
Blazkowicz,
Тот код, на который вы дали ссылку, вообще жесть:)
Вот этот, который у меня:
http://svn.apache.org/repos/asf/axis/axis2/java/transports/trunk/modules/jms/src/main/java/org/apache/axis2/transport/jms/JMSListener.java


Cейчас скину стэк.
...
Рейтинг: 0 / 0
29.02.2012, 13:38:46
| Ответить | Цитировать | Написать  
ActiveMQ, создание большого числа консюмеров
    #37684192
livehacker
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
livehacker
Участник
Blazkowicz,

Нет, не влияет.. Я с ней игрался уже. Что польное кеширование, что "none", не помогло.
Столько консюмеров нужно, тк много различных сервисов. Их действительно так очень много!
...
Рейтинг: 0 / 0
29.02.2012, 13:41:48
| Ответить | Цитировать | Написать  
ActiveMQ, создание большого числа консюмеров
    #37684201
livehacker
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
livehacker
Участник
livehacker,

Если вы посмотрите внимательно код:

Код: java
1.
2.
3.
4.
5.
6.
7.
8.
9.
10.
11.
12.
13.
14.
15.
   for (int i=0; i<3; i++) {
            // Check the consumer count rather than the active task count. Reason: if the
            // destination is of type topic, then the transport is only ready to receive
            // messages if at least one consumer exists. This is of not much importance,
            // except for automated tests.
            if (stm.getConsumerCount() > 0) {
                log.info("Started to listen on destination : " + stm.getDestinationJNDIName() +
                    " of type " + JMSUtils.getDestinationTypeAsString(stm.getDestinationType()) +
                    " for service " + stm.getServiceName());
                return;
            }
            try {
                Thread.sleep(1000);
            } catch (InterruptedException ignore) {}
        }



То увидите, что стоит секундная задержка. Это я убрал в коде, чтобы быстрее создавались консюмеры. Но если более детально смотреть код аксиса, то есть ещё недочеты.
...
Рейтинг: 0 / 0
29.02.2012, 13:43:53
| Ответить | Цитировать | Написать  
ActiveMQ, создание большого числа консюмеров
    #37684207
Фотография Blazkowicz
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Blazkowicz
Участник
livehackerВот этот, который у меня:
http://svn.apache.org/repos/asf/axis/axis2/java/transports/trunk/modules/jms/src/main/java/org/apache/axis2/transport/jms/JMSListener.java

И где там создаётся поток? ServiceTaskManager вроде реюзабельный. Нет?
...
Рейтинг: 0 / 0
29.02.2012, 13:45:25
| Ответить | Цитировать | Написать  
ActiveMQ, создание большого числа консюмеров
    #37684209
livehacker
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
livehacker
Участник
Blazkowicz,

в ServiceTaskManager.run()
...
Рейтинг: 0 / 0
29.02.2012, 13:45:58
| Ответить | Цитировать | Написать  
ActiveMQ, создание большого числа консюмеров
    #37684218
justforsqlru
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
justforsqlru
Участник
livehacker,

а нельзя одного консьюмера на весь прием заюзать ?
...
Рейтинг: 0 / 0
29.02.2012, 13:47:54
| Ответить | Цитировать | Написать  
ActiveMQ, создание большого числа консюмеров
    #37684220
Фотография Blazkowicz
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Blazkowicz
Участник
Так почему новый ServiceTaskManager создаётся? Нельзя его несколько раз переиспользовать?
...
Рейтинг: 0 / 0
29.02.2012, 13:48:18
| Ответить | Цитировать | Написать  
ActiveMQ, создание большого числа консюмеров
    #37684227
justforsqlru
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
justforsqlru
Участник
Blazkowicz , помнишь у меня то же самое но для продьюсера было ?
...
Рейтинг: 0 / 0
29.02.2012, 13:50:46
| Ответить | Цитировать | Написать  
ActiveMQ, создание большого числа консюмеров
    #37684233
livehacker
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
livehacker
Участник
Blazkowicz,

Там для каждого ендпоинта свой ServiceTaskManager.
...
Рейтинг: 0 / 0
29.02.2012, 13:52:14
| Ответить | Цитировать | Написать  
ActiveMQ, создание большого числа консюмеров
    #37684235
livehacker
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
livehacker
Участник
justforsqlrulivehacker,

а нельзя одного консьюмера на весь прием заюзать ?

Это технически сложно очень.. Либо свой транспорт написать.
...
Рейтинг: 0 / 0
29.02.2012, 13:53:04
| Ответить | Цитировать | Написать  
ActiveMQ, создание большого числа консюмеров
    #37684236
justforsqlru
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
justforsqlru
Участник
livehacker,

http://www.sql.ru/forum/actualthread.aspx?tid=916850&hl=producer

ну вот примерно то же но при отправке

решили использованием одного продьюсера при отправке
...
Рейтинг: 0 / 0
29.02.2012, 13:54:09
| Ответить | Цитировать | Написать  
ActiveMQ, создание большого числа консюмеров
    #37684254
Фотография Blazkowicz
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Blazkowicz
Участник
livehackerТам для каждого ендпоинта свой ServiceTaskManager.
1 endpoint это один Web Service. Учитывая, что у вас клиентская часть, то она связывается с 3000 веб сервисами?
Я правильно понял архитектуру?
...
Рейтинг: 0 / 0
29.02.2012, 13:57:30
| Ответить | Цитировать | Написать  
ActiveMQ, создание большого числа консюмеров
    #37684255
livehacker
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
livehacker
Участник
justforsqlru,

При отправке можно одного продюсера использовать и у меня. Но в случае с консюмерами -нет.
...
Рейтинг: 0 / 0
29.02.2012, 13:57:44
| Ответить | Цитировать | Написать  
ActiveMQ, создание большого числа консюмеров
    #37684257
livehacker
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
livehacker
Участник
Blazkowicz,

Верно.
...
Рейтинг: 0 / 0
29.02.2012, 13:58:01
| Ответить | Цитировать | Написать  
ActiveMQ, создание большого числа консюмеров
    #37684271
Фотография Blazkowicz
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Blazkowicz
Участник
justforsqlruBlazkowicz , помнишь у меня то же самое но для продьюсера было ?
У тебя была совершенно другая ситуация. Для батч отправки создавался продюсер на каждый метод.

Здесь же в постановке задачи нужно много консюмеров. Хотя пока не объяснили зачем. Так же не понятно почему эти консюмеры связаны 1:1 с endpoing и прочей Axis2 инфраструктурой.
...
Рейтинг: 0 / 0
29.02.2012, 14:00:45
| Ответить | Цитировать | Написать  
ActiveMQ, создание большого числа консюмеров
    #37684273
Фотография Blazkowicz
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Blazkowicz
Участник
BlazkowiczУ тебя была совершенно другая ситуация. Для батч отправки создавался продюсер на каждый метод.

...На каждый "мессадж"
...
Рейтинг: 0 / 0
29.02.2012, 14:01:34
| Ответить | Цитировать | Написать  
ActiveMQ, создание большого числа консюмеров
    #37684284
livehacker
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
livehacker
Участник
Blazkowiczjustforsqlru

Здесь же в постановке задачи нужно много консюмеров. Хотя пока не объяснили зачем. Так же не понятно почему эти консюмеры связаны 1:1 с endpoing и прочей Axis2 инфраструктурой.

Хороший довод. Просто в рамках политики секретности, я не все объяснить) Но могу сказать, что есть вышестоящий жар, который, к сожалению привязывает 1:1 endpoint к "и прочей Axis2 инфраструктурой."..
...
Рейтинг: 0 / 0
29.02.2012, 14:04:08
| Ответить | Цитировать | Написать  
ActiveMQ, создание большого числа консюмеров
    #37684285
Фотография Blazkowicz
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Blazkowicz
Участник
livehackerв ServiceTaskManager.run()
сначала было в startEndpoint, теперь в ServiceTaskManager.run(), где я тоже не вижу новых потоков.
Зато вижу
/** The shared thread pool from the Listener */
private WorkerPool workerPool = null;

Ткни всё же носом, где создаётся новый потоко.
...
Рейтинг: 0 / 0
29.02.2012, 14:04:34
| Ответить | Цитировать | Написать  
ActiveMQ, создание большого числа консюмеров
    #37684295
livehacker
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
livehacker
Участник
Blazkowicz,

org.apache.axis2.transport.jms.ServiceTaskManager

Код: java
1.
2.
3.
4.
   log.info("Begin start  service : " + serviceName + " ...");
        for (int i = 0; i < concurrentConsumers; i++) {
            workerPool.execute(new MessageListenerTask());
         }



Где, MessageListenerTask, иннер класс, который реализует Runnable.
...
Рейтинг: 0 / 0
29.02.2012, 14:08:05
| Ответить | Цитировать | Написать  
ActiveMQ, создание большого числа консюмеров
    #37684305
Фотография Blazkowicz
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Blazkowicz
Участник
livehackerГде, MessageListenerTask, иннер класс, который реализует Runnable.
Да, но runnable это ещё не поток. Это задача. WorkerPool это пул потоков. Где он создаётся? Можно его зашарить между всеми?
...
Рейтинг: 0 / 0
29.02.2012, 14:10:58
| Ответить | Цитировать | Написать  
ActiveMQ, создание большого числа консюмеров
    #37684329
livehacker
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
livehacker
Участник
Blazkowicz,

Он как раз и расшарен. Создается там гдето наверху. Можете побродить по сорцам.
И когда потоков >1000, то время начинает уходить на workerPool.execute. Именно на execute.
...
Рейтинг: 0 / 0
29.02.2012, 14:16:46
| Ответить | Цитировать | Написать  
ActiveMQ, создание большого числа консюмеров
    #37684330
livehacker
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
livehacker
Участник
livehacker,

*когда консюмеров >1000
...
Рейтинг: 0 / 0
29.02.2012, 14:17:22
| Ответить | Цитировать | Написать  
ActiveMQ, создание большого числа консюмеров
    #37684387
Фотография Blazkowicz
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Blazkowicz
Участник
Посмотрите NativeWorkerPool. Возможно там размер очереди - 1000. И при создании более 1000 очередь блокируется. И освобождается постепенно. Ни о каком создании новых потоков речи не идёт.
...
Рейтинг: 0 / 0
29.02.2012, 14:36:07
| Ответить | Цитировать | Написать  
ActiveMQ, создание большого числа консюмеров
    #37684412
livehacker
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
livehacker
Участник
BlazkowiczПосмотрите NativeWorkerPool. Возможно там размер очереди - 1000. И при создании более 1000 очередь блокируется. И освобождается постепенно. Ни о каком создании новых потоков речи не идёт.

В самом начале писал, что увеличил размер пула. Сейчас core параметр увеличен до 3000.
...
Рейтинг: 0 / 0
29.02.2012, 14:41:23
| Ответить | Цитировать | Написать  
ActiveMQ, создание большого числа консюмеров
    #37684428
Фотография Blazkowicz
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Blazkowicz
Участник
livehackerВ самом начале писал, что увеличил размер пула. Сейчас core параметр увеличен до 3000.
Это не размер пула. А размер очереди задач в пуле. Это другой параметр. Покажите stacktarce создания JMSListener в тот момент когд тормозит. Включая WorkerPool.execute и то что там внутри.
...
Рейтинг: 0 / 0
29.02.2012, 14:44:22
| Ответить | Цитировать | Написать  
ActiveMQ, создание большого числа консюмеров
    #37684506
livehacker
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
livehacker
Участник
В аттаче
...
Рейтинг: 0 / 0
29.02.2012, 15:09:33
| Ответить | Цитировать | Написать  
ActiveMQ, создание большого числа консюмеров
    #37684538
Фотография Blazkowicz
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Blazkowicz
Участник
Мда. Атака провалилась. Очередь пустая :(
...
Рейтинг: 0 / 0
29.02.2012, 15:18:04
| Ответить | Цитировать | Написать  
ActiveMQ, создание большого числа консюмеров
    #37684559
Фотография Blazkowicz
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Blazkowicz
Участник
А если размер пула все же поменьше выставить? В 100, например. Это как-то повлияет на ситуацию?
...
Рейтинг: 0 / 0
29.02.2012, 15:24:03
| Ответить | Цитировать | Написать  
ActiveMQ, создание большого числа консюмеров
    #37684700
livehacker
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
livehacker
Участник
Blazkowicz,

Хм.. как, странно, но почти всё тоже самое. Чуточку медленнее
...
Рейтинг: 0 / 0
29.02.2012, 16:10:28
| Ответить | Цитировать | Написать  
ActiveMQ, создание большого числа консюмеров
    #37684705
livehacker
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
livehacker
Участник
livehacker,

Я очень хочу перейти на openmq, отзывы хорошие.. Но интегрировать транспорт тяжело:(
...
Рейтинг: 0 / 0
29.02.2012, 16:11:20
| Ответить | Цитировать | Написать  
ActiveMQ, создание большого числа консюмеров
    #37684718
Фотография Blazkowicz
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Blazkowicz
Участник
livehackerХм.. как, странно, но почти всё тоже самое. Чуточку медленнее
Надо запускать под сэмплирующим профайлером и таки посомтреть где тормозит. С jvisualvm работы на час, не больше.
...
Рейтинг: 0 / 0
29.02.2012, 16:17:58
| Ответить | Цитировать | Написать  
ActiveMQ, создание большого числа консюмеров
    #37684719
livehacker
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
livehacker
Участник
Blazkowicz,

Уже начал под jprofiler'ом
...
Рейтинг: 0 / 0
29.02.2012, 16:19:49
| Ответить | Цитировать | Написать  
ActiveMQ, создание большого числа консюмеров
    #37684732
livehacker
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
livehacker
Участник
Какие могут быть ещё идеи, по поводу возникновения экспешенов (возникают при возникновении тормозов):

Код: java
1.
2.
3.
4.
5.
6.
7.
 at java.nio.channels.spi.AbstractSelectableChannel.register(AbstractSelectableChannel.java:167)
 at org.apache.activemq.transport.nio.SelectorSelection$1.run(SelectorSelection.java:44)
 at org.apache.activemq.transport.nio.SelectorWorker.processIoTasks(SelectorWorker.java:75)
 at org.apache.activemq.transport.nio.SelectorWorker.run(SelectorWorker.java:91)
 at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
 at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
 at java.lang.Thread.run(Thread.java:662)
...
Рейтинг: 0 / 0
29.02.2012, 16:25:20
| Ответить | Цитировать | Написать  
ActiveMQ, создание большого числа консюмеров
    #37684768
Фотография Blazkowicz
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Blazkowicz
Участник
livehackerКакие могут быть ещё идеи, по поводу возникновения экспешенов (возникают при возникновении тормозов):

Channel с какого-то перепугу закрылся.
...
Рейтинг: 0 / 0
29.02.2012, 16:46:54
| Ответить | Цитировать | Написать  
ActiveMQ, создание большого числа консюмеров
    #37684806
забыл ник
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
забыл ник
Участник
Может тупо файрвол какой-нибудь обрыгивается на большое число коннектов или что-то подобное
...
Рейтинг: 0 / 0
29.02.2012, 17:03:18
| Ответить | Цитировать | Написать  
ActiveMQ, создание большого числа консюмеров
    #37684811
Фотография Blazkowicz
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Blazkowicz
Участник
забыл никМожет тупо файрвол какой-нибудь обрыгивается на большое число коннектов или что-то подобное
+1
...
Рейтинг: 0 / 0
29.02.2012, 17:05:11
| Ответить | Цитировать | Написать  
ActiveMQ, создание большого числа консюмеров
    #37685006
drsm
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
drsm
Участник
ulimit -n можт?
...
Рейтинг: 0 / 0
29.02.2012, 19:19:31
| Ответить | Цитировать | Написать  
ActiveMQ, создание большого числа консюмеров
    #37685013
livehacker
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
livehacker
Участник
drsmulimit -n можт?
А в винде такое есть?D
...
Рейтинг: 0 / 0
29.02.2012, 19:30:42
| Ответить | Цитировать | Написать  
ActiveMQ, создание большого числа консюмеров
    #37685067
drsm
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
drsm
Участник
livehackerdrsmulimit -n можт?
А в винде такое есть?D
под виндой что-то никогда не запускал что-то открывающее столько сокетов :D.
1024 лимит на линуксе дефолтный.
...
Рейтинг: 0 / 0
29.02.2012, 20:25:14
| Ответить | Цитировать | Написать  
51 сообщений из 51, показаны все 3 страниц
  все  
Форумы / Java [игнор отключен] [закрыт для гостей] / ActiveMQ, создание большого числа консюмеров
Найденые пользователи ...
Разблокировать пользователей ...
Читали тему (0):
Читали форум (0):
Пользователи онлайн (0):
Польз. соглашение   Полит. конфиден.  
NoSQL.ru       Кролег: Проекты, Новости, Чат       РЕД ФОРУМ       Фотоальбом: Участники, Встречи
Закрыть
start [/forum/topic.php?all=1&fid=59&tid=2132440]:
 0ms
get settings:
 11ms
get forum list:
 17ms
check forum access:
 3ms
check topic access:
 3ms
track hit:
 47ms
get topic data:
 14ms
get forum data:
 4ms
get page messages:
 99ms
get tp. blocked users:
 2ms
others: 354ms
total:  554ms
созд. / загр.: 554ms
x
x
Закрыть


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