hyperf/go/springboot通過jsonrpc通信-有解無憂

一、背景

隨著用戶的增長和業務的增多，單節點服務已經滿足不了需求，用hyperf對主業務進行了重構，

hyperf是一個后現代的php框架，基于php+swoole，支持協程，解決了php讓人詬病的性能問題和多執行緒支持不夠的問題，官方也提供了各種組件，比如配置中心、定時任務、訊息佇列和微服務，對于日常業務需求，基本能做到開箱即用，有點php界的springcloud的意思，

用過hyperf的微服務后，眼前一亮，hyperf采用了新起一個Server，在Service層接收和回傳資料，本地也可以復用這些Service，通信協議用的是jsonrpc2.0，既支持http協議，又支持tcp協議，用http協議除錯時可以直接用postman，方便直觀，服務安全方面，線上服務器只要對微服務埠進行隔離，不對外部服務器開放即可，

之前在與JAVA組進行業務對接用的是restful，現在hyperf又提供了一種新的思路，重新設計架構，

二、架構

系統架構圖
如上圖所示，在后臺服務與服務之間，采用jsonrpc進行互動，根據業務分庫分表，不同業務之前不直接訪問資料庫，上層獨立出子專案，每個子專案包含一個前端和一個業務中臺，業務中臺采用php，不直接訪問資料庫，從根據不同的業務從不同的業務后臺取資料，進行資料組裝，

三、代碼

下面以加法運算為例，展示一下springboot、hyperf、go之間相互請求，

1、PHP

服務端代碼（以http協議為例）

<?php
declare(strict_types=1);

namespace App\JsonRpc;

use Hyperf\RpcServer\Annotation\RpcService;

#[RpcService(name: "PhpHttpService", protocol: "jsonrpc-http", server: "jsonrpc-http")]
class PhpHttpService implements PhpServiceInterface
{
    public function add(array $args): array
    {
        $result = [];
        $result["c"] = $args["a"] + $args["b"];
        return $result;
    }
}

客戶端代碼（以請求java為例）

介面

<?php
declare(strict_types=1);

namespace App\JsonRpc;

use Hyperf\RpcClient\AbstractServiceClient;

class JavaHttpServiceConsumer extends AbstractServiceClient implements JavaServiceInterface
{
    protected string $serviceName = 'JavaHttpService';

    protected string $protocol = 'jsonrpc-http';

    public function add(array $args): array
    {
        return $this->__request(__FUNCTION__, compact('args'));
    }
}

呼叫

<?php

namespace App\Task;

use Hyperf\Contract\StdoutLoggerInterface;
use Hyperf\Crontab\Annotation\Crontab;
use Hyperf\Di\Annotation\Inject;
use App\JsonRpc\JavaHttpServiceConsumer;

#[Crontab(name: "ClientTask", rule: "*/5 * * * * *", callback: "execute", memo: "客戶端定時任務")]
class ClientTask
{
    #[Inject]
    private StdoutLoggerInterface $logger;

    #[Inject]
    private JavaHttpServiceConsumer $javaHttpServiceConsumer;

    public function execute()
    {
        $seed = time();
        srand($seed);
        
        try {
            $a = rand(0, 100);
            $b = rand(0, 100);
            $result = $this->javaHttpServiceConsumer->add(["a" => $a, "b" => $b]);
            $this->logger->info(sprintf("[http] PHP asked:\"%d+%d=?\"; Java answered:\"%d\"", $a, $b, $result["c"]));
        } catch (Exception $e) {
            $this->logger->info($e->getMessage());
        }
    }
}

2、Java

服務端代碼（以http協議為例）

package io.moonquakes.javahttp.service;

import io.moonquakes.javahttp.dto.ArgsDto;
import io.moonquakes.javahttp.dto.ResultDto;

public class JavaHttpService implements IJavaHttpService {
    @Override
    public ResultDto add(ArgsDto args) {
        ResultDto resultDto = new ResultDto();
        resultDto.setC(args.getA() + args.getB());
        return resultDto;
    }
}

客戶端代碼（以請求go為例）

介面

package io.moonquakes.javahttp.client;

import com.sunquakes.jsonrpc4j.JsonRpcClient;
import com.sunquakes.jsonrpc4j.JsonRpcProtocol;
import io.moonquakes.javahttp.dto.ArgsDto;
import io.moonquakes.javahttp.dto.ResultDto;

@JsonRpcClient(value = "https://www.cnblogs.com/microiot/p/GoHttp", protocol = JsonRpcProtocol.http, url = "localhost:3602")
public interface IGoHttpClient {
    ResultDto Add(ArgsDto args);
}

呼叫

package io.moonquakes.javahttp.task;

import io.moonquakes.javahttp.client.IGoHttpClient;
import io.moonquakes.javahttp.dto.ArgsDto;
import io.moonquakes.javahttp.dto.ResultDto;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.EnableScheduling;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;

@Slf4j
@EnableScheduling
@Component
public class ClientTask {

    @Autowired(required = false)
    private IGoHttpClient goHttpClient;

    @Scheduled(fixedDelay = 10000)
    public void run() {
        ArgsDto args = new ArgsDto();
        try {
            int a = (int) (Math.random() * 100);
            int b = (int) (Math.random() * 100);
            args.setA(a);
            args.setB(b);
            ResultDto resultDto = goHttpClient.Add(args);
            log.info(String.format("[http] Java asked:\"%d+%d=?\"; Go answered:\"%d\"", a, b, resultDto.getC()));
        } catch (Exception e) {
            log.error(e.getMessage(), e);
        }
    }
}

3、Go

服務端代碼（以http協議為例）

go func() {
	s, _ := jsonrpc4go.NewServer("http", "127.0.0.1", "3602")
	s.Register(new(GoHttp))
	s.Start()
}()

客戶端代碼（以請求php為例）

phpHttpClient, _ := jsonrpc4go.NewClient("http", "127.0.0.1", "9504")
a = rand.Intn(100)
b = rand.Intn(100)
_ = phpHttpClient.Call("php_http/add", Params{Args{a, b}}, result, false)