fix协议介绍4-心跳
  TEZNKK3IfmPf 2023年11月15日 17 0


Heartbeat [type '0']



The Heartbeat monitors the status of the communication link and identifies when the last of a string of messages was not received.




fix协议介绍4-心跳



心跳消息实现:

 cs.mina.codec.msg;

 java.util.HashSet;
 java.util.List;
 java.util.Set;

 cs.mina.exception.InValidDataException;


 
 
 
    BaseMsg {
    request;
   Tag testReqID Tag(,,);
   Set tagIdsSet   HashSet();
  
   HeartbeatMsg(){
    .getHeadEntity().getMsgType().setTagValue();
    tagIdsSet.add();
      .bodyEntity.getBodyTagList().add(testReqID);
  }
  
  
    validate() {
    .headEntity.validate();
    ListTag bodyTagList.bodyEntity.getBodyTagList();
    ( i;ibodyTagList.size();i){
      bodyTagList.get(i).validate();
    }
    .tailerEntity.validate();
    (request){
      testReqID.setMust();
      testReqID.validate();
    }
    
  }

  
    decodeBody() {
    Set already HashSet();
    [] bodyItems.body.split(BaseMsg.SOH);
    (bodyItems.lengthbodyItems[].equals()){
      ;
    }
    ( i;ibodyItems.length;i){
      []tagItemsbodyItems[i].split();
      (tagItems.length){
          InValidDataException();
      }
       tagIdtagItems[];
      (already.contains(tagId)){
          InValidDataException();
      }
      already.add(tagId);
      (.tagIdsSet.contains(tagId)){
          ListTag tagList.bodyEntity.getBodyTagList();
          ( j;jtagList.size();j){
            Tag tagtagList.get(j);
            (tag.getTagId().equals(tagId)){
              tag.setTagValue(tagItems[]);
              ;
            }
          }
      }{
          InValidDataException(tagId);
      }
    }
    
  }

    isRequest() {
     request;
  }

    setRequest( request) {
    .request  request;
  }

   Tag getTestReqID() {
     testReqID;
  }

    setTestReqID(Tag testReqID) {
    .testReqID  testReqID;
  }

   Set getTagIdsSet() {
     tagIdsSet;
  }

    setTagIdsSet(Set tagIdsSet) {
    .tagIdsSet  tagIdsSet;
  }

}


处理逻辑:略




【版权声明】本文内容来自摩杜云社区用户原创、第三方投稿、转载,内容版权归原作者所有。本网站的目的在于传递更多信息,不拥有版权,亦不承担相应法律责任。如果您发现本社区中有涉嫌抄袭的内容,欢迎发送邮件进行举报,并提供相关证据,一经查实,本社区将立刻删除涉嫌侵权内容,举报邮箱: cloudbbs@moduyun.com

  1. 分享:
最后一次编辑于 2023年11月15日 0

暂无评论

推荐阅读
  TEZNKK3IfmPf   24天前   51   0   0 java
TEZNKK3IfmPf