Hessian在實(shí)際項(xiàng)目中的使用

shuibo 發(fā)布于2019-08-16 10:41 / 605人閱讀

摘要：項(xiàng)目介紹最近在一個(gè)互聯(lián)網(wǎng)跨境支付項(xiàng)目組，所使用的技術(shù)比較老，代碼是寫于年的，整個(gè)系統(tǒng)采用服務(wù)的架構(gòu)模式，連接件使用進(jìn)行同步調(diào)用，使用進(jìn)行異步調(diào)用。言歸正傳，本文主要是講一下，在該項(xiàng)目中的使用。封裝了的功能，便于調(diào)用。主要包括枚舉類和幫助類。

項(xiàng)目介紹

最近在一個(gè)互聯(lián)網(wǎng)跨境支付項(xiàng)目組，所使用的技術(shù)比較老，代碼是寫于2006年的，整個(gè)系統(tǒng)采用服務(wù)的架構(gòu)模式，連接件使用hessian進(jìn)行同步調(diào)用，使用MQ進(jìn)行異步調(diào)用。
跨境系統(tǒng)的服務(wù)分類上，主要有兩類，一類是線上的，比如交易，網(wǎng)關(guān)，出金，入金等，一類是線下的，比如對(duì)賬，核算等。這個(gè)分類方法，有點(diǎn)像之前金融市場(chǎng)業(yè)務(wù)功能分成前中后臺(tái)子系統(tǒng)。言歸正傳，本文主要是講一下，hessian在該項(xiàng)目中的使用。

劃分模塊

整個(gè)工程分為兩個(gè)WEB模塊：客戶調(diào)用模塊client，服務(wù)處理模塊handler。兩個(gè)基本jar組件:服務(wù)注冊(cè)組件register，hessian工具組件hessianutil.

register : 只有一個(gè)枚舉，用于注冊(cè)服務(wù)，一個(gè)服務(wù)一個(gè)枚舉。是不是瞬間感覺低端了。
hessianutil : 提供了hessian操作的工具類套件。之所以將這兩個(gè)分開，是因?yàn)閔essianutil基本不變，而注冊(cè)類就經(jīng)常變動(dòng)了
client : 服務(wù)調(diào)用者
handler : 服務(wù)提供者

代碼 register:

public enum SerCode {
    SIMPLE_CALL_RETURN_STRING("000000","簡(jiǎn)單調(diào)用"),
    SIMPLE_CALL_RETURN_MAP("000001","返回字典");

    private String code;
    private String desc;

    SerCode(String code, String desc) {
        this.code = code;
        this.desc = desc;
    }

    public String getCode() {
        return code;
    }

    public String getDesc() {
        return desc;
    }
}

client：

注意在hessian的service中傳入了handler的服務(wù)調(diào)用地址，hessian會(huì)創(chuàng)建代理，來實(shí)現(xiàn)RPC調(diào)用

public void makeSimpleCall(){
        Map paraMap = new HashMap();
        String reqMsg = JSonUtil.toJSonString(paraMap);
        HessianInvokeParam param = HessianInvokeHelper.processRequest(reqMsg);
        String sysTraceNo = SysTraceNoService
                .generateSysTraceNo(SystemCodeEnum.WEBGATE.getCode());
        String result = clientHessianService.invoke(
                SerCode.SIMPLE_CALL_RETURN_STRING.getCode(), sysTraceNo,
                SystemCodeEnum.WEBGATE.getCode(),
                SystemCodeEnum.TXNCORE.getCode(),
                SystemCodeEnum.TXNCORE.getVersion(), param.getDataLength(),
                param.getMsgCompress(), param.getDataMsg());
        param.parse(result);
        HessianInvokeHelper.processResponse(param);
        result = param.getDataMsg();
        System.out.println("result:"+result);
    }

handler：

