Libreria Light Message Bus

Question

Inizierò un piccolo progetto Java (GWT in realtà) nel prossimo futuro e sono nella fase di "raccolta di informazioni".

D: Esiste una libreria di bus messaggi leggera scritta in Java?

I miei requisiti sono leggeri troppo :-)

1. asincrone (senza bisogno di sincronizzazione)
2. multicast e point-to-point
3. alcun messaggio rigorosa ordinare
4. messaggio "busta" idealmente "posseduto" da Message Bus (cioè in termini di gestione del ciclo di vita)
5. consegna localizzata (cioè non inter-processo né inter-nodo)

Aggiornamento: Sembra che GWT ora supporti uno "event bus" integrato.

Answer 1

Dai un'occhiata allo eventbus.

(Collegamento fisso, grazie a jldupont per segnalarlo).

Answer 2

Non sono sicuro se è davvero leggero. Ma corrisponde al resto della tua descrizione: ActiveMQ

Answer 3

Forse potresti provare una soluzione basata su jabber (XMPP). Che dire di openfire?

Answer 4

Se si utilizza già Spring, una comoda funzionalità di Spring è l'interfaccia ApplicationEventMulticaster, che è un'API molto semplice per la pubblicazione e la sottoscrizione di eventi generati dall'applicazione. Le implementazioni utilizzano il framework TaskExecutor, il che significa che possono essere sincronizzati o asincroni come desiderato. Inoltre, ogni ApplicationContext ha un metodo publishEvent, quindi è comicamente facile impostarlo per le classi gestite in Primavera.

Quindi sì, se già usi Spring, non c'è bisogno di un'altra utility per farlo, è già integrata.

Answer 5

So che questa è una vecchia questione, ma penso che una soluzione più moderna è quella di utilizzare Guava's Event Bus (concesso non sono sicuro se funzionerà per GWT, ma sia il titolo e tag non dire GWT).

In realtà ho una RabbitMQ simple message container personalizzata che creerà automaticamente i binding della coda e sui messaggi ricevuti verrà quindi inviata a Guava EventBus. È incredibilmente elegante e si adatta perfettamente.

È possibile utilizzare facilmente il framework DI per registrare gli abbonati. Per Spring, creo BeanPostProcessor che registrerà automaticamente i bean con @Subscribe.

Di seguito è la molla 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; 
    } 

} 

Sono sicuro che è banale per fare qualcosa di simile in Guice.