Comment concevoir des notifications push à l'aide de l'Atmosphère

Fondamentalement, ce que vous avez besoin est de mettre en œuvre Publish-subscribe sur le dessus de l'Atmosphère.

Atmosphère se compose de deux parties: côté client (javascript) et côté serveur(java).

Tout d'abord, vous devez configurer le serveur-côté: L'Installation De L'Atmosphère

À savoir servlet ou de filtre, il est nécessaire de sorte qu'il pourrait ajouter AtmosphereResource à la HttpServletRequest.

AtmosphereResource représente un unique de connexion du client sur le serveur-côté.

Diffuseur est en fait un conteneur pour ces ressources, de sorte que vous n'avez pas besoin de gérer de recherche/itération/simultanéité lorsque vous avez besoin d'envoyer de multiples connexions. (À noter que plusieurs connexions peuvent être produites par un seul client).

Sur le côté serveur, vous devez fournir à ses clients un point de terminaison de s'abonner aux notifications.
Par exemple, si vous utilisez Spring-MVC, il pourrait aller comme ça (en omettant les validations/authentifications, etc.):

@RequestMapping(value = "/user-notifications/{userId}")
@ResponseStatus(HttpStatus.OK)
@ResponseBody
public void watch(@PathVariable("userId") String userId,
                  HttpServletRequest request) throws Exception {
    //Atmosphere framework puts filter/servlet that adds ATMOSPHERE_RESOURCE to all requests
    AtmosphereResource resource = (AtmosphereResource)request.getAttribute(ApplicationConfig.ATMOSPHERE_RESOURCE);

    //suspending resource to keep connection
    resource.suspend();

    //find broadcaster, second parameter says to create broadcaster if it doesn't exist
    Broadcaster broadcaster = BroadcasterFactory.getDefault().lookup(userId,true);

    //saving resource for notifications
    broadcaster.addAtmosphereResource(resource);
}

Quand quelque chose se produit, vous pouvez informer les clients comme ceci:

public void notify(User user, Event event){
    Broadcaster b = BroadcasterFactory.getDefault().lookup(user.getId());
    if (b!=null){
        b.broadcast(event);
    }
}

Sur le côté client, vous devez envoyer une demande de s'abonner et d'écouter pour la suite des événements, comme ceci:

var request = new atmosphere.AtmosphereRequest();
request.url = '/user-notifications/'+userId;
request.transport = 'websocket';
request.fallbackTransport = 'streaming';
request.contentType = 'application/json';
request.reconnectInterval = 60000;
request.maxReconnectOnClose = 1000;
request.onMessage = function(response){
    console.log(response);
    alert('something happend<br>'+response);
};
that.watcherSocket = atmosphere.subscribe(request);

Donc, pour résumer:

1. Client envoie la demande "je veux recevoir ce genre de notifications".
2. Serveur reçoit la demande, suspend et enregistre connexion quelque part (ni dans le code ou dans le Diffuseur).
3. Quand quelque chose se passe serveur pour la suspension de la connexion et envoie une notification en elle.
4. Client reçoit une notification de rappel est appelée.
5. Profit!!!

Ce wiki a des explications pour certains concepts de base de l'Atmosphère et des liens vers d'autres documents.