草庐IT

Spring-Kafka

全部标签

java - 使用 QueryDSL 和 Spring 的 Repository 编写跨表查询

我构建了一个DAL,它使用Spring的存储库通过Hibernate和JPA管理MySQL数据库上的CRUD操作。特别是这是我的存储库定义packagemy.dal.repository;importmy.domain.dal.User;importorg.springframework.data.querydsl.QueryDslPredicateExecutor;importorg.springframework.data.repository.CrudRepository;importorg.springframework.stereotype.Repository;@Repos

java - 带有工厂方法的 Spring Bean 从 XML 到 Java 配置

翻译这个bean的正确方法是:从XML到Java-Config(注意工厂方法)?下面的解决方案对吗?@BeanpublicVelocityEngineveloctyEngine(){returnVelocityFactory.getEngine();}根据Spring-philosophy有没有更好的实现?干杯,V。 最佳答案 你这样做的方式似乎是正确的。查看this博文。 关于java-带有工厂方法的SpringBean从XML到Java配置,我们在StackOverflow上找到一个

java - Spring Web MVC Java 配置-默认 Servlet 名称

我写了一个小应用来学习spring的java配置,因为我被同行唠叨了一段时间,现在升级我们的应用程序;-),一个简单的待办事项列表应用程序,它具有安全性和webmvc配置,JPA用于持久化,全部通过java配置。我在尝试运行应用程序时遇到问题。安全配置和JPA等工作正常,但在成功拦截protectedURL后我得到一个空View主要的Web应用初始化程序类扩展AbstractAnnotationConfigDispatcherServletInitializerpublicclassWiggleWebApplicationInitializerextendsAbstractAnnota

java - Kafka Java 消费者仅适用于本地主机,无法用于远程服务器

我使用Kafka已经两个月了,我使用这段代码在本地消费消息。我最近决定分发Zookeeper和Kafka,一切似乎都运行良好。当我尝试从远程IP使用消费者代码时,我的问题就开始了;一旦我将seeds.add("127.0.0.1");更改为seeds.add("104.131.40.xxx");我收到此错误消息:run:ErrorcommunicatingwithBroker[104.131.40.xxx]tofindLeaderfor[temperature,0]Reason:java.net.ConnectException:ConnectionrefusedCan'tfindme

java - Spring配置类加载顺序与spring-boot @ConditionalOnMissingBean?

我想使用@ConditionalOnMissingBean启用自定义配置和合理的默认值?我有一个springboot应用程序:@Configuration@Import({CustomConfiguration.class,DefaultConfiguration.class})@EnableAutoConfiguration(exclude={MetricFilterAutoConfiguration.class})publicclassApplication{@AutowiredErrorListenererrorListener;}和一个允许Springxml或组件扫描的Cust

java - 使用 RestTemplate 使用 Spring Hateoas Restservice

我有两个应用程序,一个叫做bar,它以HAL格式为我提供资源。另一个是使用该服务的bcm。响应bar的示例如下所示:[{"name":"Brenner/in","_links":{"self":{"href":"..host/bbsng-app-rest/betrieb/15"}}},{"name":"Dienstleistungshelfer/inHW","_links":{"self":{"href":"..host/bbsng-app-rest/betrieb/4"}}},{...现在我尝试使用SpringRestTemplate从bcm使用它。我的解决方案有效,但不知何故我对该

java - 无法使用kafka Producer API与kafka服务器通信

我已经在单个节点上设置了kafka,并启动了zookeeper和kafka服务器。我在控制台上针对内部生产者和消费者对其进行了测试,并且运行良好。但是当我在控制台上运行内部kafka消费者时,我的自定义生产者它不起作用。下面是我的Producer类Propertiesprops=newProperties();props.put("metadata.broker.list","xx.xx.xx.xx:9092");props.put("serializer.class","kafka.serializer.StringEncoder");props.put("partitioner.c

java - 编写客户端在 spring boot 中连接到 websocket

我正在尝试使用springboot制作基于websocketed的服务器/客户端应用程序。服务器接受套接字连接,然后当它收到来自客户端的文本消息时,它会处理它,然后返回一些数据。服务器有一个websocket处理程序,可以正确处理请求。publicclassDataWebSocketHandlerextendsTextWebSocketHandler{privatestaticLoggerlogger=LoggerFactory.getLogger(DataWebSocketHandler.class);privatefinalDataServicedataService;@Autow

java - Spring 与 JMS + ActiveMQ 集成 : Messages remain in JDBC Message Store after reconnect

我正在尝试使用SpringIntegration和ActiveMQ消息代理配置JMS。我的出站channel应该由JDBC消息存储支持,以防止数据丢失,例如经纪人或我的应用程序离线。到目前为止,我的配置似乎有效,但JDBC消息存储的行为并不像我预期的那样。如果我断开代理,发送到出站channel的消息将按预期保留,但在重新连接后它们保留在数据库中并且不会发送到队列。但是,我在重新连接后发送的更多消息到达队列,如果我重新启动我的应用程序,持久消息也会最终发送......application-context.xml-->context.xml我正在使用EcomxProducerGatew

java - 同一接口(interface)的Spring多重实现

我有一个接口(interface)和这个接口(interface)的多个实现类,大约有10个。我有一个像prefix+name+suffix这样的命名约定所以在运行时,我可以添加@AutowiredprivateMapmyImplementations;然后使用myImplementations.get()访问实现类方法。有没有更好的方法来访问这些实现?我只知道哪个暗示。我在运行时需要,更改取决于我收到的消息。 最佳答案 你可以实现BeanFactoryAware类中的接口(interface),然后使用注入(inject)的bea