Распределенный механизм обработки событий для Java
Итак, влияет ли добавление ожидания следующим образом?
import { AppPage } from './app.po';
// Test bed
describe('workspace-project App', () => {
let page: AppPage;
beforeEach(() => {
page = new AppPage();
});
it('should display navbar with title', () => {
page.navigateTo().then(() => {
console.log('Successfully connected to the page');
});
browser.ignoreSynchronization = true
driver.wait(function () {
return driver.isElementPresent(page.getHeaderText('hobbies'));
}, timeout);
expect(page.getHeaderText()).toEqual('hobbies');
browser.ignoreSynchronization = false;
});
});
7 ответов
AMQP (Усовершенствованный Протокол Организации очередей сообщений) - больше деталей: http://en.wikipedia.org/wiki/Advanced_Message_Queuing_Protocol , вероятно, что Вы ищете.
Это используется компаниями финансовых услуг для их высокопроизводительных требований - у апача есть движение реализации - http://cwiki.apache.org/qpid/
OpenAMQ - , http://www.openamq.org/ является более старой ССЫЛОЧНОЙ РЕАЛИЗАЦИЕЙ.
Какой бы ни инструмент, который Вы используете, я рекомендовал бы скрыть API промежуточного программного обеспечения от Вашей прикладной логики. Например, если бы Вы использовали подход Camel Apache к скрывающемуся промежуточному программному обеспечению , то Вы могли бы затем легко переключиться от AMQP до SEDA к JMS к ActiveMQ к JavaSpaces к Вашему собственному транспорту MINA на основе Ваших строгих требований.
, Если бы Вы хотите использовать брокер сообщений, я рекомендовал бы использовать Apache ActiveMQ, который является самым популярным и мощным брокером сообщений с открытым исходным кодом с самое многочисленное самое активное сообщество позади него и в Apache и снаружи .
В зависимости от Вашего варианта использования Терракота может быть отличным выбором.
Для распределенной Обработки событий Вы могли использовать , Esper.It мог обработать до 500 000 событий/с на двойном ЦП основанные на Intel аппаратные средства на 2 ГГц. Это очень стабильно, потому что многие банки используют это решение. Это поддерживает входной и выходной адаптер JMS на основе Spring шаблоны JMS. Таким образом, Вы могли использовать любую реализацию JMS для обработки событий, т.е. ActiveMQ.
темой Hazelcast является распределенное решение для обмена сообщениями паба-sub.
public class Sample implements MessageListener {
public static void main(String[] args) {
Sample sample = new Sample();
Topic topic = Hazelcast.getTopic ("default");
topic.addMessageListener(sample);
topic.publish ("my-message-object");
}
public void onMessage(Object msg) {
System.out.println("Message received = " + msg);
}
}
Hazelcast также поддерживает события на распределенной очереди, карте, наборе, списке. Все события заказаны также.
С уважением,
-talip
Если реализация JMS не для Вас, то можно интересоваться подход XMPP. Существует несколько реализаций и также имеют , Публикуют - Подписываются расширение .
Маршрутизатор событий Avis может подойти для ваших нужд. Этого достаточно для доставки событий почти в реальном времени, таких как отправка событий мыши для удаленного управления мышью (приложение, которое мы используем ежедневно).
Avis также используется для чата, виртуального присутствия и автоматизации умных комнат, где обычно 10-20 компьютеров обмениваются данными по шине обмена сообщениями на базе Avis. Его коммерческий родственник (Mantara Elvin) используется для обработки крупномасштабных коммерческих торговых мероприятий.