案例-Go服务器开发

以下是一个简单的使用 grpc-gateway 支持流双向流的案例：

假设有一个 gRPC 服务，定义了如下的方法：

service Chat {
  // 客户端向服务器发送消息
  rpc SendMessage(stream Message) returns (stream Empty);

  // 客户端请求获取所有历史消息
  rpc GetAllMessages(Empty) returns (stream Message);
}

// 消息结构体
message Message {
  string user_name = 1;
  string content = 2;
}

// 空结构体
message Empty {}

在使用 grpc-gateway 将其转换成 RESTful API 后，可以使用 HTTP/2 协议建立连接并进行数据传输。

客户端可以使用 JavaScript 或其他语言实现。以下是一个简单的 JavaScript 实现示例：

const { ChatClient } = require('./chat_grpc_web_pb.js');
const { Message, Empty } = require('./chat_pb.js');

var client = new ChatClient('http://localhost:8080', null, null);

function sendMessage() {
  var stream = client.sendMessage();
  
  stream.on('data', function(response) {
    console.log(response.toObject());
  });

  var message1 = new Message();
  message1.setUserName("Alice");
  message1.setContent("Hello World!");

  var message2 = new Message();
  message2.setUserName("Bob");
  message2.setContent("Hi Alice!");

  stream.write(message1);
  
  setTimeout(function() {
    stream.write(message2);
    stream.end();
   },5000);
}

function getAllMessages() {
   var request = new Empty();

   var stream = client.getAllMessages(request);

   stream.on('data', function(response) {
     console.log(response.toObject());
   });

   stream.on('end', function() {
     console.log("Finished");
   });
}

sendMessage();
getAllMessages();

在上述示例中，sendMessage() 方法向服务器发送两条消息，并设置了 5 秒后关闭流。getAllMessages() 方法请求获取所有历史消息，并在接收到所有消息后输出 “Finished”。

这是一个简单的使用 grpc-gateway 支持流双向流的案例，你可以根据自己的需求进行更加复杂的实现。