标签: spring-cloud

我正在寻找的拓扑是

到目前为止，我还没有看到在 Cloud Stream 中定义每条消息的主题的方法。我知道消费者将绑定到特定主题，但是生产者在将消息发送到交换器之前如何设置每条消息的主题？

source.output().send(MessageBuilder.withPayload(myMessage).build());

不提供任何方法来设置交换的主题以路由到正确的消费者。

或者也许我不理解正确的东西？

更新

我希望不会在消费者中收到消息，因为bindingRoutingKey我2222正在发送routeTo 1111. 但我仍然在消费者身上收到它。

生产者属性：

spring.rabbitmq.host=localhost
spring.rabbitmq.port=5672
spring.rabbitmq.username=guest
spring.rabbitmq.password=guest

spring.cloud.stream.bindings.output.content-type=application/json
spring.cloud.stream.bindings.output.destination=messageExchange
spring.cloud.stream.rabbit.bindings.output.producer.routing-key-expression=headers['routeTo']


@EnableBinding(Source.class)
@SpringBootApplication
public class Application {

   public static void main(String[] args) {
    SpringApplication.run(Application.class, args);
  }

}

发件人：

source.output().send(MessageBuilder.withPayload(mo).setHeader("routeTo", "1111").build());

以及消费者：

spring.rabbitmq.host=localhost
spring.rabbitmq.port=5672
spring.rabbitmq.username=guest
spring.rabbitmq.password=guest

spring.cloud.stream.bindings.input.destination=messageExchange
spring.cloud.stream.rabbit.bindings.input.consumer.bindingRoutingKey=2222

应用：

@SpringBootApplication
@EnableBinding(Sink.class)
public class Application {

private static final Logger log = LoggerFactory.getLogger(Application.class);

public static void main(String[] args) {
    SpringApplication.run(Application.class, args);
}

@StreamListener(Sink.INPUT)
public void ReceiveMo(String moDTO) …

我目前正在使用spring cloud gateway项目构建简单的api网关，计划是将路由持久化到mongodb中，然后刷新，以便新路由可用。我做了这样简单的事情来从 mongo 获取我的路线。

@Bean
public RouteLocator routeLocator(RouteLocatorBuilder builder){
    List<CreateAPIRequest> apiRequestList = repository.findAll();
    RouteLocatorBuilder.Builder routeLocator = builder.routes();
    for (CreateAPIRequest request: apiRequestList) {
        routeLocator
        .route(r-> {
              r.path("/"+request.getProxy().getListenPath())
             .filters(f->f.stripPrefix(1))
             .uri(request.getProxy().getTargetUrl()) 
        });
    }
    return routeLocator.build();
}

我能够在数据库中创建新路线，但无法即时刷新。

我需要了解如何动态刷新路线。

谢谢

我正在尝试使用 Spring Cloud Gateway 做一个示例，用于 JWT 身份验证和 URL 路由目的。

当我作为 JAVA 应用程序运行或使用嵌入式 Tomcat 容器时，一切运行良好，但当将其作为 War 部署到 Tomcat 服务器时，我会出现以下依赖项注入错误。

应用程序无法启动

描述：

org.springframework.cloud.gateway.config.GatewayAutoConfiguration 中的方法routeDefinitionRouteLocator 的参数4 需要一个类型为“org.springframework.core.convert.ConversionService”的bean，但无法找到。

注入点有以下注释： - @org.springframework.beans.factory.annotation.Qualifier(value=webFluxConversionService)

行动：

考虑在配置中定义“org.springframework.core.convert.ConversionService”类型的 bean。

我尝试添加与 Spring Web Flux 相关的 jar，但错误没有消失

我的 POM.XML

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>
    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.1.6.RELEASE</version>
        <relativePath/> <!-- lookup parent from repository -->
    </parent>
    <groupId>com.gateway</groupId>
    <artifactId>gateway</artifactId>
    <version>1.0</version>
    <packaging>war</packaging>
    <name>gateway</name>
    <description>Demo project for Spring Boot</description>

    <properties>
        <java.version>1.8</java.version>
        <spring-cloud.version>Greenwich.SR2</spring-cloud.version>
    </properties>

    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-data-jpa</artifactId>
        </dependency>
        <dependency>
    <groupId>javax.servlet</groupId> …

嘿，我按照分步指南在 Spring Boot 中设置 kafka。

但现在我无法启动该应用程序。有什么建议 ：）

日志中的错误：

org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'functionInitializer' defined in class path resource [org/springframework/cloud/stream/function/FunctionConfiguration.class]: Invocation of init method failed; nested exception is java.lang.IllegalArgumentException: Found more then one function in BeanFactory: [persistentEntities, resourceMappings]. Consider providing 'spring.cloud.function.definition' property.

什么是 spring.cloud.function.definition？以及如何设置呢？引起原因：java.lang.IllegalArgumentException：在 BeanFactory 中发现多个函数：[persistentEntities，resourceMappings]。考虑提供“spring.cloud.function.definition”属性。

问题

• 尝试使用 Spring boot admin 对 Kubernetes 中运行的 Spring Boot 微服务进行深度监控。
• Spring Boot 管理列出了微服务，但指向内部 IP。

显示内部 IP 的 Spring Boot 管理应用程序列表页面

应用程序详细信息页面几乎为零信息

细节

• 库伯内特斯 1.15
• Spring boot 管理员使用 Spring cloud discovery 发现 Spring boot 应用程序
• spring-cloud-kubernetes 版本 1.1.0.RELEASE
• 问题是 IP 属于内部 Pod 网络，在任何现实场景中用户都无法访问。

关于如何处理这种情况有任何提示吗？还有其他选择吗？

我还想知道如果 Pod 具有多个副本，Spring Boot 管理员会如何表现。我认为通过入口或节点端口指向唯一的 Pod 副本几乎是不可能的。

我正在研究的黑客

如果我可以启动另一个 pod，将 Linux 桌面公开给最终用户。从该桌面的浏览器中，用户可以访问 pod 网络 ip。作为黑客，这只是一个疯狂的想法。

我生成了两个 jhipster 应用程序：微服务网关和选择使用 JWT 保护它的微服务应用程序。授权工作方式为例外，这意味着当我以微服务网关的用户身份登录时，它会发送一个令牌，并使用此令牌我可以向微服务应用程序authentication token发出直接请求以访问受保护的资源。