2.7.18

shikeying

2024-01-11 3b67e947e36133e2a40eb2737b15ea375e157ea0

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
package com.walker.tcp.littleD;
 
import com.walker.infrastructure.utils.StringUtils;
import com.walker.tcp.AuthenticateException;
import com.walker.tcp.ProtocolException;
import com.walker.tcp.Request;
import com.walker.tcp.Response;
import com.walker.tcp.data.AbstractStringResponse;
import com.walker.tcp.protocol.StringProtocolResolver;
 
/**
 * 安全帽（小D智能定位终端）协议解析器实现。
 * @author 时克英
 * @date 2018-11-23
 *
 */
public class LittleDProtocolResolver extends StringProtocolResolver {
 
    public LittleDProtocolResolver(){
        this.setDelimiter(Constants.DATA_END_FLAG);
        this.setProtocolFeature(Constants.BODY_ID);
        this.setName("小D智能终端协议解析器");
        this.setOrder(1);
    }
    
    @Override
    protected String onResolve(String source, int size) throws ProtocolException {
        if(size < 6){
            throw new ProtocolException(ERR_PROTOCOL_SIZE);
        }
        
        if(!source.startsWith(this.getProtocolFeature().toString())){
            throw new ProtocolException(ERR_PROTOCOL_FEATURE);
        }
        return source.substring(2, 6);
    }
 
    @Override
    protected Response<?> doCreateOneResponse() {
        return new TestResponse();
    }
 
    private  class TestResponse extends AbstractStringResponse {
 
        /**
         * 
         */
        private static final long serialVersionUID = -7728231375789281173L;
        /**
         * 
         */
        private static final String TEST_PACKAGE = "0#";
        
        @Override
        public String toData() {
            /** 注意，这里心跳数据结尾可能会有多种分隔符，因为目前支持多种数据协议。
             * 例如：0#,\r\n等，这样发送出去是会出错的，因此必须根据连接协议拼接相应的分隔符！
             *  */
            return TEST_PACKAGE;
        }
 
        @Override
        public String getProtocolNum() {
            return null;
        }
 
        @Override
        public String getDelimiter() {
            return null;
        }
    }
 
    @Override
    public String getAuthenticateInfo(Request<?> request) throws AuthenticateException {
        if(request instanceof LoginRequest){
            String clientId = request.getName();
            if(StringUtils.isEmpty(clientId)){
                throw new AuthenticateException("请求信息中不存在设备ID号，无法认证");
            }
            
            if(!isPermitNotRegisterConnect() && !this.isRegistered(clientId)){
                throw new AuthenticateException("设备未在列表中注册，无法认证。clientId = " + clientId);
            }
            return clientId;
            
        } else {
            throw new AuthenticateException("connection通道认证失败，请求不是登录");
        }
    }
    
}