对于我们的项目之一,我们通过使用Java jersey客户端使用HTTP提要流。
对于客户端,可以很好地使用Feed,但是在10分钟之后,流量会异常下降;即使流生产者启动并运行并生产流
这是我尝试过的;

import java.util.Date;

import javax.ws.rs.client.Client;
import javax.ws.rs.client.ClientBuilder;
import javax.ws.rs.client.WebTarget;
import javax.ws.rs.client.Invocation.Builder;
import javax.ws.rs.core.GenericType;
import javax.ws.rs.core.MediaType;
import javax.ws.rs.core.Response;

import org.glassfish.jersey.client.ChunkedInput;

public class StreamClient {

    private static final String BOUNDARY = "\n";

    public void makeCall() {
        System.out.println("Start Time"+ new Date()) ;
        Client client = ClientBuilder.newClient();
        BasicAuth auth = new BasicAuth();
        auth.setPassword("username");
        auth.setUserName("password");
        BasicAuthentication basicAuthentication = new BasicAuthentication(auth);
        client.register(basicAuthentication);
        WebTarget target = client.target("https://localhost:7211/stream/v1/");
        Builder request = target.request(MediaType.APPLICATION_JSON);
        Response response = request.get();

        final ChunkedInput<String> chunkedInput = response.readEntity(new GenericType<ChunkedInput<String>>() {
        });

        chunkedInput.setParser(ChunkedInput.createParser(BOUNDARY));
        String chunk;
        do {
            if((chunk = chunkedInput.read()) != null)
                System.out.println(chunk);
        }while (!chunkedInput.isClosed());
        System.out.println("End Time " + new Date());
    }

    public static void main(String[] args) {
        StreamClient client = new StreamClient();
        client.makeCall();
    }


}
如果流不下降;线程必须在while循环内;一旦流关闭,线程将出来并打印sysout语句
这里的问题是;为什么chunkedinput是关闭的。
在这里,对于服务器端的每个有效负载/块分隔,它都是\r\n,并且要使其从服务器处于 Activity 状态,发送\n(在客户端,我必须忽略这一点。)

最佳答案

我建议您在断开连接的那一刻,使用wireshark准确地分析流量,这很可能是防火墙切断了连接。

无论如何,在没有双面日志记录的情况下尝试调试这些方案都是50%的俄罗斯小规矩情况。

如果要丢弃方案,请尝试更改正在传输的数据量,连接的参数(使用其他构造函数方法),并查看超时是否在时间上保持一致(如果超时取决于通常情况下的流量)您在诸如防火墙之类的中间设备中触发某个阈值的线索。

09-05 15:30
查看更多