服务定义与开发

注册 MPC API 服务

注册 MPC API 服务需要如下参数：

• registryUrl： 该值为注册中心的地址，共享式金融科技注册中心地址为 mpcpub.mpaas.cn-hangzhou.aliyuncs.com。

• appName：该值为业务方的应用名，与 API 分组名相同。

• workspaceId：应用所处环境的 workspaceId。

• projectName：应用所属租户的 projectName，与 API 分组里的 Project Name 相同。

• privateKeyPath：存放 RSA 私钥的 ClassPath，与 mpaaschannel 建立连接时用于校验合法性。 建议放置在 /META-INF/config/rsa-mpc-pri-key-{env}.der 中，{env} 为不同的环境，如 dev、sit、prod 等。

配置公钥

前往对应环境的控制台，从左侧导航栏点击 代码管理 > 接口密钥 > 配置，配置私钥对应的 RSA 公钥。

生成 RSA 公私钥的方法如下，其中公钥在控制台上配置，私钥文件在后端应用的 ${privateKeyPath} 中配置：

* the way to generate key pair: 
* ### Generate a 2048-bit RSA private key 
* 
* $ openssl genrsa -out private_key.pem 2048 
* 
* ### Convert private Key to PKCS#8 format (so Java can read it) 
* 
* $ openssl pkcs8 -topk8 -inform PEM -outform DER -in private_key.pem -out private_key.der -nocrypt 
* 
* ### Output public key portion in DER format (so Java can read it) 
* 
* $ openssl rsa -in private_key.pem -pubout -outform DER -out public_key.der 
* 
* ### change to base64:
* 
* ## 生成的私钥，后端应用中配置
* $ openssl base64 -in private_key.der -out private_key_base64.der
* 
* ## 生成的公钥，在控制台 接口密钥 中配置
* $ openssl base64 -in public_key.der -out public_key_base64.der
* 
* ### remember to clear the whitespace chars and line breaks before submit!!!

spring 方式

1. 在对应 bundle 的 spring 配置文件中，声明定义好的服务的 spring bean。

    <bean id="mockRpc" class="com.alipay.gateway.spi.mpc.test.MockRpcImpl"/>

2. 在对应 bundle 的 spring 配置文件中，声明暴露服务的 starter bean。

   接口 MpcServiceStarter 会将所有带有 OperationType 的 bean 通过 mpaaschannel 协议注册到指定的注册中心。

   <bean id="mpcServiceStarter" class="com.alipay.gateway.spi.mpc.MpcServiceStarter">
    <property name="registryUrl" value="${registy_url}"/>
    <property name="appName" value="${app_name}"/>
    <property name="workspaceId" value="${workspace_id}"/>
    <property name="projectName" value="${project_name}"/>
    <property name="privateKeyPath" value="${privatekey_path}"/>
   </bean>

spring-boot 方式

spring-boot 和 spring 本质上一样，只是注册的方式改为注解的方式，不用配置 xml 文件。

1. 通过注解的方式，将定义的服务注册成 bean：

   @Service
   public class MockRpcImpl implements MockRpc{
   }

2. 以注解的方式，定义暴露服务的 starter：

   @Configuration
   public class MpaaschannelDemo {
    @Bean(name="mpcServiceStarter")
    public MpcServiceStarter mpcServiceStarter(){
        MpcServiceStarter mpcServiceStarter = new MpcServiceStarter();
        mpcServiceStarter.setWorkspaceId("${workspace_id}");
        mpcServiceStarter.setAppName("${app_name}");
        mpcServiceStarter.setRegistryUrl("${registy_url}");
        mpcServiceStarter.setProjectName("${project_name}");
        mpcServiceStarter.setPrivateKeyPath("${privatekey_path}");
        return mpcServiceStarter;
    }
   }

配置 MPC 日志

为了便于排查问题，可酌情配置 MPC 相关日志，下面以 log4j 配置为例：

<!-- [MPC Logger] tenant link，记录建联，settings 信息 -->
    <appender name="MPC-TENANT-LINK-APPENDER" class="org.apache.log4j.DailyRollingFileAppender">
        <param name="file" value="${log_root}/mpaaschannel/tenant-link.log"/>
        <param name="append" value="true"/>
        <param name="encoding" value="${file.encoding}"/>
        <layout class="org.apache.log4j.PatternLayout">
            <param name="ConversionPattern" value="%d [%X{remoteAddr}][%X{uniqueId}] %-5p %c{2} - %m%n"/>
        </layout>
    </appender>

    <!-- [MPC Logger] 记录一个流相关的数据 (包括一对tenant stream <-> component stream) -->
    <appender name="MPC-STREAM-DATA-APPENDER" class="org.apache.log4j.DailyRollingFileAppender">
        <param name="file" value="${log_root}/mpaaschannel/stream-data.log"/>
        <param name="append" value="true"/>
        <param name="encoding" value="${file.encoding}"/>
        <layout class="org.apache.log4j.PatternLayout">
            <param name="ConversionPattern" value="%d [%X{remoteAddr}][%X{uniqueId}] %-5p %c{2} - %m%n"/>
        </layout>
    </appender>


<!-- [MPC Logger] tenant 日志 -->
    <logger name="TENANT-LINK-DIGEST" additivity="false">
        <level value="INFO" />
        <appender-ref ref="MPC-TENANT-LINK-APPENDER" />
        <appender-ref ref="ERROR-APPENDER" />
    </logger>

    <!-- [MPC Logger] component 日志 -->
    <logger name="STREAM-DATA-DIGEST" additivity="false">
        <level value="INFO" />
        <appender-ref ref="MPC-STREAM-DATA-APPENDER" />
        <appender-ref ref="ERROR-APPENDER" />
    </logger>