在写start-motan时，已经加入自动注册的功能，自然要考虑服务下线的功能，其在github上也写如何优化关机，下面尝试在start中加入该功能。
官方说：待关闭节点需要调用以下代码，建议通过servlet或业务的管理模块进行该调用。
MotanSwitcherUtil.setSwitcherValue(MotanConstants.REGISTRY_HEARTBEAT_SWITCHER, true)
同时官方在注解的例子中说：在使用注册中心时要主动调用下面代码：
MotanSwitcherUtil.setSwitcherValue(MotanConstants.REGISTRY_HEARTBEAT_SWITCHER, true);
注册和反注册调用的两段代码一样....
进去翻了下代码，总嚼着反注册怎么着也要传个false进来
public void onValueChanged(String key, Boolean value) {
if (key != null && value != null) {
if (value) { // 传入值为true时执行
available(null);
} else { // 传入值为false时执行
unavailable(null);
}
}
}
// 最终的操作
@Override
protected void doAvailable(URL url) {
try{
serverLock.lock();
if (url == null) {
availableServices.addAll(getRegisteredServiceUrls());
for (URL u : getRegisteredServiceUrls()) {
removeNode(u, ZkNodeType.AVAILABLE_SERVER);
removeNode(u, ZkNodeType.UNAVAILABLE_SERVER);
createNode(u, ZkNodeType.AVAILABLE_SERVER);
}
} else {
availableServices.add(url);
removeNode(url, ZkNodeType.AVAILABLE_SERVER);
removeNode(url, ZkNodeType.UNAVAILABLE_SERVER);
createNode(url, ZkNodeType.AVAILABLE_SERVER);
}
} finally {
serverLock.unlock();
}
}
@Override
protected void doUnavailable(URL url) {
try{
serverLock.lock();
if (url == null) {
availableServices.removeAll(getRegisteredServiceUrls());
for (URL u : getRegisteredServiceUrls()) {
removeNode(u, ZkNodeType.AVAILABLE_SERVER);
removeNode(u, ZkNodeType.UNAVAILABLE_SERVER);
createNode(u, ZkNodeType.UNAVAILABLE_SERVER);
}
} else {
availableServices.remove(url);
removeNode(url, ZkNodeType.AVAILABLE_SERVER);
removeNode(url, ZkNodeType.UNAVAILABLE_SERVER);
createNode(url, ZkNodeType.UNAVAILABLE_SERVER);
}
} finally {
serverLock.unlock();
}
}
下面测试下不同的传值的实际结果
先加入一个关闭回调，加个断点。
Runtime.getRuntime().addShutdownHook(new Thread() {
public void run() {
try {
MotanSwitcherUtil.setSwitcherValue(MotanConstants.REGISTRY_HEARTBEAT_SWITCHER, false);
} catch (Exception e) {
e.printStackTrace();
}
}
});
通过测试，无论传入的是true，还是false，服务都取消了。
只要执行这个命令kill pid，即使不执行setSwitcherValue方法，暴露的服务也给反注册了。
查看zk命令行：
// 服务刚启动时
[zk: localhost:2181(CONNECTED) 24] ls /motan/default_rpc/com.github.chenxing2.demo.api.IMotanDemo/server
[192.168.1.100:8888]
// 执行 kill pid时，注册的服务直接消失
[zk: localhost:2181(CONNECTED) 25] ls /motan/default_rpc/com.github.chenxing2.demo.api.IMotanDemo/server
[]
为啥会这样？看打印信息是从spring发起的，后续看这块代码时再研究下。
到这的话，优雅关机也能实现了。
kill pid时，处理下线程池等相关的关闭；再获取到本服务内的剩余调用数，等待现有的请求处理完。不知道Motan是否有直接拿到调用数的功能，还没看管理后台。
只是，通过这种方式关闭服务，跟踪代码在doUnavailable方法中实际并未执行任何有效代码，所以还是按照官方说明的方法测试一下「建议通过servlet或业务的管理模块进行该调用」
偷个懒，来个一锤子买卖，在原有代码中加点料，调用服务时，先反注册，然后再返回结果：
public String say(String val) {
MotanSwitcherUtil.setSwitcherValue(MotanConstants.REGISTRY_HEARTBEAT_SWITCHER, false);
return "hello " + val;
}
先上结果：
- 传true，该服务可多次正常调用，毫无问题
// 服务启动时
[zk: localhost:2181(CONNECTED) 27] ls /motan/default_rpc/com.github.chenxing2.demo.api.IMotanDemo/server
[192.168.1.100:8888]
// 调用setSwitcherValue后（传值为true）
[zk: localhost:2181(CONNECTED) 28] ls /motan/default_rpc/com.github.chenxing2.demo.api.IMotanDemo/server
[192.168.1.100:8888]
- 传false，该服务可多次正常调用，毫无问题
// 服务启动时
[zk: localhost:2181(CONNECTED) 29] ls /motan/default_rpc/com.github.chenxing2.demo.api.IMotanDemo/server
[192.168.1.100:8888]
// 调用setSwitcherValue后（传值为false）
[zk: localhost:2181(CONNECTED) 30] ls /motan/default_rpc/com.github.chenxing2.demo.api.IMotanDemo/server
[]
从结果可以看出来，优雅关闭服务，是需要传入false的，这个应该是官方文档写错了。
只是，在服务已消失的情况下，客户端依然可以发起请求，并能正常收到结果。按我理解应该是收到不到结果才对，毕竟只配了一个服务，该服务下线应通知客户端该服务不可用的，实际上还能使用，这是为什么....
然后又启动一个客户端，此时报错了error_message: ClusterSupport No service urls for the refer，对于这个结果没有任何问题，毕竟已无服务了。
难道是只有一个服务它就不通知了？那就启动两个服务，其中一个服务调用后反注册，另一个不做处理，并且打印不同的消息以确定是哪个服务响应。
// 启动两个服务
[zk: localhost:2181(CONNECTED) 32] ls /motan/default_rpc/com.github.chenxing2.demo.api.IMotanDemo/server
[192.168.1.100:8888, 192.168.1.103:8888]
通过调用测试，当其中一个服务反注册后，后面的请求均发送到正常的服务器，也意味着，反注册后的服务是不会再收到客户端请求的。（只有一个服务时无论是否反注册依然会收到请求）
- addShutdownHook，命令行关服务
- 通过jmx对外暴露
- 通过http等方法
综合还是使用前两个来实现，命令行也要能优雅关机，然后也可通过jmx远程优雅关机
网友评论