Cassandra， Jersey rest api 随着每个 rest 请求增加线程、内存使用量和端口

Question

我创建了简单的jersey rest api来查询cassandra。还使用 Ajax 长轮询。但是，随着每个请求内存、端口使用率和线程的增加，即使在请求完成后，这些也不会减少。也关闭了卡桑德拉会议，但没有运气。下面是其余代码

@Path("/pull")
@GET
@Produces(MediaType.APPLICATION_JSON)
public JSONArray get(@QueryParam("offset") String offset, @QueryParam("currentUser") String currentUser,
        @QueryParam("longPolling") boolean longPolling) {
    JSONArray messages = new JSONArray();
    JSONObject message = null;
    Session session = Connector.getSession();
    String query = "SELECT * FROM messages";
    ResultSet resultSet = null;
    PreparedStatement ps = null;
    BoundStatement stmt = null;
    int timeOut = 0;
    try {
        while (messages.length() == 0 && timeOut++ < 30) {
            if (longPolling && !offset.equals("0")) {
                query = "SELECT * FROM messages WHERE id > ? ALLOW FILTERING";
                ps = session.prepare(query);
                stmt = ps.bind(UUID.fromString(offset));
                resultSet = session.execute(stmt);
            } else {
                resultSet = session.execute(query);
            }
            List<Row> ls = resultSet.all();
            ls.sort(new Sort<Row>());
            for (Row row : ls) {
                if ((!longPolling || !row.getString("sentby").equals(currentUser))) {
                    message = new JSONObject();
                    message.put("id", row.getUUID("id"));
                    message.put("sentby", row.getString("sentby"));
                    message.put("message", row.getString("message"));
                    messages.put(message);
                }
            }
            if (messages.length() == 0 && longPolling) {
                Thread.sleep(1000);
            }
        }
    } catch (JSONException | InterruptedException e) {
        e.printStackTrace();
    } finally {
        message = null;
        resultSet = null;
        session.close();
    }
    return messages;
}

Answer 1

我认为

主要问题是您每次都在初始化会话并将其拆除。会话是一个相对较重的对象，每个应用程序只应使用一个。请将会话放到其他 Bean，然后在此处的代码中使用依赖注入来获取它。不要按请求打开和关闭会话。这绝对不会是高性能的。

也不要每次都准备报表。在您的这个 bean 上，仅创建一个预准备语句并跨请求使用它。