mq相关内容

打开队列管理器时遇到错误，名称=...原因代码=2354

首先：我有两个BizTalk应用程序。首先从SQL服务器进行轮询，然后发送到MQ队列，运行良好。第二个应用程序处理一个文件并使用动态发送端口。在编排中，我更新了TOMQ(Microsoft.XLANGs.BaseTypes.Address)=队列路径； TOMQ(Microsoft.XLANGs.BaseTypes.TransportType)="；MQSeries"；；它获取文件 ..
发布时间：2022-04-17 23:43:06 C#/.NET

使用来自IBM MQ的所有消息

我要使用来自MQ的所有消息。 public static void main(String[] args) { JMSContext context = null; Destination destination = null; JMSConsumer consumer = null; JmsFactoryFactory FF = JmsFactoryFactory.getIns ..
发布时间：2022-04-12 12:25:32 Java开发

RabbitMQ:下一条消息只有在上一条消息被确认后才能出队

我想在 RabbitMQ 中的队列上有这个约束: 队列中的下一条消息在前一条消息(正在处理的消息)被确认之前不能出队. 通过这个，我将实现事件的有序处理和跨多个队列的并行处理.我如何/可以为此配置 RabbitMQ? 编辑(澄清):将有许多消费者都试图从所有队列中获取工作，并且由于他们无法从正在处理的事件未确认的队列中获取工作 - 保持有序处理. 解决方案 在前一条消 ..
发布时间：2022-01-11 17:55:24 其他开发

使用来自 MQ 的消息并在 Spring JMS 中合并

我使用 spring + MQ + Websphere 应用服务器. 我想异步使用来自 MQ 的消息并将这些消息组合起来，以便在每次提交中轻松将 N 个实体持久化到数据库中.(没有强调我的目标 Oracle 数据库太多提交) 我使用 DefaultMessageListenerContainer 并使 onMessage 方法同步以添加消息(直到批量大小)，并创建线程以等待条件满足(时 ..
发布时间：2021-11-12 03:13:57 其他开发

TCP 套接字的连接池和多线程?

我有一个 Java 应用程序(比如 A)，它通过 TCP 套接字与一个应用程序(比如 B)通信.我的 java 应用程序是多线程的，最多可以处理 100 个线程.在 A 之间进行通信 -->B 我们有 10 个套接字. 挑战 - 连接池 - 需要连接池机制来处理 n(比如 100)个线程(应用程序 A)，与应用程序 B 通过 x(比如 10)个 TCP 套接字. 多线程 - 两个 ..
发布时间：2021-11-11 23:16:31 Java开发

ServiceStack Messaging API:它可以进行广播吗?

正如我以前 提到，我正在使用ServiceStack Messaging API (IMessageQueueClient.Publish) 以及更底层的 IRedisClient.PublishMessage. 当我需要一个特定的消息/请求仅由一个模块/服务的一个实例处理时，我会使用 Messaging API，因此即使我可能有多个模块在运行，所有模块都在侦听 MyRequest，只有一个 ..
发布时间：2021-07-05 20:14:12 其他开发

RabbitMQ:只有在确认前一条消息后才能出列下一条消息

我想在 RabbitMQ 的队列上设置这个约束: 在上一条消息(正在处理的消息)被确认之前，队列中的下一条消息不能出列. 通过这个，我将实现事件的有序处理和跨多个队列的并行处理.我/如何为此配置 RabbitMQ? 编辑(澄清):将有许多消费者都试图从所有队列中获取工作，并且由于他们无法从正在处理的事件未被确认的队列中获取工作 - 保持有序处理. 解决方案 在上一条消 ..
发布时间：2021-07-02 18:34:23 其他开发

在证书签名请求(CSR)中使用公钥

在我们的服务器上创建CSR时将生成公钥和私钥对.我们将通过持有我们的私钥将CSR和公钥发送给CA.在使用CA的根证书的私钥进行签名之前，CA会先验证我们的公钥.我们有自己的CA团队来认证CSR请求.我的查询如下: CSR本身会包含公钥吗?还是需要向CA分别提供公钥? 在将CSR发送到CA之前，将其用我们的公钥签名吗?(或)除此以外，CSR还应持有公钥? CA是否仅通过CSR(或)对CSR ..
发布时间：2021-05-15 19:22:54 其他开发

JMS相关性ID被截断

我正在将uuid字段设置为JMSCorrelationID到我的出站消息.我还设置了对Queue的答复和对Quemanger的COD答复.设置正确的用户标识符后，我可以在设置的ReplyTo Q中接收到COD消息.但是，在COD消息中收到的correlationIDID已将我的UUID字段的字节截断为32个字节.因此，我无法协调收到COD的消息.发送消息时，请找到以下代码.我已经省略了ReplyT ..
发布时间：2021-05-15 19:22:37 其他开发

剪切dspmq命令的输出

我正在尝试削减dspmq命令的输出 这是给出的输出: QMNAME(QMGR)状态(正在运行)QMNAME(QMGR)状态(正常结束)QMNAME(QMGR)状态(意外结束)QMNAME(QMGR)状态(正在运行) 这是我希望输出显示的样子: QMGR正在运行QMGR正常结束QMGR意外结束QMGR跑步 我尝试了cut命令的各种组合，但没有成功或失败.任何帮助将不胜感激. ..
发布时间：2021-04-27 20:43:25 服务器开发

消耗来自MQ的消息并在Spring JMS中合并

我使用spring + MQ + Websphere Application Server. 我想异步使用来自MQ的消息，并合并消息以使消息列表易于在每次提交中将N个实体持久保存到数据库中.(不必过多地提交我的目标Oracle数据库) 我使用DefaultMessageListenerContainer并同步了onMessage方法以添加消息(直到批处理大小)，并创建线程以等待条件满足 ..
发布时间：2021-04-08 19:06:51 其他开发

IBM MQMD标头如何区分

如何区分MQMT_SYSTEM_FIRST与MQMT_REQUEST? 解决方案 MQMT_SYSTEM_FIRST是范围标识符，永远不会在真实消息中使用.如果您在MQMD中看到值1，则其总是表示MQMT_REQUEST. 因此，实际上，您将MQMT_SYSTEM_FIRST -> MQMT_SYSTEM_LAST作为系统MQMT*值的保留范围，而将MQMT_APPL_FIRST - ..
发布时间：2020-11-26 02:06:24 其他开发

通过.net客户端通过SSL连接到IBM MQ

我正在尝试通过.NET客户端连接到MQ服务器队列.我需要使用证书进行安全通信.这是我的代码: MQEnvironment.SSLKeyRepository = "*SYSTEM"; MQEnvironment.ConnectionName = connectionName; MQEnvironment.Channel = channelName; MQEnvironment.properti ..
发布时间：2020-11-26 01:51:00 C#/.NET

尝试使用PHP连接到MQ；差不多了

因此，过去的几天我一直在尝试解决这个似乎已被遗忘的问题，因为两个可用的PECL扩展(SAM和mqseries)都没有更新很长时间.我已经尝试了两者，由于SAM拒绝与我建立连接，因此mqseries在这一点上似乎使我走得最远，即使MQ在命令行中运行正常.我已经成功创建了到QueueManager的连接，但在下一步(MQOPEN)期间，我不幸失败了: $mqcno = array( ..
发布时间：2020-11-26 01:49:23 PHP

从Windows Cert Store获取.Net MQ客户端时的证书标签

我已将KeyStore设置为* User，以从Windows证书存储区获取证书。MqClient应用程序正尝试使用标签名称来查找证书，如客户端Trace中的日志所示。我尝试从client.ini和代码设置CertificateLabel，但它不会覆盖该值。 我该如何更改？即使我可以覆盖我如何更改直接导入到证书存储中的证书的标签？ 请帮助 000001B6 12：23：39.86 ..
发布时间：2020-09-30 20:54:15 C#/.NET

TCP套接字的连接池和多线程?

我有一个Java应用程序(例如A)，可以通过TCP套接字与应用程序(例如B)进行通信.我的Java应用程序是多线程的，最多可以处理100个线程.在A之间进行通信B我们有10个套接字. 挑战- 连接池-需要连接池机制来处理n个(例如100个)应用程序A的线程，并与之通信 通过X(例如10)TCP套接字号访问应用程序B. 多线程-两个线程如何访问同一套接字，一个接一个地发送请求并获取 ..
发布时间：2020-09-03 06:27:22 Java开发

在RabbitMQ主题交换中路由与模式不匹配的消息

两个队列通过以下路由键绑定到主题交换: 队列A，绑定了路由键模式匹配*.foo 与路由键模式匹配*.bar 绑定的队列B 我想在此交换中添加第三个队列，以接收既不是foo消息也不是bar消息的消息.如果我用#路由密钥将此队列绑定，我自然会得到我需要的所有消息，但包括不需要的foo和bar. 任何路由修补模式NOT *.foo和NOT *.bar的消息的方式? 解决方案 如 ..
发布时间：2020-07-19 18:46:55 其他开发

异步接收来自MQ的多条消息

我在应用程序中使用Spring + Hibernate + JPA. 我需要从Websphere MQ中读取消息，并将消息插入DB. 有时可能有连续的消息可用，有时消息的数量很少，有时我们期望没有来自Queue的消息. 当前，我正在逐一阅读消息并将其插入数据库.但这对性能没有太大帮助. 我的意思是当我有大量消息时(例如Queue中的300k消息)，我无法更快地插入它们.每秒插入数 ..
发布时间：2020-05-13 20:48:18 其他开发

以编程方式在mosquitto中设置访问控制限制

我正在开发将使用mqtt的应用程序.我将使用python库.我一直倾向于使用mosquitto，但是找不到以编程方式为其设置访问控制限制的方法.我正在编写的应用程序需要能够区分用户，并且只允许他们订阅某些主题.当前的解决方案看起来是通过配置文件完成的.是否有可扩展的解决方案来解决蚊子的访问控制限制?如果不是，您是否知道存在的mqtt经纪人? 解决方案 即使这可能不再与您有关，其他人也会发现 ..
发布时间：2020-05-12 18:47:17 Python