public class SimpleHandler implements EventHandler {
    public String handle(String dataMsg) throws HessianInvokeException {
        return "this is from simple handler";
    }
}



        contextConfigLocation
        
            classpath*:context/**/*.xml
        
    
    
        org.springframework.web.context.ContextLoaderListener
    
    
        remoting
        org.springframework.web.servlet.DispatcherServlet
        
            contextConfigLocation
            
                classpath*:remote/**/*.xml
            
        
    
    
        remoting
        /service/*

通過如上配置，客戶端就可以通過訪問http://localhost:8080/handler...和對(duì)應(yīng)的code來訪問handler了。

hessianutil

封裝了hessian的功能，便于調(diào)用。里面的類就不一一做介紹了。主要包括枚舉類和幫助類。

//所有handler必須實(shí)現(xiàn)的接口
public interface EventHandler {
    String handle(String dataMsg) throws HessianInvokeException;
}

//hessian調(diào)用時(shí)用的接口
public interface HessianInvokeService {
    /**
     * Hessian通訊服務(wù)接口
     *
     * @param serCode
     *            服務(wù)代碼
     * @param sysTraceNo
     *            系統(tǒng)跟蹤號(hào)
     * @param originNo
     *            源系統(tǒng)編號(hào)
     * @param targetNo
     *            目的系統(tǒng)編號(hào)
     * @param versionNo
     *            接口版本號(hào) 格式：1.0.0
     * @param dataLength
     *            消息正文長(zhǎng)度
     * @param msgCompress
     *            消息正文是否壓縮
     * @param dataMsg
     *            消息正文
     * @return
     */
    String invoke(String serCode, String sysTraceNo, String originNo,
                  String targetNo, String versionNo, int dataLength, int msgCompress,
                  String dataMsg);

}

//調(diào)用的主要方法類
public class HessianService implements HessianInvokeService {

    private final Log logger = LogFactory.getLog(HessianService.class);
    private Map eventHandlerMap;
    public void setEventHandlerMap(Map eventHandlerMap) {
        this.eventHandlerMap = eventHandlerMap;
    }
    @SuppressWarnings("unchecked")
    @Override
    public String invoke(String serCode, String sysTraceNo, String originNo,
                         String targetNo, String versionNo, int dataLength, int msgCompress,
                         String dataMsg) {

        logger.info("requet auth system:" + "serCode:" + serCode
                + "sysTraceNo:" + sysTraceNo + "originNo:" + originNo
                + "targetNo:" + targetNo + "versionNo:" + versionNo);

        if(logger.isDebugEnabled()){
            logger.info("dataMsg:" + dataMsg);
        }

        Map result = new HashMap();
        try {

            // 驗(yàn)證請(qǐng)求參數(shù)
            HessianInvokeHelper.validateReqParam(serCode, sysTraceNo, originNo,
                    targetNo, versionNo, dataLength, msgCompress, dataMsg);

            // 驗(yàn)證請(qǐng)求服務(wù)代碼是否正確
            EventHandler handler = eventHandlerMap.get(serCode);
            if (handler == null) {
                throw new HessianInvokeException(
                        ResponseCodeEnum.UNDEFINED_SERVICE.getCode(),
                        ResponseCodeEnum.UNDEFINED_SERVICE.getDesc());
            }

            // 驗(yàn)證目標(biāo)系統(tǒng)編碼
            HessianInvokeHelper.validateTargetNo(targetNo,
                    SystemCodeEnum.TXNCORE.getCode());

            // 驗(yàn)證請(qǐng)求消息正文內(nèi)容長(zhǎng)度
            HessianInvokeHelper.validateDataMsgSize(dataLength, dataMsg);

            String reqMsg = dataMsg;
            // 判斷是否需要解壓請(qǐng)求消息正文內(nèi)容
            if (msgCompress == 1) {
                try {
                    reqMsg = ZipUtil.uncompress(dataMsg);
                } catch (IOException e) {
                    throw new HessianInvokeException(
                            ResponseCodeEnum.UNCOMPRESS_FAILURE.getCode(),
                            ResponseCodeEnum.UNCOMPRESS_FAILURE.getDesc(), e);
                }
            }

            if(logger.isDebugEnabled()){
                logger.info("reqMsg:" + reqMsg);
            }

            Map map = JSonUtil.toObject(reqMsg, Map.class);
            map.put("sysTraceNo", sysTraceNo);
            String rsp = handler.handle(JSonUtil.toJSonString(map));

            return HessianInvokeHelper.buildResponse(serCode, sysTraceNo,
                    SystemCodeEnum.TXNCORE.getCode(), originNo, versionNo, rsp);

        } catch (Exception e) {
            logger.error(e.getMessage(), e);
            logger.error(e.getMessage(), e);
            result.put("responseCode",
                    ResponseCodeEnum.UNDEFINED_ERROR.getCode());
            result.put("responseDesc",
                    ResponseCodeEnum.UNDEFINED_ERROR.getDesc());
        }
        return HessianInvokeHelper.buildResponse(serCode, sysTraceNo,
                SystemCodeEnum.TXNCORE.getCode(), originNo, versionNo,
                JSonUtil.toJSonString(result));
    }
}