龙华做网站哪家好,学ui去哪个机构比较好,网站备案网站名称,腾讯云服务器购买后怎么使用版本
spring-cloud-starter-dubbo-2.2.4.RELEASE
问题描述
生产者重启后#xff0c;正常注册到注册中心#xff0c;但是消费者调用接口是no provider#xff0c;偶现#xff0c;频繁出现
解决办法
先说原因和解决办法#xff0c;有兴趣可以看下问题的排查过程。
原因…版本
spring-cloud-starter-dubbo-2.2.4.RELEASE
问题描述
生产者重启后正常注册到注册中心但是消费者调用接口是no provider偶现频繁出现
解决办法
先说原因和解决办法有兴趣可以看下问题的排查过程。
原因
dubbo在建立连接后会起一个任务检查连接的是否有效如果已经时间会重新连接。问题出在时间间隔上面。 从元数据读取heartbeat这个key如果没有那么使用默认的60秒我们项目没有设置这个心跳时间那么默认就是60秒。 而重试时间间隔默认为这个时间的三倍也就是3分钟。此时也就问题就已经很明显重连时间间隔太长。生产者重新启动后还没有重新建立连接。此时调用DubboMetadataService.getExportedURLs的方法获取服务原数据还使用已经关闭的那个时效的连接会失败报错
Caused by: org.apache.dubbo.remoting.RemotingException: message can not send, because channel is closed .表现
查看日志发现生产者有下线后消费者会去重连但是有时能重连成功有时重连失败 连接失败 连接成功 经过观察每次生产者启动后都是因为重连失败会导致No Provider。
解决办法
dubbo:protocol:name: dubboheartbeat: 1000这里设置1秒那么3秒会进行一次检查已经足够了在生产者启动暴露服务期间与生产者建立连接。 此时再查看元数据已经有了timeout 设置心跳时间后重启生产者和消费者。问题解决以后重启生产者不会再出现 No Provider的问题
问题排查过程
服务刷新角度排查
首先排查是不是因为是不是因为生产者注册到nacos服务变动没有触发消费端的服务刷新。经过排查正常触发了DubboMetaDataService的服务刷新也正常触发了Dubbo Invoker的刷新。这俩监听器分别是com.alibaba.cloud.dubbo.registry.DubboCloudRegistry#subscribeDubboMetadataServiceURLs(org.apache.dubbo.common.URL, org.apache.dubbo.registry.NotifyListener)
com.alibaba.cloud.dubbo.registry.DubboCloudRegistry#subscribeURLs(org.apache.dubbo.common.URL, org.apache.dubbo.registry.NotifyListener) 执行顺序上没问题因为spring cloud alibaba只注册DubboMetadataService到注册中心消费者需要引用的生产者接口是用过DubboMetadataService.getExportedURLs做rpc调用生产者获取到的。因此需要先刷新DubboMetadataService对应的invoker再刷新消费者引用的的那些 invoker 但是在触发获取getExportedURLs时发现有些情况获取到的结果是空 private ListURL getTemplateExportedURLs(URL subscribedURL,ListServiceInstance serviceInstances) {DubboMetadataService dubboMetadataService getProxy(serviceInstances);ListURL templateExportedURLs emptyList();if (dubboMetadataService ! null) {templateExportedURLs getExportedURLs(dubboMetadataService, subscribedURL);}else {if (logger.isWarnEnabled()) {logger.warn(The metadata of Dubbo service[key : {}] still cant be found, it could effect the further Dubbo service invocation,subscribedURL.getServiceKey());}}return templateExportedURLs;}生产者服务暴露时机排查
消费者正常通过DubboMetadataService.getExportedURL获取服务返回空。首先怀疑生产者逻辑有问题。 经过排查生产者保证了 首先暴露所有的服务后才注册元数据到注册中心 消费者rpc调用。在生产者DubboMetadataService的实现IntrospectiveDubboMetadataService上断电观察发现这里返回的数据是没问题的
Overridepublic String getExportedURLs(String serviceInterface, String group, String version) {ListURL urls getRepository().getExportedURLs(serviceInterface, group,version);return jsonUtils.toJSON(urls);}
消费者调用生产者排查
不得不说这个问题真的难查在不断点的情况下很容易出现但是加上断点导致程序执行速度变慢很难复现。、 最终查看日志发现在生产者重启后的报错
Caused by: org.apache.dubbo.remoting.RemotingException: message can not send, because channel is closed .但是我生产已经启动了dubbo端口也起来了。为什么还报这个错。
Caused by: org.apache.dubbo.remoting.RemotingException: message can not send, because channel is closed .看到这里下意识猜测是不是因为生产者下线并上线后消费者用的还是旧链接而没有重新建立连接。 查看日志发现生产者有下线后消费者会去重连但是有时能重连成功有时重连失败 连接失败 连接成功 经过观察每次生产者启动后都是因为重连失败会导致No Provider。 那么问题就找到了。至于怎么解决看下这个ReconnectTimerTask的逻辑是怎么样的
public class ReconnectTimerTask extends AbstractTimerTask {private static final Logger logger LoggerFactory.getLogger(ReconnectTimerTask.class);private final int idleTimeout;public ReconnectTimerTask(ChannelProvider channelProvider, Long heartbeatTimeoutTick, int idleTimeout) {super(channelProvider, heartbeatTimeoutTick);this.idleTimeout idleTimeout;}Overrideprotected void doTask(Channel channel) {try {Long lastRead lastRead(channel);Long now now();// Rely on reconnect timer to reconnect when AbstractClient.doConnect fails to init the connectionif (!channel.isConnected()) {try {logger.info(Initial connection to channel);((Client) channel).reconnect();} catch (Exception e) {logger.error(Fail to connect to channel, e);}// check pong at client} else if (lastRead ! null now - lastRead idleTimeout) {logger.warn(Reconnect to channel channel , because heartbeat read idle time out: idleTimeout ms);try {((Client) channel).reconnect();} catch (Exception e) {logger.error(channel reconnect failed during idle time., e);}}} catch (Throwable t) {logger.warn(Exception when reconnect to remote channel channel.getRemoteAddress(), t);}}
}
发现这个任务会检查连接是否有效如果连接无效那么会重新连接。 这个任务的执行时机是通过dubbo的时间轮调用的。 关于时间轮的这里不展开了。看下这个定时任务的执行间隔是多少 在HeaderExchangeClient中建立连接后。会开启一个重试连接的任务。 private void startReconnectTask(URL url) {if (shouldReconnect(url)) {AbstractTimerTask.ChannelProvider cp () - Collections.singletonList(HeaderExchangeClient.this);int idleTimeout getIdleTimeout(url);long heartbeatTimeoutTick calculateLeastDuration(idleTimeout);this.reconnectTimerTask new ReconnectTimerTask(cp, heartbeatTimeoutTick, idleTimeout);IDLE_CHECK_TIMER.newTimeout(reconnectTimerTask, heartbeatTimeoutTick, TimeUnit.MILLISECONDS);}}其中heartbeatTimeoutTick标识了重连检查的时间间隔
String HEARTBEAT_KEY heartbeat;
int DEFAULT_HEARTBEAT 60 * 1000;
public static int getIdleTimeout(URL url) {int heartBeat getHeartbeat(url);// idleTimeout should be at least more than twice heartBeat because possible retries of client.int idleTimeout url.getParameter(Constants.HEARTBEAT_TIMEOUT_KEY, heartBeat * 3);if (idleTimeout heartBeat * 2) {throw new IllegalStateException(idleTimeout heartbeatInterval * 2);}return idleTimeout;}public static int getHeartbeat(URL url) {return url.getParameter(Constants.HEARTBEAT_KEY, Constants.DEFAULT_HEARTBEAT);}可以看到超时时间是从dubbo元数据读取heartbeat这个key如果没有那么使用默认的60秒我们项目没有设置这个心跳时间那么默认就是60秒。 而重试时间间隔默认为这个时间的三倍3分钟。此时也就问题就已经很明显重连时间间隔太长。生产者重新启动后还没有重新建立连接。此时调用DubboMetadataService.getExportedURLs的方法获取服务原数据会失败报错
Caused by: org.apache.dubbo.remoting.RemotingException: message can not send, because channel is closed .等到了时间重连成功后又因为此时的nacos中的数据不再变化不再触发服务变动导致一直都是No Provider的状态。 那么解决这个办法也很简单那就是设置心跳时间小一些。
