网站建设功能描述书,公司简介万能模板,网站开发所使用的浏览器,网络科技公司洛阳在此篇中我们将简要介绍关于grpc对java客户端的实现。在开始开发前#xff0c;我们需要先导入io.grpc grpc-netty 1.11.0io.grpc grpc-protobuf 1.11.0io.grpc grpc-stub 1.11.0如果是Android除了这几个包外#xff0c;你可能还需要一个javax.annotation:javax.annotation-ap…在此篇中我们将简要介绍关于grpc对java客户端的实现。在开始开发前我们需要先导入 io.grpc grpc-netty 1.11.0io.grpc grpc-protobuf 1.11.0io.grpc grpc-stub 1.11.0 如果是Android除了这几个包外你可能还需要一个javax.annotation:javax.annotation-api:1.2包这个大家可以自行百度。 当然你如果想自己编译proto文件你还需要引用一些插件具体你可以看 https://github.com/grpc/grpc-java 完成包的导入后我们就可以正式开始开发了首先需要导入proto的生成文件。 根据上篇中大约有3个文件在这里再说明一次多文件必须把引用的文件一同编译。否则你将不会生成outerclass那个文件导致报错。这点一定要注意。 接下来我们就可以编码了在java端grpc存在3种stub包括stubblockingstub和futurestub。 其中futurestub只支持普通的grpc服务不支持流的形式。 blockingstub支持普通的和服务端流。 stub支持所有的形式。 先让我们看一下普通形式请求和服务端流形式请求。 int port 50052; String urlPath 192.168.2.223; Channel channel; //设置grpc链接 channel NettyChannelBuilder.forAddress(urlPath, port).negotiationType(NegotiationType.PLAINTEXT).build(); UserServerGrpc.UserServerBlockingStub userServerBlockingStub UserServerGrpc.newBlockingStub(channel); UserVo.User user UserVo.User.newBuilder().setUserId(1).build(); //根据条件获得用户 UserVo.User u userServerBlockingStub.getUserById(user); System.out.println(u); System.out.println(); //获得用户列表 UserVo.Empty empty UserVo.Empty.newBuilder().build(); UserVo.UserList userList userServerBlockingStub.getList(empty); for(int i0;i userIterator userServerBlockingStub.getListStream(empty); while (userIterator.hasNext()){ System.out.println(userIterator.next().toString()); } 这两种比较简单只需要我们建立一个stub然后调用对应的方法填入数据即可。 对于客户端流和双向流是一样的我们首先需要实现一个StreamObserver的接口在onnext方法中拿到返回数据。在onCompleted中判断是否完成。 final StreamObserver streamObserver new StreamObserver() { Override public void onNext(UserVo.UserList userList) { //拿到服务端返回值 } Override public void onError(Throwable throwable) { } Override public void onCompleted() { //完成 } }; UserVo.User U1 UserVo.User.newBuilder().setUserId(3).setUserName(小刘).setAge(10).build(); UserVo.User U2 UserVo.User.newBuilder().setUserId(4).setUserName(小红).setAge(23).build(); UserVo.UserList userList1 UserVo.UserList.newBuilder().setU(1,U1).setU(2,U2).build(); UserServerGrpc.UserServerStub userServerBlockingStub1 UserServerGrpc.newStub(channel); final StreamObserver streamObserver1 userServerBlockingStub1.setUserStream(streamObserver); //发送数据 streamObserver1.onNext(U1); streamObserver1.onNext(U2); //发送完成 streamObserver1.onCompleted(); 到此grpc的4种形式基本就算是结束grpc在调用上比较简单主要是在proto的编译上。如果编译正确基本使用还是比较简单的。
