image.png

如上图所示，SOFABolt 整个配置管理分为五部分：

• 系统变量管理类：ConfigManager，配置多个实例共享的配置。
• 用户变量管理类：ConfigContainer，可以为多个实例配置不同的配置。
• 开关类：Switch，一些开关操作。
• 用户可配置实例类：ConfigurableInstance，包含 ConfigContainer 和 Switch 实例，RpcServer 和 RpcClient 都是其子类。
  Rpc 独有的配置项和管理器：RpcConfig。

参数配置方式通常有两种，一种是系统变量的设置，这是一种全局的配置；另外一种，就是用户通过 api （例如，通过构造器参数）进行配置，这样可以为不同的实例的参数配置不同的值。所以在 Netty 的可配置类中，通常会提供系统变量配置和构造器配置两种参数配置，当然参数本身还有原始的默认值。最终参数配置的优先级是：

用户 api 配置变量（构造器参数变量）> 系统变量 > 原始的默认值

一、系统变量管理类

系统变量的设置通常由两种方式：

• java 进程启动参数添加 -Dxxx = yyy
• System.setProperty(String key, String value)

SOFABolt 通过 Configs 类配置了一系列的配置项的 key 及其默认值；通过 ConfigManager 进行配置项的获取。源码如下：

========================== Configs ==========================
/** TCP_NODELAY option */
public static final String TCP_NODELAY  = "bolt.tcp.nodelay";
public static final String TCP_NODELAY_DEFAULT = "true";

======================= ConfigManager =======================
public static boolean tcp_nodelay() {
    return getBool(Configs.TCP_NODELAY, Configs.TCP_NODELAY_DEFAULT);
}

public static boolean getBool(String key, String defaultValue) {
    return Boolean.parseBoolean(System.getProperty(key, defaultValue));
}

二、用户变量管理类

• ConfigType 定义了是服务端还是客户端的配置：CLIENT_SIDE 和 SERVER_SIDE；
• ConfigItem 定义了配置项，目前只有两个：NETTY_BUFFER_LOW_WATER_MARK 和 NETTY_BUFFER_HIGH_WATER_MARK，Netty write buffer 的高低水位。
• ConfigContainer 定义了设置和获取用户配置项的接口；DefaultConfigContainer 对其进行了默认实现

疑问：关于 ConfigItem 的扩展，官方文档：“You can define new config items based on this if need.” 但是 ConfigItem 是 enum，是无法被继承的，应该怎样去扩展自己的配置呢？个人感觉 ConfigItem 和 Configs 有冗余的嫌疑，https://github.com/alipay/sofa-bolt/issues/101

三、开关类

• Switch 定义开关配置接口；
• GlobalSwitch 定义了全局开关项；
• ProtocolSwitch 定义了与协议相关的开关项，例如 CRC_SWITCH。

======================= GlobalSwitch =======================
// 重连
public static final int CONN_RECONNECT_SWITCH = 0;
// 监控连接
public static final int CONN_MONITOR_SWITCH = 1;
// 服务端启动连接管理器
public static final int SERVER_MANAGE_CONNECTION_SWITCH = 2;
// 服务端同步停止
public static final int SERVER_SYNC_STOP = 3;
/** user settings */
private BitSet userSettings  = new BitSet();

/**
 * Init with system default value
 *   if settings exist by system property then use system property at first;
 *   if no settings exist by system property then use default value in {@link com.alipay.remoting.config.Configs}
 * All these settings can be overwrite by user api settings.
 */
public GlobalSwitch() {
    if (ConfigManager.conn_reconnect_switch()) {
        userSettings.set(CONN_RECONNECT_SWITCH);
    } else {
        userSettings.clear(CONN_RECONNECT_SWITCH);
    }

    if (ConfigManager.conn_monitor_switch()) {
        userSettings.set(CONN_MONITOR_SWITCH);
    } else {
        userSettings.clear(CONN_MONITOR_SWITCH);
    }
}

======================= ProtocolSwitch =======================
// switche index
public static final int CRC_SWITCH_INDEX = 0x000;
// default value
public static final boolean CRC_SWITCH_DEFAULT_VALUE = true;
/** protocol switches */
private BitSet bs = new BitSet();

开关是使用 BitSet 来实现的，BitSet简要原理：
BitSet默认底层数据结构是一个long[]数组，开始时长度为1，即只有long[0]，而一个long有64bit。
当BitSet.set(1)的时候，表示将long[0]的第二位设置为true，即0000 0000 ... 0010（64bit）,则long[0]==2；
当BitSet.get(1)的时候，第二位为1，则表示true；如果是0，则表示false；
当BitSet.set(64)的时候，表示设置第65位，此时long[0]已经不够用了，扩容处long[1]来，进行存储。
存储类似 {index:boolean} 键值对。

