Vertx 实现webapi实战项目(三)

 

实现消息分发和handler分配：上传json根据mId字段不同提供不同的解析器，然后将消息分发到不同的handler中。

一：消息分发

1：建立消息解析。新建接口IMessageRecognizer

/***
 * 根据mId获取不同的解码器
 * ***/
public interface IMessageRecognizer {
    MessageFactory recognize(short messageId);
}

2：实现接口。MessageRecognizer

public class MessageRecognizer implements IMessageRecognizer {
    @Override
    public MessageFactory recognize(short messageId) {
        return null;
    }
}

二：handler管理

1：新建接口InterHandler

public interface InterHandler {
    void handler(AbstractUpMessage up, HttpServerResponse resp);
    short getMessageId();
}

 2:新建handler管理类，使用Map将handler储存，使用时通过mId获取相应的handler

public class HandlerManager {
    private final Map<Short,InterHandler> handlers = new ConcurrentHashMap<>();

    private static HandlerManager ourInstance = new HandlerManager();

    public static HandlerManager getInstance() {
        if(ourInstance == null){
            synchronized (HandlerManager.class){
                ourInstance = new HandlerManager();
            }
        }
        return ourInstance;
    }

    public void addHandler(InterHandler handler){
        InterHandler old = handlers.putIfAbsent(handler.getMessageId(),handler);
        if(old != null){
            throw new RuntimeException("handler repeat :"+handler.getMessageId());
        }
    }

    public InterHandler getHandler(short code){
        return handlers.get(code);
    }
}

下节介绍怎么使用前面建立的类。

项目结构如下，