p：poll/push的通知系統

Question

我試圖實現基本社交網絡的基本通知系統p:poll在視圖層和一個簡單的NotificationService類從數據庫獲取新的通知和刷新通知列表NotificationBean這是每個用戶viewscoped。類似這樣的流程：

-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有PrimePush它基於Atmosphere Framework，它打開網絡套接字，似乎更適合創建通知系統。

但我不知道應該使用哪些組件及其屬性。它有p:socket組件和channel屬性。我應該使用用戶名作爲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添加爲朋友。一定有某事。像這樣：

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

但我不確定這是否正確使用這種功能要求或不。考慮到應用程序的可擴展性，每個進程開放如此多的通道可能需要昂貴的成本。

感謝您的幫助。

Answer 1

PrimeFaces push支持一個或多個推送通道。能夠因特定原因創建私人頻道;例如，像您的情況一樣，您可以創建多個頻道。我爲此使用了獨特的ID。

基本上，我已經實現了一個託管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註釋移除頻道。我的解決方案中有一個用戶會話通道。

我的建議是;請勿在網頁上明確使用用戶名。由於安全原因，這並不好。