webflux项目在服务器使用报未能获取有效的上下文

[zhuangzibin]

webflux项目在服务器使用报未能获取有效的上下文

[zhuangzibin]

今天打断点找了下问题，问题就出在响应式中flatMap切换了线程，boxThreadLocal不是原来的线程上下文了，所以拿不到原线程的上下文内容导致报错，webflux的确是切换线程的，所以应该依赖于contextWrite存储和deferContextual去取才对。
在本地不会报错就是本地测试不会切换线程，只有上服务器才会

public static Box getBoxNotNull() {
		Box box = boxThreadLocal.get();
		if(box ==  null) {
			throw new InvalidContextException("未能获取有效的上下文").setCode(SaErrorCode.CODE_10002);
		}
		return box;
	};

[StringKe]

@zhuangzibin 你解决这个问题了么？通过 deferContextual 或者 contextWrite 这个需要在 response 里才能获取到吧

应该要修改 ServerRequest.bodyToMono 的实现？

[zhuangzibin]

@zhuangzibin 你解决这个问题了么？通过 deferContextual 或者 contextWrite 这个需要在 response 里才能获取到吧

应该要修改 ServerRequest.bodyToMono 的实现？

其实官方的demo有写，在调用他的工具类时，先set一次，在另一个线程初始化上下文。如果你不使用他的工具类，可以考虑在拦截器那里就把用户信息放到Mono的上下文里，然后自己写工具类去上下文取，就不依赖于他的stpUtil工具类

return SaReactorHolder.getContextAndSetSync()
                .map(ignore -> {
                    StpUtil.login(1L, new SaLoginModel()
                            .setDevice("APP")
                            .setExtra(UserUtil.USER_ID, 1L));
                    
                    return 1L;
                });