Système de notification avec p: poll / push

J'ai essayé de mettre en œuvre le système de notification de base de base pour un réseau social avec p:poll sur la couche de la vue et un simple NotificationService classe qui obtient les nouvelles notifications de DB et actualise la liste d'avis de NotificationBean qui est viewscoped pour chaque utilisateur. Processus de flux de similaire à ceci:

-Poll calls NotificationBean.getNewNotifications for example every 15 sec.
--getNewNotifications calls NotificationService and DAO methods
---notificationList of user is refreshed
----DataTable on view layer shows new notifications

Mais la préoccupation de p:poll est sur c'est la performance, car il envoie une requête à chaque intervalle d'expiration.

PrimeFaces a PrimePush qui est basée sur l'Atmosphère Cadre, il ouvre le web sockets et semble plus adapté pour la création de systèmes de notifications.

Mais je ne sais pas quels composants et les propriétés qui doivent être utilisés. Il a p:socket composant avec channel de la propriété. Dois-je utiliser des noms d'utilisateur comme un channel valeurs? Ci-dessous un code venant de PrimeFaces vitrine et résume les dernières phrases:

<p:socket onMessage="handleMessage" channel="/notifications" />

Que j'ai compris de cette vitrine exemple ce p:socket écoute notifications canal. Et pousseur extrait de code est:

PushContext pushContext = PushContextFactory.getDefault().getPushContext();       
pushContext.push("/notifications", new FacesMessage(summary, detail));

Mais cela permettra d'informer tous les utilisateurs de pages, j'ai besoin d'un poussoir qui avertit l'utilisateur spécifique. Disons que il y a 2 utilisateurs et supposons que User1 ajoute User2 comme un ami. Il doit y avoir qqch. comme ça:

pushContext.push("User2/notifications", new FacesMessage("friendship request", "from User1"));

Mais je ne suis pas sûr que c'est l'usage correct pour ce genre d'exigence fonctionnelle ou non. Compte tenu de l'évolutivité de l'application, il peut être coûteux d'ouverture si de nombreux canaux par un processus.

Merci pour votre aide.

source d'informationauteur

  1. 8

    PrimeFaces pousser prend en charge un ou plusieurs canaux à pousser. Pour être en mesure de créer des chaînes privées, pour des raisons spécifiques; par exemple, l'utilisateur, comme dans votre cas, vous pouvez créer plusieurs canaux. J'avais utilisé des identifiants uniques pour ce but.

    En gros, j'ai mis en place un managed bean qui est de l'application étendue qui gère le canal utilisateur correspondant, qui devraient être considérés. Vous pouvez la gérer de différentes manières.

    @ManagedBean
@ApplicationScoped
public class ChannelsBean {

    Map<String, String> channels = new HashMap<String, String>();

    public void addChannel(String user, String channel) {
        channels.put(user, channel);
    }

    public String getChannel(String user) {
        return channels.get(user);
    }

}

    Puis à l'injecter ce bean dans le backing bean qui envoie des notifications.

    @ManagedBean
@SessionScoped
public class GrowlBean {

    private String channel;

    @ManagedProperty(value = "#{channelsBean}")
    private ChannelsBean channels;

    private String sendMessageUser;

    private String user;

    @PostConstruct
    public void doPostConstruction() {
        channel = "/" + UUID.randomUUID().toString();
        channels.addChannel(user, channel);
    }

    public void send() {
        PushContext pushContext = PushContextFactory.getDefault().getPushContext();

        pushContext.push(channels.getChannel(sendMessageUser), new FacesMessage("Hi ", user));
    }

    //Getter Setters
}

    Vous devriez donner de la chaîne de valeur de p:socket. Ici, c'est le coup d'envoi de l'exemple de la page;

    <p:growl widgetVar="growl" showDetail="true" />  

<h:form>  
    <p:panel header="Growl">  
        <h:panelGrid columns="2">  
            <p:outputLabel for="user" value="User: " />   
            <p:inputText id="user" value="#{growlBean.sendMessageUser}" required="true" />  


        </h:panelGrid>  

        <p:commandButton value="Send" actionListener="#{growlBean.send}" />  
    </p:panel>  
</h:form>  

<p:socket onMessage="handleMessage" channel="#{growlBean.channel}" />  

<script type="text/javascript">  
function handleMessage(facesmessage) {  
    facesmessage.severity = 'info';  

    growl.show([facesmessage]);  
}  
</script>

    Pour des problèmes d'évolutivité, de vous tenir à l'actif ou inactif canaux. Vous pouvez supprimer celui qui n'est pas en session, ou inactif pendant un certain temps. Supprimer des chaînes en utilisant @PreDestroy annotation quand les haricots sont en train de détruire. Il y a un canal pour une session utilisateur dans ma solution.

    Ma suggestion est; ne pas utiliser des noms d'utilisateur explicitement sur les pages. Il n'est pas bon pour des raisons de sécurité.