Библиотека сообщений Lightweight Message Bus

Question

В ближайшем будущем я начну небольшой проект Java (GWT), и я нахожусь на этапе «сбора информации».

В: Существует ли библиотека сообщений с легкими сообщениями, написанная на Java?

Мои требования легкий тоже :-)

1. асинхронном (нет необходимости в синхронизации)
2. многоадресного и точка-точка
3. нет строгого сообщение заказа
4. сообщение "конверт" в идеале «принадлежит» по шине сообщений (т.е. с точки зрения управления жизненным циклом)
5. локализованная доставка (то есть не межпроцессная или межузловая)

Обновление: Кажется, что GWT теперь поддерживает интегрированный "event bus".

Answer 1

Посмотрите на eventbus.

(Ссылка исправлена, спасибо jldupont, чтобы указать это).

Answer 2

Не уверен, что это действительно легкий вес. Но это не соответствует остальной части вашего описания: ActiveMQ

Answer 3

Возможно, вы можете попробовать решение на основе jabber (XMPP). Как насчет openfire?

Answer 4

Если вы используете Spring уже, то удобной функцией скрытой функции Spring является интерфейс ApplicationEventMulticaster, который представляет собой очень простой API для публикации и подписки на события, созданные приложением. В реализациях используется каркас TaskExecutor, что означает, что они могут синхронизироваться или асинхронно по желанию. Кроме того, каждый имеет метод publishEvent, поэтому его легко настроить для классов, управляемых Spring.

Так что да, если вы уже используете Spring, вам не нужно использовать еще одну утилиту для этого, она уже встроена.

Answer 5

Я знаю, что это старый вопрос, но я думаю, что более современное решение заключается в использовании Guava's Event Bus (предоставлен Я не уверен, если он будет работать на GWT, но и ваш заголовок и теги не говорят GWT).

У меня есть обычай RabbitMQ simple message container, который автоматически создаст привязки очередей и полученные сообщения отправит в Guava EventBus. Его невероятная элегантность и весы великолепно.

Вы можете легко использовать свою инфраструктуру DI для регистрации подписчиков. Для Spring я создаю BeanPostProcessor, который автоматически регистрирует bean-компоненты с @Subscribe.

Ниже Spring BeanPostProcessor:

package com.snaphop.spring; 

import java.lang.reflect.Method; 

import org.springframework.beans.BeansException; 
import org.springframework.beans.factory.annotation.Autowired; 
import org.springframework.beans.factory.config.BeanPostProcessor; 
import org.springframework.stereotype.Component; 

import com.google.common.eventbus.EventBus; 
import com.google.common.eventbus.Subscribe; 

@Component 
public class EventBusBeanPostProcessor implements BeanPostProcessor { 

    private EventBus eventBus; 

    @Override 
    public Object postProcessBeforeInitialization(Object bean, String beanName) throws BeansException { 
     if (isApplicable(bean)) { 
      eventBus.register(bean); 
     } 
     return bean; 
    } 

    @Override 
    public Object postProcessAfterInitialization(Object bean, String beanName) throws BeansException { 
     return bean; 
    } 

    protected boolean isApplicable(Object bean) { 
     for(Method m : bean.getClass().getMethods()) { 
      if (m.isAnnotationPresent(Subscribe.class)) 
       return true; 
     } 
     return false; 
    } 

    @Autowired 
    public void setEventBus(EventBus eventBus) { 
     this.eventBus = eventBus; 
    } 

} 

Я уверен, что это тривиально, чтобы сделать что-то подобное в Guice.