A tour of grp:05 - GRP server streaming service end stream

In the last one , We did gRPC Medium unary call, That is, the client sends a request , The server replies with a response . And tried   It invokes in a cross language situation . In this paper , We will try to achieve  server straming  That is, the client sends a request , service   The client replies to multiple responses , And also try to call across languages .

go server straming call

1.  add to filter_message.proto  Used to describe filter criteria .

​2.  modify laptop_service.proto  add to   A search  service.

​3.  function  make clean  and  make gen  The generated code

4.  stay laptop_store.go  stay  LaptopStore  Add to interface  Search  function , And add the corresponding implementation .( Because deep copy ⻉ Used multiple times , Here is a function )

​5.  stay laptop_server.go  Add  SearchLaptop  Method

​6.  take  client  Under bag  main.go  Medium  createLaptop  Logical extraction , And in main Function using  for  establish 10 individual ;  Add a filter

​7. make server Run the server  make client  Running client , View results , Running normally

​ Can be observed , In the creation of 10 individual Laptop, After receiving the filter conditions ,server  Will check one by one map Data in , If   accord with , Then return a , That is, the result is returned item by item several times .

Java server straming call

1.  take  gRpc go Straming  Writing in the filter_message.proto and  laptop_service.protp  File copy ⻉  to  Java  Project  proto  In the folder , And run  mvn clean  and  mvn comple

2.  stay LaptopStore  Add... In the interface  search  Method

3.  Add an interface LaptopStream  There is only one  send  Method

​4.  stay InMemoryLaptopStore  To implement the new  search  Method

​5.  stay LaptopService  Write a  searchLaptop  Method as the implementation of the server .

​6.  Next, we'll implement LaptopClient  Implement client logic , Add one more  SearchLaptop  Method .

​7.  modify  LaptopClient  Medium main Method , First create 10 individual Laptop Then filter and query

​ function server  Run again  client

​ Can be observed ,server The result of is returned many times , This is also  server straming  Characteristics of .

Cross language  server straming call  test

Let's run Java  Of  server  Run again  golang  Of client.

​ And vice versa , function  golang  Of  server  and  Java  Of  client.

​ The results of the operation meet the expectations , And in accordance with  server straming  Characteristics of .

​