栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 软件开发 > 后端开发 > Java

Gateway 报错 java.lang.IllegalStateException: block()/blockFirst()/blockLast() are blocking, which is

Java 更新时间: 发布时间: IT归档 最新发布 模块sitemap 名妆网 法律咨询 聚返吧 英语巴士网 伯小乐 网商动力

Gateway 报错 java.lang.IllegalStateException: block()/blockFirst()/blockLast() are blocking, which is

引起错误的原因,在负载均衡调用时 BlockingLoadBalancerClient 会有一个 block 的操作

	@Override
	public  ServiceInstance choose(String serviceId, Request request) {
        // 略...
        // block
		Response loadBalancerResponse = Mono.from(loadBalancer.choose(request)).block();
        // 略...
		return loadBalancerResponse.getServer();
	}

往里面走会看到有个 blockingGet 方法,有做一个判断当前线程是否为非阻塞线程(NonBlocking)

// BlockingSingleSubscriber 类方法
final T blockingGet() {
    if (Schedulers.isInNonBlockingThread()) {
        throw new IllegalStateException("block()/blockFirst()/blockLast() are blocking, which is not supported in thread " + Thread.currentThread().getName());
    }
}

// Schedulers 类方法
public static boolean isInNonBlockingThread() {
    return Thread.currentThread() instanceof NonBlocking;
}

由于 Gateway 使用的线程为 NonBlocking,因此会报错,解决方案可以直接使用其他线程池调用,使用 Future#get(long, Timeunit) 获取响应结果;简单的例子如下:

CompletableFuture future = CompletableFuture.supplyAsync(() -> 1 + 1);
Integer ret = future.get(1, TimeUnit.SECONDS);
转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/845907.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号