跨平台

Rpc的请求响应通过tcp协议,服务广播使用udp协议,我们只需要实现网络协议即可

PHP示例代码

  1. <?php
  2. /**
  3.  * Created by PhpStorm.
  4.  * User: xcg
  5.  * Date: 2019/6/17
  6.  * Time: 14:30
  7.  */
  8. $data = [
  9.     'command' => 1,//1:请求,2:状态rpc 各个服务的状态
  10.     'request' => [
  11.         'serviceName' => 'UserService',
  12.         'action' => 'register',//行为名称
  13.         'arg' => [
  14.             'args1' => 'args1',
  15.             'args2' => 'args2'
  16.         ]
  17.     ]
  18. ];
  20. //$raw = serialize($data);//注意序列化类型,需要和RPC服务端约定好协议 $serializeType
  22. $raw = json_encode($data, JSON_UNESCAPED_UNICODE | JSON_UNESCAPED_SLASHES);
  24. $fp = stream_socket_client('tcp://127.0.0.1:9600');
  25. fwrite($fp, pack('N', strlen($raw)) . $raw);//pack数据校验
  27. $data = fread($fp, 65533);
  28. //做长度头部校验
  29. $len = unpack('N', $data);
  30. $data = substr($data, '4');
  31. if (strlen($data) != $len[1]) {
  32.     echo 'data error';
  33. } else {
  34.     $data = json_decode($data, true);
  35. //    //这就是服务端返回的结果，
  36.     var_dump($data);//默认将返回一个response对象 通过$serializeType修改
  37. }
  38. fclose($fp);

Go示例代码

  1. package main
  3. import (
  4.     "encoding/binary"
  5.     "net"
  6. )
  8. func main() {
  9.     var tcpAddr *net.TCPAddr
  10.     tcpAddr,_ = net.ResolveTCPAddr("tcp","127.0.0.1:9600")
  11.     conn,_ := net.DialTCP("tcp",nil,tcpAddr)
  12.     defer conn.Close()
  13.     sendEasyswooleMsg(conn)
  14. }
  16. func sendEasyswooleMsg(conn *net.TCPConn) {
  17.     var sendData []byte
  18.     data := `{"command":1,"request":{"serviceName":"UserService","action":"register","arg":{"args1":"args1","args2":"args2"}}}`
  19.     b := []byte(data)
  20.     // 大端字节序(网络字节序)大端就是将高位字节放到内存的低地址端，低位字节放到高地址端。
  21.     // 网络传输中(比如TCP/IP)低地址端(高位字节)放在流的开始，对于2个字节的字符串(AB)，传输顺序为：A(0-7bit)、B(8-15bit)。
  22.     sendData = int32ToBytes8(int32(len(data)))
  23.     // 将数据byte拼装到sendData的后面
  24.     for _, value := range b {
  25.         sendData = append(sendData, value)
  26.     }
  27.     conn.Write(sendData)
  28. }
  30. func int32ToBytes8(n int32) []byte {
  31.     var buf = make([]byte, 4)
  32.     binary.BigEndian.PutUint32(buf, uint32(n))
  33.     return buf
  34. }

Java

  1. import java.io.IOException;
  2. import java.io.InputStream;
  3. import java.io.OutputStream;
  4. import java.net.Socket;
  6. public class Main {
  7.     public static void main(String[] args) throws IOException {
  8.         byte[] msg = "{\"command\":1,\"request\":{\"serviceName\":\"UserService\",\"action\":\"register\",\"arg\":{\"args1\":\"args1\",\"args2\":\"args2\"}}}".getBytes();
  9.         byte[] head = Main.toLH(msg.length);
  10.         byte[] data = Main.mergeByteArr(head, msg);
  12.         //创建Socket对象，连接服务器
  13.         Socket socket=new Socket("127.0.0.1",9600);
  14.         //通过客户端的套接字对象Socket方法，获取字节输出流，将数据写向服务器
  15.         OutputStream out=socket.getOutputStream();
  16.         out.write(data);
  18.         //读取服务器发回的数据，使用socket套接字对象中的字节输入流
  19.         InputStream in=socket.getInputStream();
  20.         byte[] response=new byte[1024];
  21.         int len=in.read(response);
  22.         System.out.println(new String(response,4, len-4));
  23.         socket.close();
  24.     }
  26.     static byte[] toLH(int n) {
  27.         byte[] b = new byte[4];
  28.         b[3] = (byte) (n & 0xff);
  29.         b[2] = (byte) (n >> 8 & 0xff);
  30.         b[1] = (byte) (n >> 16 & 0xff);
  31.         b[0] = (byte) (n >> 24 & 0xff);
  32.         return b;
  33.     }
  36.     static byte[] mergeByteArr(byte[] a, byte[] b) {
  37.         byte[] c= new byte[a.length + b.length];
  38.         System.arraycopy(a, 0, c, 0, a.length);
  39.         System.arraycopy(b, 0, c, a.length, b.length);
  40.         return c;
  41.     }
  42. }

::: warning 其他语言只需要实现tcp协议即可 :::