微服务超时与重试

相关文章推荐

大方的椅子 · 足协暂停与阿根廷足协相关合作之前，双方曾有过 ...· 3 月前 ·

从未表白的毛衣 · 朱霖峰入选中国乒乓球青年队 ...· 5 月前 ·

爱看球的毛豆 · #琅寰书院-万花雨 ...· 1 年前 ·

重情义的香菇 · 神奇宝贝里的特殊球，小智自己就用过三个，你认 ...· 1 年前 ·

年轻有为的针织衫 · 食戟之灵（番外篇）_百度百科· 1 年前 ·

腾讯云

备案控制台

开发者社区

TVP

文章/答案/技术大牛

写文章

专栏首页 DDD 微服务超时与重试

4 0

分享

Socket socket = new Socket();
socket.connect(new InetSocketAddress("10.0.0.1",8080),20000);

Exception in thread "main" java.net.SocketTimeoutException: connect timed out
    at java.net.DualStackPlainSocketImpl.waitForConnect(Native Method)
    at java.net.DualStackPlainSocketImpl.socketConnect(DualStackPlainSocketImpl.java:85)
    at java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:350)
    at java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:206)
    at java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:188)
    at java.net.PlainSocketImpl.connect(PlainSocketImpl.java:172)
    at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392)
    at java.net.Socket.connect(Socket.java:589)

ServerSocket serverSocket = new ServerSocket(8080);
while ( true) {
    Socket socket = serverSocket.accept();
    new Thread(new P(socket)).start();
}

Socket socket = new Socket();
socket.connect(new InetSocketAddress("localhost",8080),20000);
socket.setSoTimeout(3000);

java.net.SocketTimeoutException: Read timed out
    at java.net.SocketInputStream.socketRead0(Native Method)
    at java.net.SocketInputStream.socketRead(SocketInputStream.java:116)
    at java.net.SocketInputStream.read(SocketInputStream.java:170)
    at java.net.SocketInputStream.read(SocketInputStream.java:141)
    at java.net.SocketInputStream.read(SocketInputStream.java:223)

Selector selector = Selector.open();
InetSocketAddress isa = new InetSocketAddress(host, port);
// 调用open静态方法创建连接到指定主机的SocketChannel
SocketChannel sc = SocketChannel.open(isa);

