p：poll/pushを使用した通知システム

Question

ビューレイヤでp:pollの基本ソーシャルネットワークの基本通知システムを実装しようとしましたが、NotificationServiceクラスでは新しい通知をDBから取得し、NotificationBeanこれは各ユーザーについて表示されます。これに似たプロセスフロー：

-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 

しかしp:pollの懸念は、それがすべての間隔満了時にクエリを送信しますので、それはパフォーマンスだについてです。

PrimeFacesは、Atmosphere Frameworkに基づいて、Webソケットを開き、通知システムを作成するのに適しているように見えます。PrimePushがあります。

しかし、どのコンポーネントとどのプロパティを使用するべきかわかりません。これは、channelプロパティを持つp:socketコンポーネントを持っています。ユーザー名をchannelの値として使用する必要がありますか？ PrimeFacesからのコードの下には、最後の文章を紹介し、まとめたものです。

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

は、私の知る限り理解されるように this showcase exampleからこの p:socketは notificationsチャネルをリッスンします。私は、特定のユーザに通知プッシャーを必要とし、

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

しかし、これは、すべてのユーザーページに通知します：そしてプッシャーコードスニペットです。たとえば、2人のユーザーがおり、User1がUser2を友人として追加したとします。 sthがなければなりません。

しかし、これはこの種の機能要件の正しい使用法であるかどうかはわかりません。アプリケーションのスケーラビリティを考慮すると、プロセスごとに非常に多くのチャネルを開くコストが高くなる可能性があります。

ありがとうございます。

Answer 1

PrimeFacesプッシュは、プッシュする1つ以上のチャネルをサポートします。特定の理由でプライベートチャネルを作成できるようにするにはあなたの場合のようにユーザーごとに、複数のチャンネルを作成することができます。私はこの目的のためにユニークなIDを使用していました。

基本的に、私は、管理対象のBeanを実装しました。このBeanは、ユーザースコープを考慮して処理するアプリケーションスコープです。それをさまざまな方法で維持することができます。

@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); 
    } 

} 

このBeanを通知を送信するバッキングBeanに挿入します。

@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 
} 

チャネルの値をp：socketに与える必要があります。ここにはページのキックオフの例があります。

<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> 

スケーラビリティの問題については、アクティブまたは非アクティブのチャネルを維持する必要があります。あなたはしばらくの間、セッションまたは非アクティブではないものを削除することができます。 Beanが破棄されているとき@PreDestroyアノテーションを使用してチャネルを削除します。私のソリューションには、1つのユーザーセッションに1つのチャネルがあります。

私の提案は、ページでユーザー名を明示的に使用しないでください。セキュリティ上の理由から、それは良くありません。