spring-cloud相关内容
我在 Zuul 中有一个场景,其中 URL 路由的服务也可能关闭.因此,响应正文在 JSON 正文响应中被抛出 500 HTTP 状态和 ZuulException. {“时间戳":1459973637928,“状态":500,"error": "内部服务器错误",“异常":“com.netflix.zuul.exception.ZuulException","message": "转发错误"}
..
我有一个配置了 @EnableResourceServer 注释的资源服务器,它通过 user-info-uri 参数引用授权服务器,如下所示: 安全性:oauth2:资源:用户信息 uri:http://localhost:9001/user 授权服务器/user 端点返回 org.springframework.security.core.userdetails.User 的扩展名,例如电
..
我是开发微服务的新手,虽然我已经研究了一段时间,阅读了 Spring 的文档和 Netflix 的文档. 我已经开始了一个简单的项目可在 Github 上使用.它基本上是一个 Eureka 服务器(Archimedes)和三个 Eureka 客户端微服务(一个公共 API 和两个私有 API).查看 github 的自述文件以获得详细说明. 关键是,当一切都在运行时,我希望如果其中一个
..
在 spring boot 中将属性放在 application.yml 或 bootstrap.yml 上有什么区别?在 logging.config 情况下,应用程序的工作方式不同. 解决方案 我刚刚问了 Spring Cloud 的人,我想我应该分享我在这里的信息. bootstrap.yml 在 application.yml 之前加载. 通常用于以下情况: 当使
..
我正在尝试让 SpringCloud AWS SQS 与自定义 SimpleMessageListenerContainerFactory 一起工作,以便我可以设置超时和最大消息数.如果没有使用 @SqsListener 注释的自定义 SimpleMessageListenerContainerFactory 方法,可以很好地拾取 SQS 中的消息.但是当我尝试配置自定义 SimpleMessag
..
zookeeper 和 spring 云配置服务器有什么区别?它们都将配置存储在服务器中并使它们可供客户端使用. 什么时候应该使用一个而不是另一个? 解决方案 zookeeper 和 spring 云配置服务器有什么区别? 使用 Spring Cloud Config Server,您可以集中管理所有环境中应用程序的外部属性.配置服务器上的概念与 Spring Enviro
..
你能告诉我如何停止发送到我的第三个 kafka 主题,当控件到达 catch 块时,当前消息被发送到错误主题以及在正常情况下应该发送到的主题加工.代码片段如下: @Component公共类 Abc {私有最终 StreamBridge streamBridge;公共 Abc (StreamBridge streamBridge)this.streamBridge = 流桥;@豆角,扁豆公共函数
..
我正在尝试根据一些评估将数据发送到不同的主题.我正在使用 SPring CLoud Streams 和 Kafka 如何有条件地转发kafka主题.需要在我专门评论的地方插入SCS-kafka相关代码. 谢谢. @EnableBinding(Sink.class)公共类 SampleSink {私有最终记录器记录器 = LoggerFactory.getLogger(this.ge
..
我正在尝试实现一个事件驱动架构来处理分布式事务.每个服务都有自己的数据库,并使用 Kafka 发送消息通知其他微服务有关操作. 示例: 订购服务 ------->|卡夫卡|------->支付服务||订单 MariaDB DB 付款 MariaDB 数据库 订单收到订单请求.它必须将新订单存储在其数据库中并发布一条消息,以便支付服务意识到它必须为该项目收费: 私人订单业务订单业务
..
你能告诉我如何停止发送到我的第三个 kafka 主题,当控件到达 catch 块时,当前消息被发送到错误主题以及在正常情况下应该发送到的主题加工.代码片段如下: @Component公共类 Abc {私有最终 StreamBridge streamBridge;公共 Abc (StreamBridge streamBridge)this.streamBridge = 流桥;@豆角,扁豆公共函数
..
版本: SpringBoot:2.3.12.RELEASE SpringCloud:Hoxton.SR12 SpringCloud Starter Sleuth:3.0.3 骆驼:3.4.6 我想将 Sleuth 添加到一个现在使用 ActiveMQ 的预先存在的项目中,以前它是在使用 JMS.当我这样做时,来自 ActiceMQ 消息的值被阻止/删除(一个是“文件名",它是 S
..
我正在尝试让 Spring Cloud 使用自动配置来处理消息传递. 我的属性文件包含: cloud.aws.credentials.accessKey=xxxxxxxxxxcloud.aws.credentials.secretKey=xxxxxxxxxxcloud.aws.region.static=us-west-2 我的配置类如下: @EnableSqs@ComponentSc
..
我需要为我的 lambda 函数访问 AWS Lambda 的上下文.我正在使用 SpringBootRequestHandler 来接收请求,它应该调用一个实现 Function 接口的类.下面是两个类的代码示例: public class A extends SpringBootRequestHandler{@覆盖公共对象句柄请求(S3Event 事件,上下文上下文){返回 super.ha
..
版本: SpringBoot:2.3.12.RELEASE SpringCloud:Hoxton.SR12 SpringCloud Starter Sleuth:3.0.3 骆驼:3.4.6 我想将 Sleuth 添加到一个现在使用 ActiveMQ 的预先存在的项目中,以前它是在使用 JMS.当我这样做时,来自 ActiceMQ 消息的值被阻止/删除(一个是“文件名",它是 S
..
当从方法返回值生成消息时,有没有办法配置默认的Message标头: @Publisher(channel = "theChannelname")公共 MyObject someMethod(Object param) {...返回我的对象;} 或 @SendTo("theChannelname")公共 MyObject someMethod(Object param) {...返回我的对
..
首先,感谢 Spring 团队为推动这项工作所做的所有工作! 现在Camden.SR5正式版了,我有一些问题在使用Spring Boot 1.5.1时如何正确配置spring cloud stream kafka binder. Spring Boot 1.5.1 对 kafka 进行了自动配置,而这些配置选项似乎与 Spring Cloud Stream kafka binder 中
..
在 spring 云数据流中,根据我的理解,每个流都是一个微服务,但数据流服务器不是.我说得对吗? Spring Cloud Dataflow(SCDF) 服务器是否可以有多个实例?如何对数据流服务器进行负载平衡?我打算在 AWS 中部署它.官方文档没有提到有关数据流服务器负载平衡的任何内容.如果可能的话,仪表板、外壳如何工作? 解决方案 SCDF-server 是一个常规的 Spr
..
是否可以将 Spring Cloud Contract Producer 验证发布给 Pact broker? 解决方案 您必须将 DSL 转换为 Pact 文件,然后推送这些文件.所以从技术上讲这是可能的. 更新:我们在文档中描述了如何做到这一点 - https://cloud.spring.io/spring-cloud-contract/reference/html/howto
..
1) 我已经使用 cf push -p abcdef.jar sinkapp 在 PCF 上注册了一个接收器应用程序.一切顺利 2) 现在我的 SCDF 服务器也在 PCF 上 如何使用位于同一 PCF、同一组织、同一空间上的数据流在 SCDF 服务器上注册 sinkapp.因为我不知道我应该参考什么来注册它?我正在寻找可以从数据流 shell 提供给 SCDF 的命令. 谢谢.
..
我正在按照说明操作 此处 提供自定义 RestTemplate. 我已经创建了 spring.factories 文件并验证它在META-INF 目录或 JAR. 我已经按照描述创建了类. 我在我的 中添加了一些日志语句 CustomConfigServiceBootstrapConfiguration 并且它们在我运行应用程序后不会出现. 似乎 spring.fact
..