问题标签 [spring-messaging]

我正在使用 spring integration 4.1.0 使用 jms-int:message-driven-channel-adapter 实现来自 TIBCO EMS 队列的消息消费

我有 9 个不同的消息驱动通道适配器在不同队列中的不同服务器上侦听。

下面是如何定义消息驱动的通道适配器

我将我的应用程序部署在 Tomcat 上，一切正常。所有适配器从队列中读取消息并发送处理。

但是由于某种原因，过了一段时间后，消息没有从队列中取出。目前我必须重新启动 tomcat 才能让适配器再次工作。我在 UI 中有一个按钮来启动/停止适配器，但是一旦适配器停止从队列中挑选消息，该按钮就不起作用。当适配器选择消息时，开始/停止按钮也可以正常工作。我可以停止并且适配器停止挑选消息，我可以开始并且适配器开始挑选消息。问题是当我的适配器运行一段时间后，说 5 - 10 小时后，队列中有一条消息，即使处于运行状态，适配器也没有选择。然后按钮也停止工作。

任何人都可以帮助可能是什么问题？为什么适配器在 5-10 小时后会出现故障？

非常感谢任何帮助。

更新：这是侦听器失败时来自 jstack 的堆栈跟踪。

任何意见？

我正在尝试使用简单的代理、SockJS 和 STOMP 来实现 Spring Websocket。我的应用程序在扩展 HandlerInterceptorAdapter 类的自定义拦截器（称为 SecurityInterceptor）中处理身份验证。我希望 SOMP 客户端在建立连接时发出的 HTTP 请求通过我的拦截器类，以便我验证用户是经过身份验证的用户。但是这些初始 HTTP 请求不会通过我的自定义拦截器。有人可以在这个问题上启发我吗？以下是我正在做的

主要的网络配置类：

WebSocket 配置类：

控制器类：

web.xml 中的 Dispatcher servlet 映射：

STOMP 客户端：

GlobalAPI 是上下文根。

初始请求 http://localhost:8080/GlobalAPI/dms/secured/hello/info 不会通过拦截器。当我发出任何其他 HTTP 请求（例如http://localhost:8080/GlobalAPI/dms/secured/documents）时，该请求会很好地通过拦截器。我的代码有什么问题？

我正在使用 Spring-websocket，但遇到以下问题：

我试图在@MessageMapping注释中放置一个占位符，以便从属性中获取 url。它适用于@RequestMapping但不适用于@MessageMapping.

如果我使用此占位符，则 URL 为空。有什么想法或建议吗？

例子：

我正在使用 RabbitMQ 作为代理创建一个 spring websocket 应用程序。有没有办法过滤用户将在频道上看到的 Web 套接字消息？

多人将订阅该频道。

我正在向客户发送价格（10000+），但下面的代码有循环，导致客户等待计算的过程出现延迟。

PriceVisibleForCustomer = 价格 + CustomerMargin

价格 - 每 300 毫秒更改一次 - 从中​​央商店发送，与客户实例无关

CustomerMargn - 由客户协议/部门/管理员决定等产生的一些正负值。在客户 http 会话期间它不会改变，我可以将它保存在内存中

客户 - 他在登录后参与流程，他应该看到 8 种产品的价格快速变化。

也许我需要更多技术？我有 Spring 3/4、Java、Weblogic，我甚至可以为这个任务创建单独的 webapp 来提供计算价格。

我考虑过 Java 中的线程，但是 10000 多个客户意味着线程太多，不是吗？如何更改此代码？也许我应该改变架构，但如何？

在我的 Web 应用程序（基于 Spring Tool Suite 构建）中，我维护 2 个 .properties 文件以将网站消息保存为希腊语和英语。我面临以下问题。有时在包含希腊消息的文件中，所有消息都松散编码并表示为问号，如我的 .properties 文件中的以下示例所示：

该问题随机发生，大多数情况下甚至没有向文件添加新消息。但是，jsp 上的消息已正确显示。我还没有找到解决我的问题的方法，每次发生时我只是从我们的存储库中替换文件。

我的目标：我有多个并行运行的作业（进程）（单独的线程）。我想实现消息传递，以便每个进程都可以将消息（如果需要）发送到 rabbitmq 服务器。现在我有这个

并从我的一项操作中调用它

我应该把它变成抽象类，我的每个操作/流程都应该扩展它吗？什么是最好的方法？我可以使上述过程更好吗？

整个魔法在这里它只在 linux\server\laptop 机器上崩溃并且在 mac 上完美地工作（自动装配）。我有

如果这些类之一（例如 C）有

然后 C 在 WebSocketConfiguration 上变为 null 并且所有后续类也变为 null （当前示例中的 D 类也。所以这里的顺序很重要）

有趣的是，在 Mac 笔记本电脑上它可以完美运行，但在服务器和我的 linux 笔记本电脑上我遇到了麻烦。

在 A、B、C、D 类中也有相互引用（循环依赖自动装配），但据我了解，Spring 必须非常容易地解决它。

如果我从 SimpMessagingTemplate 中删除 @Autowire 所有类都可以完美加载并且可以正常工作。

这里可能有什么问题？

嗨，我一直在尝试使用 Spring 的 Websocket 支持制作消息总线。有许多 sockjs 客户端连接到 Spring 应用程序的示例。我现在想尝试使用 WebSockets 来允许两个 Spring 应用程序在双向服务器客户端场景中进行通信。

我使用 JHipster 作为我的基础，它提供了 Spring 基础（安全性、REST、WebSockets、持久性等）。我坚持使用嵌入式 Spring SimpleMessageBroker，如此处所示 - https://github.com/jhipster/jhipster-sample-app-websocket

我也一直在关注 Spring websocket 示例项目作为构建客户端的指南 - https://github.com/rstoyanchev/spring-websocket-portfolio/blob/master/src/test/java/org/springframework/samples/投资组合/web/tomcat/IntegrationPortfolioTests.java

不幸的是，我的 WebSocketStompClient 客户端在连接时到处都是。最初我遇到了 Spring Security 和 CSRF 的问题，在多次尝试模仿 Angular 客户端的标头后，我刚刚禁用了 CSRF。现在我看到 HTTP 连接升级请求被拒绝。

谁能指出我正确的方向/有效的材料？（上面的 spring 示例测试失败）

以前一切正常。今天我将 Spring Batch 与我的 Spring Boot 应用程序一起配置，并遇到了application.properties.

我有以下使用 Jasypt 加密的属性：

现在，为了配置我添加的 Spring Batch

application.properties归档。

另外，我添加了batch-h2.properties文件：

之后我不断收到以下异常：

aws.sqs.account.access.key财产现在无法解决。

我将此属性注入到我的配置中：

如何解决？