MongoDB Stream是怎样实现美满数据增量迁徙的？

界说Channel频道的转换表：

public static enum Channel {  
    Food("美食"),  
    Emotion("情绪"), 
    Pet("宠物"),  
    House("家居"),  
    Marriage("征婚"),  
    Education("教诲"),  
    Travel("旅游") ; 
 
    private final String oldName;  
    public String getOldName() {  
        return oldName;  
    }  
    private Channel(String oldName) {  
        this.oldName = oldName;  
    }  
    /**  
     * 转换为新的名称  
     *  
     * @param oldName  
     * @return  
     */  
    public static String toNewName(String oldName) {  
        for (Channel channel : values()) {  
            if (channel.oldName.equalsIgnoreCase(oldName)) {  
                return channel.name();  
            }  
        }  
        return "";  
    }  
    /**  
     * 返回一个随机频道  
     *  
     * @return  
     */  
    public static Channel random() {  
        Channel[] channels = values();  
        int idx = (int) (Math.random() * channels.length);  
        return channels[idx];  
    }  
} 

为topic表预写入1w笔记录：

开启监听使命，将topic上的全部改观写入到增量表：

代码中通过watch呼吁得到一个MongoCursor工具，用于遍历全部的改观。

FullDocument.UPDATE_LOOKUP选项启用后，在update改观变乱中将携带完备的文档数据(FullDocument)。

watch()呼吁提交后，mongos会与分片上的mongod(主节点)成立订阅通道，这也许必要耗费一点时刻。

为了模仿线上营业的真实环境，启用几个线程对topic表举办一连写操纵：

ChangeTask实现逻辑如下：

（编辑：湖南网）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!