小编Din*_*dan的帖子

Spring 5 Reactive 中的 HTTP 响应异常处理

我正在使用 Spring Boot 2 和 Spring 5 和 WebFlux 反应式启动器开发一些反应式微服务。

我面临以下问题:我想处理通过调用另一个 REST 服务收到的所有 HTTP 状态,并在收到一些错误的 HTTP 状态时抛出异常。例如,当我调用端点并收到 404 HTTP 状态时,我想抛出一个异常,并且该异常将在某些 ExceptionHandler 类中处理,就像在 Spring 4 中使用@ControllerAdvice.

这样做的正确方法是什么?希望得到一些好的建议。

java exception spring-boot spring-webflux

14
推荐指数
2
解决办法
2万
查看次数

Android Studio 3.1.1 - 无法添加模块(导入gradle项目)

Android Studio 3.1.1.新模块 - >导入gradle项目,选择要导入和确认的项目后,IDE崩溃异常:

元素:类org.jetbrains.plugins.groovy.lang.psi.impl.GroovyFileImpl因为:不同的提供者:SingleRootFileViewProvider {myVirtualFile = file:///home/michal/AndroidStudioProjects/FirebaseJobTest/settings.gradle,content = VirtualFileContent {size = 26}}(1416c50); SingleRootFileViewProvider {myVirtualFile = file:///home/michal/AndroidStudioProjects/FirebaseJobTest/settings.gradle,content = VirtualFileContent {size = 26}}(665cfacf)在以下位置失效:请参阅附件com.intellij.psi.PsiInvalidElementAccessException:Element:class org .jetbrains.plugins.groovy.lang.psi.impl.GroovyFileImpl因为:不同的提供者:SingleRootFileViewProvider {myVirtualFile = file:///home/michal/AndroidStudioProjects/FirebaseJobTest/settings.gradle,content = VirtualFileContent {size = 26}}( 1416c50); SingleRootFileViewProvider {myVirtualFile = file:///home/michal/AndroidStudioProjects/FirebaseJobTest/settings.gradle,content = VirtualFileContent {size = 26}}(665cfacf)在以下位置无效:请参阅com.intellij.psi.util.PsiUtilCore.ensureValid中的附件(PsiUtilCore.java:502)

你知道任何解决方法吗?

crash import module gradle android-studio

11
推荐指数
1
解决办法
3505
查看次数

复制与冗余

我目前正在阅读有关分布式系统的信息,我面临着两个以类似方式描述的不同术语:复制冗余

谁能部分解释每个术语?

replication redundancy distributed-system

7
推荐指数
1
解决办法
2553
查看次数

如何在JavaFx中为不同的分辨率自动调整窗口大小?

我有以下问题:

JavaFX在桌面上用全高清创建了一个窗口,我设置了这样的场景:

Scene scene = new Scene(root,1475,1015);
Run Code Online (Sandbox Code Playgroud)

当我在具有1360*760分辨率的笔记本电脑上运行应用程序时,我看不到整个应用程序,我无法调整它的大小.

如何设置我的应用程序以自动调整桌面/笔记本电脑的功能及其分辨率和尺寸?

java windows resize javafx scenebuilder

6
推荐指数
1
解决办法
1万
查看次数

如何匹配wire-mock url中的请求参数?

我正在尝试使用wire-mock创建一个模拟服务器,但我面临以下问题:我想点击这样的URL /customers?customerId={customerId}&customerNo={customerNo}

我的问题是如何在 Java 代码中匹配请求参数customerIdcustomerNo模拟服务器的存根。

编辑

第一次响应后,结果如下:

在此输入图像描述

编辑2

这是我的存根:

WireMockServer mockServer = new WireMockServer(8079);
mockServer.start();
mockServer.stubFor(get(urlEqualTo("/api/loan/admin/contracts"))
                .withQueryParam("status", equalTo("ACTIVE"))
                .withQueryParam("cnp", equalTo("1950503410033"))
                .willReturn(aResponse().withBody("Welcome to Baeldung!")));
Run Code Online (Sandbox Code Playgroud)

java httprequest mockserver

6
推荐指数
1
解决办法
1万
查看次数

测微计@Timed 注释

谁能解释一下千分尺注释公开的度量_count_sum度量之间有什么区别@Timed

在这里,您有两个度量值示例,作为@Timed方法的注释帖子的结果。

GET_CARD_LIMITS_BY_LIMIT_TYPE_seconds_count{class="ro.orange.productsbff.infrastructure.adapter.cms.integration.CmsClient",method="getCardLimitsByType",} 9.0

GET_CARD_LIMITS_BY_LIMIT_TYPE_seconds_sum{class="ro.orange.productsbff.infrastructure.adapter.cms.integration.CmsClient",method="getCardLimitsByType",} 1.838999262
Run Code Online (Sandbox Code Playgroud)

谢谢!

java spring-boot prometheus micrometer

5
推荐指数
1
解决办法
2065
查看次数

Scala 案例类与 Kotlin 数据类

Scala 有一个叫做case class的特性,而 Kotlin 有另一个叫做data class 的特性。Scala案例类和 Kotlin数据类之间的主要区别是什么?

scala class kotlin

4
推荐指数
2
解决办法
696
查看次数

Kafka Streams - 缺少源主题

我在 Kafka Streams 拓扑中工作,有时在更改 applicationId 和/或 clientId 属性后,我在特定的 kafka 流上收到错误:“ Missing source topic stream.webshop.products.prices.5 durign assignment. Returning error INCOMPLETE_SOURCE_TOPIC_METADATA”。我已经create.topic=true在每个 Kafka 节点的 server.properties 中设置了属性,但似乎没有创建此流的主题。

这是我的 Kafka Streams 拓扑:

    package ro.orange.eshop.productindexer.domain

import org.apache.kafka.streams.KafkaStreams
import org.apache.kafka.streams.StreamsBuilder
import org.apache.kafka.streams.kstream.Materialized
import org.apache.kafka.streams.kstream.Printed
import ro.orange.digital.avro.Aggregate
import ro.orange.digital.avro.Key
import ro.orange.digital.avro.Price
import ro.orange.digital.avro.StockQuantity
import ro.orange.eshop.productindexer.infrastructure.configuration.kafka.makeStoreProvider
import java.util.concurrent.CompletableFuture

class SaleProductTopology(
        private val streamNameRepository: IStreamNameRepository,
        private val saleProductMapper: ISaleProductMapper,
        private val productRatingMapper: IProductRatingMapper,
        private val productStockMapper: IProductStockMapper,
        private val lazyKafkaStreams: CompletableFuture<KafkaStreams>
) {
    fun streamsBuilder(): StreamsBuilder { …
Run Code Online (Sandbox Code Playgroud)

apache-kafka apache-kafka-streams

3
推荐指数
1
解决办法
2673
查看次数

Scala 中的 LazyList 和 List 有什么区别?

什么是以下集合类型之间的差异斯卡拉ListLazyList类型?

scala scala-collections

3
推荐指数
1
解决办法
1799
查看次数

MVC Annotation Spring MVC <mvc:annotation-driven />

我对Spring MVC很新,我有一个问题要问你.

我知道标签<mvc:annotation-driven />在servlet配置中处理注释,例如@ Controller,@ RequestMapping,但是我正在使用portlet,我很好奇这个注释在这里是如何工作的?

谢谢!

java model-view-controller spring portlet annotations

2
推荐指数
1
解决办法
7795
查看次数

使RPM Ansible失败并显示Python错误

我正在尝试在具有RHEL 7.2的计算机上安装Ansible,以创建Ansible服务器。

我需要Ansible v2.4或更高版本,为此,我执行了以下步骤:

 1. yum -y install git asciidoc rpm-build python2-devel
 2. cd /usr/src
 3. git clone git://github.com/ansible/ansible.git --recursive
 4. cd ansible
 5. git checkout stable-2.4
Run Code Online (Sandbox Code Playgroud)

从现在开始一切正常,但是现在我想运行以下命令:

make rpm 在那之后: yum install rpm-build/ansible-2.4-0.git201601051704.a2a786e.stable201.el7.centos.noarch.rpm

但是在运行时make rpm,出现以下错误:

Traceback (most recent call last):
  File "packaging/release/versionhelper/version_helper.py", line 9, in <module>
    from packaging.version import Version, VERSION_PATTERN
ImportError: No module named packaging.version
Makefile:39: *** "version_helper failed".  Stop.
Run Code Online (Sandbox Code Playgroud)

pip yum ansible-2.x

1
推荐指数
1
解决办法
2619
查看次数

协程执行时间与回调执行时间

我正在阅读“Functional Kotlin”一书,我刚刚从那本书中尝试了一些关于 Kotlin 并发编程的示例。我有以下并发代码的实现:

  1. 带回调:
package com.freesoft.functional.coroutines

import kotlin.concurrent.thread

class CallbacksMain

class CallbackUserClient(private val client: UserClient) {
    fun getUser(id: Int, callback: (User) -> Unit) {
        thread {
            callback(client.getUser(id))
        }
    }
}

class CallbackFactClient(private val client: FactClient) {
    fun get(user: User, callback: (Fact) -> Unit) {
        thread {
            callback(client.getFact(user))
        }
    }
}

class CallBackUserRepository(private val userRepository: UserRepository) {
    fun getUserById(id: UserID, callback: (User?) -> Unit) {
        thread {
            callback(userRepository.getUserById(id))
        }
    }

    fun insertUser(user: User, callback: () -> Unit) {
        thread { …
Run Code Online (Sandbox Code Playgroud)

kotlin kotlin-coroutines

1
推荐指数
1
解决办法
422
查看次数

Spring Boot 2 中不使用 Netty Server 和 Reactive starter

我正在使用 Spring Boot 2 和反应式启动器开发一个反应式项目。我的问题是,当我启动应用程序时,它启动的是 Tomcat 服务器而不是 Netty。

这是 build.gradle 文件中的依赖项任务:

dependencies {
compile("org.springframework.boot:spring-boot-starter-actuator:${springBootVersion}")
compile("org.springframework.boot:spring-boot-starter-webflux:${springBootVersion}")
compile("org.springframework.boot:spring-boot-starter-hateoas:${springBootVersion}")
compile group: 'com.github.tomakehurst', name: 'wiremock', version: '2.15.0'
compile("ro.orange.omoney:lms-token-client:0.1.0-SNAPSHOT")
testCompile("org.springframework.boot:spring-boot-starter-test:${springBootVersion}")
Run Code Online (Sandbox Code Playgroud)

}

你能告诉我为什么我会遇到这个问题吗?谢谢你!

gradle spring-boot reactor-netty spring-webflux

0
推荐指数
1
解决办法
2291
查看次数