wso2 msf4j : 서버 속성을 구성하는 방법

Question

현재 StreamingOutput API와 함께 MSF4J를 사용하려고합니다. 그러나 File을 스트리밍하는 대신 일련의 끝이없는 짧은 문자열/텍스트를 스트리밍하려고합니다. 문자열이 클라이언트에 즉시 플러시되기를 원합니다. 그러나, 클라이언트는 플러시 후에 그것을 얻지 못하고있다. 내 문자열이 청크에 잠시 후에 플러시되기 때문에 그것이 기본 8kb 버퍼로 인해 믿습니다. glassfish에서와 같은 방법으로이 기본 버퍼를 재정의하려면 어떻게합니까? https://jersey.java.net/apidocs/2.22/jersey/org/glassfish/jersey/server/ServerProperties.html#OUTBOUND_CONTENT_LENGTH_BUFFER

내가 원하는 뭔가 같은 ...

Properties properties = new Properties() 
properties.set("jersey.config.server.contentLength.buffer", 0);** 

new MicroservicesRunner() 
    .setProperties(properties)** 
    .addInterceptor(new HTTPMonitoringInterceptor()) 
    .deploy(new MyService()) 
    .start(); 

내 streamingout 클래스

new StreamingOutput(){  
    public void write(OutputStream os) throws IOException, WebApplicationException  { 
     while(true){ 
      os.write("some string".getBytes()); 
      os.flush(); 
     }  
     } 
} 

당신을 감사합니다.

Answer 1

이것은 전체 코드입니다. 작동하지만 서버 속성을 무시할 수있는 방법이 필요합니다.

properties.set ("jersey.config.server.contentLength.buffer", 0); 덕분에 .

패키지 ph.sample.api.ms;

import org.wso2.msf4j.MicroservicesRunner; import org.wso2.msf4j.analytics.httpmonitoring.HTTPMonitoringInterceptor;

Public 클래스 출원 { 공공 정적 무효 메인 (문자열 []에 args) {

new MicroservicesRunner(9000) 
      .addInterceptor(new HTTPMonitoringInterceptor()) 
      .deploy(new StreamService()) 
      .start(); 
} } 

패키지 ph.sample.api.ms;

import javax.ws.rs.GET; import javax.ws.rs.Path; import javax.ws.rs.core.Response;

import org.wso2.carbon.metrics.core.annotation.Timed; 가져 오기 java.io.IOException; import java.io.OutputStream;

import javax.ws.rs.WebApplicationException; import javax.ws.rs.core.StreamingOutput;

@Path ("/ 스트림") 공용 클래스 StreamService { @GET @Path ("/ 등록") 이 @Timed 공공 응답() {

return Response.ok(new StreamingOutput(){ 
     @Override   
     public void write(OutputStream os) throws IOException, WebApplicationException { 
     while(true){ 
      os.write("some string".getBytes()); 
      os.flush(); 
     }    
     } 
    }).build(); 
} 

}

가입