-
0 votesanswersviews
当一个经纪人失败时, Kafka 制片人失败了
我们有一个3节点kafka(0.10.2.0)集群3节点ZK(zookeeper-3.4.10)集群 . 有大约80个主题,每个主题有10个分区和2个复制因子 . 每个Producer都会获得所有3个代理的列表,每个消费者都会获得所有3个zookeeper节点的列表 . Zookeeper properties: initLimit=10 syncLimit=5 # disable the per... -
0 votesanswersviews
多部分文件api中不支持的媒体类型
它始终在POSTMAN中提供415不支持的媒体类型错误 . Headers 包含带有边界的multipart / form-data,如下面的CURL调用 . 还试图用RequestBody替换RequestPart但没有成功 . 我们是否需要在使用FilePart时以任何不同的方式从 Spring 季5调用多部分文件上传apis? RESTContoller: @PostMapping(val... -
3 votesanswersviews
使用Spring 5 WebFlux框架解码ByteArray
我正在尝试使用带有kotlin的新Spring WebFlux框架 . 我找不到这个代码(myService)的错误: fun foo(): Flux<ByteArray> { val client = WebClient.create("http://byte-array-service") return client .g... -
10 votesanswersviews
Spring WebFlux和Reactor的线程模型
目前正在尝试使用 Spring 5.0.0.RC2 , Reactor 3.1.0.M2 和 Spring Boot 2.0.0.M2 进行反应式编程 . 想知道WebFlux和Reactor用来正确编写应用程序并处理可变状态的 concurrency and threading model . Reactor doc声明该库被认为是并发不可知的,并提到了Scheduler抽象 . WebFl... -
11 votesanswersviews
如何在Spring WebFlux中记录请求和响应主体
我希望使用Kotlin在Spring WebFlux上的REST API中集中记录请求和响应 . 到目前为止,我已经尝试过这种方法 @Bean fun apiRouter() = router { (accept(MediaType.APPLICATION_JSON) and "/api").nest { "/user".nest {... -
2 votesanswersviews
如何使用Spring WebFlux返回404
我有一个像这样的控制器(在Kotlin): @RestController @RequestMapping("/") class CustomerController (private val service: CustomerService) { @GetMapping("/{id}") fun findById(@PathVariable... -
1 votesanswersviews
Spring Webflux Reactor上下文
在以下示例中, test2 应该能够从 test 和 test1 访问 context 值,但似乎没有发生这种情况 . 欢迎任何见解 . 参考文献: http://projectreactor.io/docs/core/release/reference/#context https://jira.spring.io/browse/SPR-15680 https://simonbasl... -
0 votesanswersviews
Spring WebFlux:WebClient结合了2个Reactive RESTful Web服务
我正在使用Spring WebFlux开发具有Reactive支持的Microservices应用程序 . 让我们看看,我有一个问题列表属于一个类别和每个问题的选项列表 . 我将问题和选项分离到具有Reactive支持的服务中,我希望使用另一个服务将它们组合在一起使用Spring WebFlux的WebClient . 当然,它也需要支持Reactive . QuestionServiceImpl... -
0 votesanswersviews
Spring WebFlux Web客户端 - 迭代分页REST API
我需要从可分页的REST API的所有页面获取项目 . 我还需要开始处理项目,只要它们可用,不需要等待加载所有页面 . 为了做到这一点,我正在使用Spring WebFlux及其WebClient,并希望返回 Flux<Item> . 此外,我使用的REST API是速率限制的,每个响应都包含 Headers ,其中包含当前限制的详细信息: 当前窗口的大小 当前窗口中的剩余时... -
2 votesanswersviews
Spring Boot 2.0.2.RELEASE中的WebFlux并发模型
从Spring-Boot 2.0.1升级到2.0.2后,我注意到请求处理线程名称已更改 . 此外,看起来现在有更多专用于HTTP请求处理的线程 . 经过一些实验,我可以看到在我们现在拥有的4核服务器上: reactor-http-server-epoll- * - 处理传入HTTP请求的4个线程 . reactor-http-client-epoll- * - 处理来自WebCLien... -
1 votesanswersviews
Spring WebFlux没有流媒体响应
我期待这段代码将事件传递给客户端(代码在Kotlin中,但Java非常相似) @RestController object CustomerController { @GetMapping("/load", produces = arrayOf("application/stream+json")) fun load(): Flux<S... -
0 votesanswersviews
Spring引导webFlux内部单声道不发射数据
我是 Spring 季启动webflux的新手 . 我在这里遇到一个小问题“userMono不是空的”但这部分代码正在执行“switchIfEmpty(Mono.just(”hello123“))” 这是我的代码 Mono<String> someMono = serverRequest.bodyToMono(String.class); Mono<List<S... -
1 votesanswersviews
WebClient停止从Flux读取时的异常
我创建了一个返回无限Flux的服务器和一个异步读取响应对象的客户端 . 我希望客户取消订阅Flux并停止处理它 . 服务器的控制器: @GetMapping(path = "/infinite", produces = TEXT_EVENT_STREAM_VALUE) public Flux<String> getStreamOfLongs() { retu... -
3 votesanswersviews
Reactive WebClient不会发出响应
我有一个关于Spring Reactive WebClient的问题...几天前我决定使用Spring Framework中新的反应性东西,我做了一个小项目,只为个人目的抓取数据 . (向一个网页发出多个请求并合并结果) . 我开始使用新的反应式WebClient来发出请求但我发现的问题是客户端没有为每个请求发出响应 . 听起来很奇怪 . 以下是我为获取数据所做的工作: private Mono... -
8 votesanswersviews
Spring WebFlux,如何调试我的WebClient POST交换?
我无法理解在构建WebClient请求时我做错了什么 . 我想了解实际的HTTP请求是什么样的 . (例如,将原始请求转储到控制台) POST /rest/json/send HTTP/1.1 Host: emailapi.dynect.net Cache-Control: no-cache Postman-Token: 93e70432-2566-7627-6e08-e2bcf8d1ffcd ... -
0 votesanswersviews
在计划任务中使用Flux
我正在开发一个Spring Webflux项目,并且遇到了一个试图在计划任务中发布和使用Flux的问题 . @Scheduled(fixedRate = 20*1000) fun updateNews() { try { logger.info("Automatic Update at: ${LocalDateTime.now()}") ... -
5 votesanswersviews
在项目反应器中包装阻塞I / O.
我有一个spring-webflux API,它在服务层需要从使用JDBC的现有存储库中读取 . 在完成了关于这个主题的阅读之后,我想将阻塞数据库调用的执行与其他非阻塞异步代码分开 . 我已经定义了一个专用的jdbcScheduler: @Bean public Scheduler jdbcScheduler() { return Schedulers.fromExecutor(Execu... -
1 votesanswersviews
Spring Webflux - 服务器/客户端线程利用率
我正在和Netty一起使用Spring Webflux(2.0.3.RELEASE),并尝试了解服务器和Web客户端如何使用线程 . 我用WebClient编写了一些带有http调用链的代码片段 . 我怀疑所有的呼叫都是非阻塞的,但我无法弄清楚为什么只有一个请求通过整个链 . 这是下面的代码和日志输出: public class DemoApplication { private WebClie... -
7 votesanswersviews
Reactor将Mono <Boolean>映射到Mono <Void>
我有返回 Mono<Boolean> 的函数,我想将它映射到 Mono<Void> (因为这是我在Controller方法中返回的内容) . 有没有更好的方法来返回 Mono 而不是 .flatMap { Mono.empty<Void>() } ? 我不能使用 .map{ null } 因为映射函数不能接受 null . -
1 votesanswersviews
为什么Reactor 3需要单声道类型?
Reactor 3有2种主要数据类型,它们都是反应流发布者 reactor.core.publisher.Mono<T> reactor.core.publisher.Flux<T> 我理解Mono是0或1个元素的流,而Flux是0或N个元素的流 . 由于Mono和Flush都在实施 org.reactivestreams.Publisher<T> ... -
1 votesanswersviews
反应堆( spring 通量)
我正在使用Spring Flux . 我需要从不同的来源组装一个Object . 我怎样才能确定两个流都返回了所需的数据? 喜欢: public Mono<MyObject> createMyObject() { MyObject myObject = new MyObject(); someService.getSomeData().subscri... -
0 votesanswersviews
spring 反应器 - 等到单声道完成然后做下一个单声道
假设我有一个repository.save(..)方法,它返回一个Mono . 还可以说我有一个repository.findByEmail(..),它返回一个Mono . Problem: 我希望第一个单声道完成第二个单声道后完成 . repository.save(..).then(repository.findByEmail(..)) 但是,第二个Mono总是先执行?我的印象是 .then... -
0 votesanswersviews
等待运行Reactor Mono实例完成
我写了这段代码来分拆大量的WebClients(受 reactor.ipc.netty.workerCount 限制),立即启动Mono,等待所有Monos完成: List<Mono<List<MetricDataModel>>> monos = new ArrayList<>(metricConfigs.size()); for (Metri... -
0 votesanswersviews
spring 反应器螺纹模型
Spring Webflux的新手警报(v 2.0.1.RELEASE) . 我想将Spring Webflux用于后端(Webless)应用程序,以便从JMS侦听器处理大量数据 . 我的理解是Spring Webflux提供了一种非阻塞/异步并发模型 . 但是,我得到了一个基本问题,我需要一些帮助 . 作为一个免责声明,这个反应式编程的整个概念对我来说是一个新的东西,我仍然处于这种范式转换的过程... -
2 votesanswersviews
针对Reactor(或Akka)解决方案的CompletableFuture解决方案
我有以下方法使用 CompletableFuture 这样: public AClass aMethod() { CompletableFuture<SomeClassA> someClassAFuture = CompletableFuture.supplyAsync(() -> someMethodThatReturnsA()); Compl... -
0 votesanswersviews
使用Mono和CompletableFuture
我看到了一段代码,我想知道为什么我们需要一起使用 Mono 和 CompletableFuture . @GetMapping("{productId}") public CompletableFuture<CartProduct> getProduct(@PathVariable UUID productId) { return time("C... -
0 votesanswersviews
在Spring Boot Client中接收Flux
这是Spring 5 Web Reactive - How can we use WebClient to retrieve streamed data in a Flux?的后续问题 我尝试遵循建议如何使用Spring WebClient接收Flux但实际上遇到了netty问题 . 在服务器端,代码是一个简单的控制器,公开Mongo存储库的findAll方法: @RequestMapping(&... -
2 votesanswersviews
将spring-webflux微服务切换到http / 2(netty)
有没有人使用spring-webflux和netty(http / 2)? Spring Documentation说: 您可以使用server.http2.enabled配置属性在Spring Boot应用程序中启用HTTP / 2支持 . 此支持取决于所选的Web服务器和应用程序环境,因为JDK8不支持该协议 . Spring Boot不支持h2c,即HTTP / 2协议的明文版本 . 因... -
0 votesanswersviews
使用application / stream json时,Spring Reactive WebFlux报告空通量
我有一个反应核心WebClient发布到给定的 endpoints . 有效负载是JsonNodes的流量,内容类型是 application/stream+json JsonNode response = localEP.post().uri( "/createItem" ) .contentType(MediaType.APPLICATION_STREAM_JSO... -
0 votesanswersviews
使用application / stream json时,WebFlux不发送数据
我有一个反应核心WebClient发布到给定的 endpoints . 有效载荷是 Job 对象的通量,内容类型是应用程序/流json Flux jobFlux = Flux.just(new Job()); Mono<JsonNode> response = localEP.post().uri( "/dev/job" ) .contentType(Me...