0
点赞
收藏
分享

微信扫一扫

Biz-SIP业务中台案例实战(2)——App服务调用Sink服务

Biz-SIP业务中台的App服务,类似于DDD架构中应用层的应用服务,App服务会对Sink层的Sink服务进行调用和服务编排。而Sink层的Sink服务,类似于DDD架构中的领域服务,主要是被App服务所驱动,Sink服务主要实现业务逻辑的处理,也可以对接外部第三方服务进行业务逻辑的处理。
本节介绍的App服务调用Sink服务这个实战案例,是通过Biz-SIP的开放API接口,调用基于Java开发的App服务(/bean/sample2),然后再通过App服务调用Sink层的hello-sink服务(用HelloSinkBeanService.java类作为模拟),添加上hello消息后返回。
在这里插入图片描述

具体代码和配置可以查看Biz-SIP源代码中的Sample相关测试案例(https://gitee.com/szhengye/biz-sip)

一、Sink层Sink服务的开发和配置

首先,我们需要编写一个Sink服务类(HelloSinkBeanService.java):

@Slf4j
@Service
public class HelloSinkBeanService extends AbstractSinkService implements SinkBeanInterface {
    @Override
    public JSONObject process(JSONObject inMessage) throws BizException {
        log.debug("收到报文:\n{}", BizUtils.buildJsonLog(inMessage));
        inMessage.set("message","hello!");
        return inMessage;
    }
}

HelloSinkBeanService类继承了SinkBeanInterface接口,实现了process()方法,这个方法的输入输出参数,都是平台统一的JSONObject对象。
可以看到在process()方法中,对输入报文是增加了一个message域,值为“hello”。
然后,在在Biz-SIP配置目录的sink.yml中,配置对应的Sink服务:

- id: hello-sink
  type: rest
  processor: sink-bean
  url: http://bizsip-sample-sink/hello-sink
  class-name: com.bizmda.bizsip.sample.sink.service.HelloSinkBeanService

可以看到hello-sink这个Sink服务,是关联了上面编写的HelloSinkBeanService类。
最后,还需要在SampleSinkApplication的应用配置文件application-local.yml中,在bizsip.sink-id配置项中,增加hello-sink以便启动Sink服务:

bizsip:
  config-path: /var/bizsip/config
  sink-id: hello-sink,echo-sink

二、App层App服务的开发和配置

首先,我们需要编写一个App服务类(Sample2AppService.java):

@Slf4j
@Service
public class Sample2AppService implements AppBeanInterface {
    private BizMessageInterface sinkInterface = AppClientFactory
            .getSinkClient(BizMessageInterface.class,"hello-sink");

    @Override
    public JSONObject process(JSONObject message) throws BizException {
        log.debug("收到请求数据:\n{}", BizUtils.buildJsonLog(message));
        BizMessage<JSONObject> bizMessage = sinkInterface.call(message);
        return bizMessage.getData();
    }
}

Sample2AppService类继承了AppBeanInterface接口,实现了process()方法,这个方法的输入输出参数,都是平台统一的JSONObject对象。
在process()方法中,通过sinkInterface接口,调用了hello-sink这个Sink服务。
然后,在app.yml中,配置对应的App服务:

- app-service-id: /bean/sample2
  type: app-bean-service
  class-name: com.bizmda.bizsip.sample.app.service.Sample2AppService

三、启动应用进行测试

启动SampleSinkApplication和SampleAppApplication应用,通过开放平台接口发起请求,就可以接收到响应,返回的报文内容增加了message域:

$ curl -H "Content-Type:application/json" -H "Biz-Service-Id:/bean/sample2" -X POST --data '{"accountNo":"003"}' http://localhost:8888/api|jq

{
  "code": 0,
  "message": "success",
  "extMessage": null,
  "appServiceId": "/bean/sample2",
  "traceId": "3cf20f08fe7f4d0d8c320ea14b61c98e",
  "parentTraceId": null,
  "timestamp": 1646564189216,
  "data": {
    "message": "hello!",
    "accountNo": "003"
  }
}

Biz-SIP官方网站:http://bizsip.bizmda.com
Gitee:https://gitee.com/szhengye/biz-sip

举报

相关推荐

0 条评论