使用Jmeter处理SSE请求

import org.apache.http.impl.client.CloseableHttpClient
import org.apache.http.impl.client.HttpClients
import org.apache.http.client.methods.HttpGet
import org.apache.http.impl.conn.PoolingHttpClientConnectionManager
import org.apache.http.protocol.BasicHttpContext
import org.apache.http.HttpResponse
import org.apache.http.util.EntityUtils

PoolingHttpClientConnectionManager cm = new PoolingHttpClientConnectionManager()
CloseableHttpClient httpclient = HttpClients.custom()
        .setConnectionManager(cm)
        .build()

HttpGet httpGet = new HttpGet("http://your-sse-server.com/events")
HttpResponse response = httpclient.execute(httpGet, new BasicHttpContext())

response.getEntity().getContent().eachLine { line ->
    log.info(line)
    // 这里你可以处理每一行数据，例如将其保存到文件或者添加到JMeter变量中
}

EntityUtils.consume(response.getEntity())