ロングポーリングでユーザーごとに異なったレスポンスを返したい

Question

現在ロングポーリングを用いてSNSアプリケーションを作れないかと考えています
しかし下記のコードでは全てのメッセージを対象にした更新は出来てもユーザーごとに異なったレスポンス、例えば
あるユーザーがフォローしている相手のコメントを選別して返すというようなことは出来ません

そこでデータベースへの問い合わせにユーザー情報を付随させる、或いはデータベースから取得した情報をユーザーごとに
フィルタリングする方法などがあれば教えてください
なおロングポーリングの手法はこちらの"Comet(ロングポーリング) 非同期"のサンプルを参考にしました

package servlet;

import java.io.IOException;
import java.io.PrintWriter;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.Timer;
import java.util.TimerTask;
import java.util.concurrent.CopyOnWriteArrayList;

import javax.servlet.AsyncContext;
import javax.servlet.ServletConfig;
import javax.servlet.ServletException;
import javax.servlet.annotation.WebServlet;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import javax.servlet.http.HttpSession;

import com.fasterxml.jackson.databind.ObjectMapper;

import dao.CommentDAO;
import model.ActiveUser;
import model.CommentSet;


@WebServlet(name = "UpdateMessage", urlPatterns = { "/UpdateMessage" }, asyncSupported = true)
public class UpdateMessage extends HttpServlet {
	private static final long serialVersionUID = 1L;
	int count;
	List<AsyncContext> queue = new ArrayList<>();

	public void init(ServletConfig config) throws ServletException {
		super.init();
		//5秒ごとに更新
		Timer timer = new Timer();
		TimerTask task = new TimerTask() {
			@Override
			public void run() {
				count++;
				//新着メッセージをDBから取得
				CommentDAO commentDAO = new CommentDAO();
				List<Map<String, String>> result = commentDAO.selectNewComment();
				broadcast(result);
			}
		};
		timer.schedule(task, 5000, 5000);
	}

	synchronized public void broadcast(List<Map<String, String>> result) {
		CopyOnWriteArrayList<AsyncContext> target = new CopyOnWriteArrayList<>(queue);
		synchronized (queue) {
			queue = new ArrayList<>();
		}
		for(AsyncContext context : target) {
			HttpServletResponse response = (HttpServletResponse) context.getResponse();
			response.setContentType("application/json");
			try {
				ObjectMapper mapper = new ObjectMapper();
				String json = mapper.writeValueAsString(result);
				System.out.println(json);
				response.setContentType("application/json;charset=UTF-8");
				PrintWriter writer = response.getWriter();
				writer.print(json);
				writer.close();
				context.complete();
			} catch(IOException e) {
				e.printStackTrace();
			}
		}
	}

	@Override
	protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
		try {
			final AsyncContext context = request.startAsync();
			queue.add(context);
		}catch(IllegalStateException e) {
			e.printStackTrace();
		}
	}
}

Answer 1

あるユーザーがフォローしている相手のコメントを選別して返す

実現する方法はいくつかあると思いますが例として

1.リクエストにユーザーの認証情報を付加

• user_id などの情報をクライアントがリクエストに付加する
  • もしsecureである必要があると単に user_id だと用意に他の人もアクセスできてしまうので、認証の部分作る必要あり
• queue にその情報を保存
• broadcast 時に user_id でフィルタ

2.HTTPリクエストを挟む

• broadcast は現状の仕組み
  • ただ、全コメント流れてしまうので secure ではない
• Commentを取得するようなHTTPエンドポイントを用意する
  • ここにフォローしているか？新着か？などのロジックで内容や返す返さないを実装
• ユーザー側で boardcast のレスポンスをそのまま出すのではなく、その comment_id なりでもう一度????のエンドポイントにリクエスト
• ユーザー側で 返ってきた内容を表示

のような感じですかね？ただ、実サービスを作る場合、どちらもセキュアでないかつ Commet よりも Websocket が利用できる場合そのほうがパフォーマンス等優れているために

Socket.io Websocket / Commet を実装したライブラリ
Pusher リアルタイム通信のための HTTP API を用意したサービス

等利用を検討するとよいかと思います。