|
@@ -242,10 +242,12 @@ public class GRPCController extends BaseController {
|
|
.buildPartial();
|
|
.buildPartial();
|
|
outputStream = response.getOutputStream();
|
|
outputStream = response.getOutputStream();
|
|
Iterator<PredictionResponse> predictions = stub.streamPredictions(request);
|
|
Iterator<PredictionResponse> predictions = stub.streamPredictions(request);
|
|
|
|
+ outputStream.write("begin".getBytes());
|
|
|
|
+ outputStream.flush();
|
|
//将结果记录到问答表
|
|
//将结果记录到问答表
|
|
while (predictions.hasNext()) {
|
|
while (predictions.hasNext()) {
|
|
String responseStr = predictions.next().getPrediction().toStringUtf8();
|
|
String responseStr = predictions.next().getPrediction().toStringUtf8();
|
|
-// System.out.println(responseStr);
|
|
|
|
|
|
+ System.out.println(responseStr);
|
|
responseStr = JSON.parseObject(responseStr).getString("message");
|
|
responseStr = JSON.parseObject(responseStr).getString("message");
|
|
if("complete".equals(responseStr)){
|
|
if("complete".equals(responseStr)){
|
|
System.out.println("结尾语句并且是非JSON,无需处理");
|
|
System.out.println("结尾语句并且是非JSON,无需处理");
|