public void connect(){
        selector = Selector.open();
        InetSocketAddress isa = new InetSocketAddress(host, port);
        //10秒连接超时
        new Timer().schedule(tt, 10000);
        // 调用open静态方法创建连接到指定主机的SocketChannel
        sc = SocketChannel.open(isa);
        // 设置该sc以非阻塞方式工作
        sc.configureBlocking(false);
        // 将Socketchannel对象注册到指定Selector
        sc.register(selector, SelectionKey.OP_READ);
        Message msg = new Message();
        msg.what = 0;
        msg.obj = sc;
        handler.sendMessage(msg); // 连接成功
        new Thread(new NIOReceiveThread(selector, handler)).start();
    }catch (IOException e)  {
        e.printStackTrace();
        handler.sendEmptyMessage(-1); // IO异常
TimerTask tt = new TimerTask(){
    @Override
    public void run(){
        if (sc == null || !sc.isConnected()){
                throw new SocketTimeoutException("连接超时");
            }catch (SocketTimeoutException e){
                e.printStackTrace();
                handler.sendEmptyMessage(-6); // 连接超时
};

Bootstrap b = new Bootstrap();
b.option(ChannelOption.CONNECT_TIMEOUT_MILLIS, 10000)

public Response request(Request request) throws TransportException {
    int timeout = nettyClient.getUrl().getMethodParameter(request.getMethodName(), request.getParamtersDesc(),
            URLParamType.requestTimeout.getName(), URLParamType.requestTimeout.getIntValue());
    if (timeout <= 0) {
           throw new MotanFrameworkException("NettyClient init Error: timeout(" + timeout + ") <= 0 is forbid.",
                   MotanErrorMsgConstant.FRAMEWORK_INIT_ERROR);
    NettyResponseFuture response = new NettyResponseFuture(request, timeout, this.nettyClient);
    this.nettyClient.registerCallback(request.getRequestId(), response);
    ChannelFuture writeFuture = this.channel.write(request);
    boolean result = writeFuture.awaitUninterruptibly(timeout, TimeUnit.MILLISECONDS);
    if (result && writeFuture.isSuccess()) {
        response.addListener(new FutureListener() {
            @Override
            public void operationComplete(Future future) throws Exception {
                if (future.isSuccess() || (future.isDone() && ExceptionUtil.isBizException(future.getException()))) {
                    // 成功的调用 
                    nettyClient.resetErrorCount();
                } else {
                    // 失败的调用 
                    nettyClient.incrErrorCount();
        return response;
    writeFuture.cancel();
    response = this.nettyClient.removeCallback(request.getRequestId());
    if (response != null) {
        response.cancel();
    // 失败的调用 
    nettyClient.incrErrorCount();
    if (writeFuture.getCause() != null) {
        throw new MotanServiceException("NettyChannel send request to server Error: url="
                + nettyClient.getUrl().getUri() + " local=" + localAddress + " "
                + MotanFrameworkUtil.toString(request), writeFuture.getCause());
    } else {
        throw new MotanServiceException("NettyChannel send request to server Timeout: url="
                + nettyClient.getUrl().getUri() + " local=" + localAddress + " "
                + MotanFrameworkUtil.toString(request));
}

NettyResponseFuture responseFuture = NettyClient.this.removeCallback(response.getRequestId());
if (responseFuture == null) {
    LoggerUtil.warn(
            "NettyClient has response from server, but resonseFuture not exist,  requestId={}",
            response.getRequestId());
    return null;
if (response.getException() != null) {
    responseFuture.onFailure(response);
} else {
    responseFuture.onSuccess(response);
}

public Object getValue() {
    synchronized (lock) {
        if (!isDoing()) {
            return getValueOrThrowable();
        if (timeout <= 0) {
            try {
                lock.wait();
            } catch (Exception e) {
                cancel(new MotanServiceException("NettyResponseFuture getValue InterruptedException : "
                        + MotanFrameworkUtil.toString(request) + " cost="
                        + (System.currentTimeMillis() - createTime), e));
            // don't need to notifylisteners, because onSuccess or
            // onFailure or cancel method already call notifylisteners
            return getValueOrThrowable();
        } else {
            long waitTime = timeout - (System.currentTimeMillis() - createTime);
            if (waitTime > 0) {
                for (;;) {
                    try {
                        lock.wait(waitTime);
                    } catch (InterruptedException e) {
                    if (!isDoing()) {
                        break;
                    } else {
                        waitTime = timeout - (System.currentTimeMillis() - createTime);
                        if (waitTime <= 0) {
                            break;
            if (isDoing()) {
                timeoutSoCancel();
        return getValueOrThrowable();
}

// 先使用method的配置
int tryCount =
        refUrl.getMethodParameter(request.getMethodName(), request.getParamtersDesc(), URLParamType.retries.getName(),
                URLParamType.retries.getIntValue());
// 如果有问题，则设置为不重试
if (tryCount < 0) {
    tryCount = 0;
for (int i = 0; i <= tryCount; i++) {
    Referer<T> refer = referers.get(i % referers.size());
    try {
        request.setRetries(i);
        return refer.call(request);
    } catch (RuntimeException e) {
        // 对于业务异常，直接抛出
        if (ExceptionUtil.isBizException(e)) {
            throw e;
        } else if (i >= tryCount) {
            throw e;
        LoggerUtil.warn(String.format("FailoverHaStrategy Call false for request:%s error=%s", request, e.getMessage()));

码农戏码

微服务超时与重试

微服务超时与重试

前言

超时

connectionTimeout

socketTimeout

nio

netty

connectionTimeout

socketTimeout

motan

totalTimeout

重试

实现

motan