java grpc bistream 样例

下面是一个使用Java gRPC的示例代码，其中使用了ByteString来处理二进制数据流：

import io.grpc.ManagedChannel;
import io.grpc.ManagedChannelBuilder;
import io.grpc.stub.StreamObserver;

import com.google.protobuf.ByteString;

import example.StreamingRequest;
import example.StreamingResponse;
import example.StreamingServiceGrpc;

public class GrpcExample {
    public static void main(String[] args) {
        ManagedChannel channel = ManagedChannelBuilder.forAddress("localhost", 50051)
                .usePlaintext()
                .build();

        StreamingServiceGrpc.StreamingServiceStub stub = StreamingServiceGrpc.newStub(channel);

        StreamObserver<StreamingRequest> requestObserver = stub.streamingMethod(new StreamObserver<StreamingResponse>() {
            @Override
            public void onNext(StreamingResponse value) {
                // 处理响应
            }

            @Override
            public void onError(Throwable t) {
                // 处理错误
            }

            @Override
            public void onCompleted() {
                // 处理完成
            }
        });

        // 发送请求流
        for (int i = 0; i < 10; i++) {
            ByteString data = ByteString.copyFromUtf8("Request " + i);
            StreamingRequest request = StreamingRequest.newBuilder()
                    .setData(data)
                    .build();

            requestObserver.onNext(request);
        }

        // 完成请求流
        requestObserver.onCompleted();

        // 阻塞等待完成
        try {
            Thread.sleep(5000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }

        channel.shutdown();
    }
}

在上述示例中，我们创建了一个ManagedChannel，连接到gRPC服务器。然后，我们使用StreamingServiceGrpc.StreamingServiceStub创建了一个请求流的StreamObserver。我们通过调用onNext方法发送StreamingRequest对象，其中使用ByteString来包装二进制数据流。最后，我们通过调用onCompleted方法来完成请求流。

注意：上述示例仅用于演示用途，实际使用时需要根据自己的需求进行适当的修改和处理