BufferingResponseListener 和 getContentAsString 追加之前获取的内容

Question

我运行用于 Jetty 的自定义 WebSocketServlet，它向许多平台（Facebook、Vk.com、Mail.ru、Ok.ru 以及 Firebase 和 Amazon 消息传递）使用 Jetty HttpClient 实例：

public class MyServlet extends WebSocketServlet {
    private final SslContextFactory mSslFactory = new SslContextFactory();
    private final HttpClient mHttpClient = new HttpClient(mSslFactory);

    @Override
    public void init() throws ServletException {
        super.init();

        try {
            mHttpClient.start();
        } catch (Exception ex) {
            throw new ServletException(ex);
        }

        mFcm      = new Fcm(mHttpClient);    // Firebase
        mAdm      = new Adm(mHttpClient);    // Amazon
        mApns     = new Apns(mHttpClient);   // Apple
        mFacebook = new Facebook(mHttpClient);
        mMailru   = new Mailru(mHttpClient);
        mOk       = new Ok(mHttpClient);
        mVk       = new Vk(mHttpClient);
    }

这在过去的一年里非常有效，但是自从我最近升级了我的 WAR-文件以使用 Jetty 9.4.14.v20181114 之后，问题就开始了 -

public class Facebook {
    private final static String APP_ID      = "XXXXX";
    private final static String APP_SECRET  = "XXXXX";
    private final static String MESSAGE_URL = "https://graph.facebook.com/%s/notifications?" +
            // the app access token is: "app id | app secret"
            "access_token=%s%%7C%s" +
            "&template=%s";

    private final HttpClient mHttpClient;

    public Facebook(HttpClient httpClient) {
        mHttpClient = httpClient;
    }

    private final BufferingResponseListener mMessageListener = new BufferingResponseListener() {
        @Override
        public void onComplete(Result result) {
            if (!result.isSucceeded()) {
                LOG.warn("facebook failure: {}", result.getFailure());
                return;
            }

            try {
                // THE jsonStr SUDDENLY CONTAINS PREVIOUS CONTENT!
                String jsonStr = getContentAsString(StandardCharsets.UTF_8);
                LOG.info("facebook success: {}", jsonStr);
            } catch (Exception ex) {
                LOG.warn("facebook exception: ", ex);
            }
        }
    };

    public void postMessage(int uid, String sid, String body) {
        String url = String.format(MESSAGE_URL, sid, APP_ID, APP_SECRET, UrlEncoded.encodeString(body));
        mHttpClient.POST(url).send(mMessageListener);
    }
}

突然，为成功调用 HttpClient 而调用的 getContentAsString 方法开始传递先前获取的字符串 - 预先实际结果字符串。

请问是什么原因，是 BufferingResponseListener 行为发生了一些变化，还是一些不明显的 Java 怪癖？

Answer 1

BufferingResponseListener 从未打算跨请求重复使用。

只需为每个request/response分配一个新的BufferingResponseListener。

BufferingResponseListener 和 getContentAsString 追加之前获取的内容

BufferingResponseListener and getContentAsString append the previously fetched content

java

servlets

jetty

embedded-jetty

jetty-9