四、用户可配置实例类

NettyConfigure：提供了 Netty 配置的接口类；
ConfigurableInstance：提供了可配置实例的接口类；
AbstractConfigurableInstance：ConfigurableInstance 实现类，源码如下：

public class AbstractConfigurableInstance implements ConfigurableInstance {
    private ConfigContainer configContainer = new DefaultConfigContainer();
    private GlobalSwitch    globalSwitch    = new GlobalSwitch();
    private ConfigType      configType;

    protected AbstractConfigurableInstance(ConfigType configType) {
        this.configType = configType;
    }

    // public 方法，用户可以直接获取该实例进行操作
    @Override
    public ConfigContainer conf() {
        return this.configContainer;
    }

     // public 方法，用户可以直接获取该实例进行操作
    @Override
    public GlobalSwitch switches() {
        return this.globalSwitch;
    }

    @Override
    public void initWriteBufferWaterMark(int low, int high) {
        this.configContainer.set(configType, ConfigItem.NETTY_BUFFER_LOW_WATER_MARK, low);
        this.configContainer.set(configType, ConfigItem.NETTY_BUFFER_HIGH_WATER_MARK, high);
    }

    @Override
    public int netty_buffer_low_watermark() {
        // 首先获取用户api配置
        if (null != configContainer
            && configContainer.contains(configType, ConfigItem.NETTY_BUFFER_LOW_WATER_MARK)) {
            return (Integer) configContainer
                .get(configType, ConfigItem.NETTY_BUFFER_LOW_WATER_MARK);
        } else {
            // 然后在从系统变量进行获取
            return ConfigManager.netty_buffer_low_watermark();
        }
    }

    @Override
    public int netty_buffer_high_watermark() {
        if (null != configContainer
            && configContainer.contains(configType, ConfigItem.NETTY_BUFFER_HIGH_WATER_MARK)) {
            return (Integer) configContainer.get(configType,
                ConfigItem.NETTY_BUFFER_HIGH_WATER_MARK);
        } else {
            return ConfigManager.netty_buffer_high_watermark();
        }
    }
}

AbstractConfigurableInstance 有两个极重要的子类 RpcServer 和 RpcClient。

public RpcClient() {
    // 创建对象的时候就指定好了 ConfigType
    super(ConfigType.CLIENT_SIDE);
}

public void init() {
    ...
    // 连接监控开关是否打开
    if (switches().isOn(GlobalSwitch.CONN_MONITOR_SWITCH)) {
        ...
    }
    // 重连开关是否打开
    if (switches().isOn(GlobalSwitch.CONN_RECONNECT_SWITCH)) {
        ...
    }
}

/**
 * enable connection reconnect switch on
 * Notice: This api should be called before RpcClient#init()
 */
public void enableReconnectSwitch() {
    this.switches().turnOn(GlobalSwitch.CONN_RECONNECT_SWITCH);
}

/**
 * disable connection reconnect switch off
 * Notice: This api should be called before RpcClient#init()
 */
public void disableReconnectSwith() {
    this.switches().turnOff(GlobalSwitch.CONN_RECONNECT_SWITCH);
}

/**
 * is reconnect switch on
 * @return
 */
public boolean isReconnectSwitchOn() {
    return this.switches().isOn(GlobalSwitch.CONN_RECONNECT_SWITCH);
}

最后，来看一下使用姿势：

======================= 系统变量 =======================
System.setProperty(Configs.CONN_RECONNECT_SWITCH, "true");
java -Dbolt.conn.reconnect.switch = true -jar xx.jar


======================= 用户变量 =======================
RpcClient client = new RpcClient();
// 1. 通用方式，目前 ConfigItem 只有 netty write buffer 的高低水位
client.conf().set(ConfigType.CLIENT_SIDE, ConfigItem.NETTY_BUFFER_LOW_WATER_MARK, 80 * 1024);
client.conf().set(ConfigType.CLIENT_SIDE, ConfigItem.NETTY_BUFFER_HIGH_WATER_MARK, 100 * 1024);

// 2. 设置高低水位的预留方式
client.initWriteBufferWaterMark(80 * 1024, 100 * 1024);
client.init();

======================= 开关 =======================
// 1. 通用方式
client.switches().turnOn(GlobalSwitch.CONN_RECONNECT_SWITCH);
client.switches().isOn(GlobalSwitch.CONN_RECONNECT_SWITCH);
client.switches().turnOff(GlobalSwitch.CONN_RECONNECT_SWITCH);
client.init();

// 2. 预留设置
client.enableReconnectSwitch();
client.isReconnectSwitchOn();
client.disableReconnectSwith();