26
4
I have following api returning Flux of String
我有以下返回字符串通量的接口
个人中心
文章发布
退出 @GetMapping(value = "/api/getStrListFlux",produces = MediaType.TEXT_EVENT_STREAM_VALUE)
public Flux<String> getListOfStr0() {
return Flux.just("Str-1", "Str-2", "Str-3", "Str-4", "Str-5")
.log().delayElements(Duration.ofSeconds(1));
}
Whenever I stop the Springboot Application while above method is yet to finish producing all the elements, following exception is thrown
每当我在上述方法尚未完成所有元素的生成时停止SpringBoot应用程序时，都会抛出以下异常
2023-09-11T09:05:28.695+08:00 INFO 2776 --- [nio-8080-exec-1] reactor.Flux.OnErrorReturn.1 : onSubscribe(FluxOnErrorReturn.ReturnSubscriber)
2023-09-11T09:05:28.698+08:00 INFO 2776 --- [nio-8080-exec-1] reactor.Flux.OnErrorReturn.1 : request(1)
2023-09-11T09:05:28.698+08:00 INFO 2776 --- [nio-8080-exec-1] reactor.Flux.OnErrorReturn.1 : onNext(Str-1)
2023-09-11T09:05:29.704+08:00 INFO 2776 --- [ parallel-1] reactor.Flux.OnErrorReturn.1 : request(1)
2023-09-11T09:05:29.704+08:00 INFO 2776 --- [ parallel-1] reactor.Flux.OnErrorReturn.1 : onNext(Str-2)
2023-09-11T09:05:30.709+08:00 INFO 2776 --- [ parallel-2] reactor.Flux.OnErrorReturn.1 : request(1)
2023-09-11T09:05:30.709+08:00 INFO 2776 --- [ parallel-2] reactor.Flux.OnErrorReturn.1 : onNext(Str-3)
2023-09-11T09:05:31.711+08:00 INFO 2776 --- [ parallel-3] reactor.Flux.OnErrorReturn.1 : request(1)
2023-09-11T09:05:31.711+08:00 INFO 2776 --- [ parallel-3] reactor.Flux.OnErrorReturn.1 : onNext(Str-4)
2023-09-11T09:05:32.714+08:00 INFO 2776 --- [ parallel-4] reactor.Flux.OnErrorReturn.1 : request(1)
2023-09-11T09:05:32.715+08:00 INFO 2776 --- [ parallel-4] reactor.Flux.OnErrorReturn.1 : onNext(Str-5)
2023-09-11T09:05:32.718+08:00 INFO 2776 --- [ parallel-4] reactor.Flux.OnErrorReturn.1 : onComplete()
Exception in thread "task-6" java.lang.UnsupportedOperationException: The dispatcher returned from the ServletContext does not support asynchronous dispatching
at org.apache.catalina.core.AsyncContextImpl.dispatch(AsyncContextImpl.java:196)
at org.apache.catalina.core.AsyncContextImpl.dispatch(AsyncContextImpl.java:174)
at org.apache.catalina.core.AsyncContextImpl.dispatch(AsyncContextImpl.java:168)
at org.springframework.web.context.request.async.StandardServletAsyncWebRequest.dispatch(StandardServletAsyncWebRequest.java:135)
at org.springframework.web.context.request.async.WebAsyncManager.setConcurrentResultAndDispatch(WebAsyncManager.java:405)
at org.springframework.web.context.request.async.WebAsyncManager.lambda$startDeferredResultProcessing$8(WebAsyncManager.java:473)
at org.springframework.web.context.request.async.DeferredResult.setResultInternal(DeferredResult.java:272)
at org.springframework.web.context.request.async.DeferredResult.setResult(DeferredResult.java:243)
at org.springframework.web.servlet.mvc.method.annotation.ResponseBodyEmitterReturnValueHandler$HttpMessageConvertingHandler.complete(ResponseBodyEmitterReturnValueHandler.java:223)
at org.springframework.web.servlet.mvc.method.annotation.ResponseBodyEmitter.complete(ResponseBodyEmitter.java:235)
at org.springframework.web.servlet.mvc.method.annotation.ReactiveTypeHandler$AbstractEmitterSubscriber.run(ReactiveTypeHandler.java:355)
at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144)
at java. Base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642)
at java.base/java.lang.Thread.run(Thread.java:1623)
Could not able to find any help. Please explain what is the cause and remedy for this..
找不到任何帮助。请解释一下造成这种情况的原因和补救措施。
I expect that SpringBoot application shutdowns gracefully and there is no error while doing so.
我希望SpringBoot应用程序能够正常关闭，并且不会出现任何错误。
in order for it to shutdown gracefully u need to set this property server.shutdown=graceful. if you dont have it, try with it again
为了让它正常关闭，您需要设置此属性server.Shutdown=graceful。如果你没有，再试一次
it worked .. thanks
它成功了..。谢谢
i ll post the solution as an answer. can you please mark it as right so that the thread gets solved? thanks
我会将解决方案作为答案发布。你能把它标记为正确吗，这样线就可以解决了吗？谢谢
in order for it to shutdown gracefully u need to set this property: server.shutdown=graceful
为了让它正常关闭，您需要设置此属性：server.Shutdown=graceful
26
4
0
询问 unrelated question我有这样的代码: public boolean equals(Object obj) { if (this == obj) retur
在我之前的一个问题中 js: Multiple return in Ternary Operator我询问了有关使用三元运算符返回多个参数的问题。但是现在参数IsActveUser boolean(t
假设我有一个带有 return 的 if 语句。从效率的角度来看，我应该使用 if(A > B): return A+1 return A-1 或 if(A > B): return
例如考虑以下代码: int main(int argc,char *argv[]) { int *p,*q; p = (int *)malloc(sizeof(int)*10); q
PyCharm 对这段代码发出警告，说最后一个返回是不可访问的: def foo(): with open(...): return 1 return 0 如果 ope
我想实现这样的目标: 如果在返回 Json 的方法中抛出异常，则返回 new Json(new { success = false, error = "unknown"}); 但如果方法返回 View
它是多余的，但我正在学习 JS，我想知道它是如何工作的。 直接从模块返回函数 let func1 = function () { let test = function () {
我不明白我应该使用什么。我有两页 - intro.jsp(1) 和 booksList.jsp(2)。我为每一页创建了一个 Controller 类。第一页有打开第二页的按钮:
我最近在 Joomla 组件(Kunena，更准确地说是 Kunena)中看到这段代码，那么使用 $this->return VS 简单的 return 语句有什么区别. 我已经用谷歌搜索了代码，但没
我的类实现了 IEnumerable。并且可以编译这两种方式来编写 GetEnumerator 方法: public IEnumerator GetEnumerator() { yield r
我只是在编码，我想到了一个简单的想法(显然是问题)，如果我有一个像这样的函数: int fun1(int p){ return(p); } 我有一个这样的函数: int fun1(int p){
这个问题在这里已经有了答案: What does the comma operator do in JavaScript? (5 个答案) 关闭 9 年前。 function makeArray
假设我写了一个 for 循环，它将输出所有数字 1 到 x: x=4 for number in xrange(1,x+1): print number, #Output: 1 2 3 4 现
我最近在这个 Apache Axis tutorial example. 中看到了下面的一段代码 int main() { int status = AXIS2_SUCCESS; ax
function a(){ return{ bb:"a" } } and function a(){ return { bb:"a" } } 这两个代码有什么区别吗，如果有请
function a() { return 1; } function b() { return(1); } 我在 Chrome 的控制台中测试了上面的代码，都返回了 1。 function c()
考虑这三个函数: def my_func1(): print "Hello World" return None def my_func2(): print "Hello World"
这可能是一个愚蠢的问题，但我正在努力，如果有一种简明的方法来测试函数的返回结果，如果它不满足条件，则返回该值(即，传递它)。。现在来回答一个可能的问题，是的，我正在寻找的类似于例外提供的东西。然而，作
我正在测试一个函数，并尝试使用 return 来做什么，并在 PowerShell 5.1 和 PwSh 7.1 中偶然发现了一个奇怪的问题，即 return cmdlet似乎不适合在团体中工作: P
这个问题已经有答案了: Return in generator together with yield (2 个回答) Why can't I use yield with return? (5 个回
我是一名优秀的程序员,十分优秀！