java 球衣客户端的 HTTP 流异常下降

Question

对于我们的一个项目，我们使用 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 关闭了。

在这里，对于服务器端的每个 payload/chunk 分隔，它是 \r\n 并使其从服务器激活连接，发送 \n （在客户端，我必须忽略它.)

Answer 1

我建议使用 wireshark 在连接丢失的那一刻准确地分析流量，很可能是防火墙正在切断连接。

无论如何，在没有双面日志记录的情况下尝试调试这些场景是 50% 的俄罗斯规则情况。

如果你想放弃场景尝试改变正在传输的数据量，连接的参数（使用其他构造函数方法）并查看超时时间是否一致，如果超时取决于数量流量通常是您在防火墙等中间设备中触发某个阈值的线索。

java 球衣客户端的 HTTP 流异常下降

HTTP Stream dropping abnormally with java jersey client

java

jersey

jersey-client