标签: message-queue

很多时候我使用'mqsc'从脚本文件创建MQ队列管理器,但我不知道如何生成脚本文件.

谢谢

我无法让我的应用响应用户操作.因此,我想在多个线程之间拆分消息处理.

我可以简单地创建多个线程,从所有线程中读取相同的消息队列,并让哪个线程能够处理每个消息？

如果是这样,怎么办呢？

如果没有,你能提出另一种解决这个问题的方法吗？

我想知道在使用和处理消息队列时你的最佳做法是什么.如果特别是在处理部分中有代码以便可视化您的概念,我也将不胜感激.语言是C#或任何.NET语言都可以.正在使用的队列是Microsoft消息队列.

目前我遇到的错误是我们的系统资源不足但我们的硬件规格内存和磁盘空间很高.

我遇到的具体错误消息是:资源不足,无法执行操作.

非常感谢任何有关此事的重要或相关帮助.在此先感谢您的时间.

有没有人有一些示例代码显示序列化std :: string的管道,通过boost :: interprocess :: message_queue发送它并再次将其取回？

使用以下代码(我已经模糊了实际的凭据):

CloudStorageAccount cloudStorageAccount = new CloudStorageAccount(new StorageCredentials(username, key), true);
CloudQueueClient clnt = cloudStorageAccount.CreateCloudQueueClient();

string logQueueReference = "log2";
CloudQueue queue = clnt.GetQueueReference(logQueueReference);

queue.CreateIfNotExists();

生成以下请求:

HEAD /log2?comp=metadata&timeout=90 HTTP/1.1
x-ms-version: 2012-02-12
User-Agent: WA-Storage/2.0.6.0
x-ms-date: Tue, 29 Apr 2014 13:26:29 GMT
Authorization: SharedKey username:transformedkey
Host: username.queue.core.windows.net

并返回以下响应:

HTTP/1.1 403 Server failed to authenticate the request. Make sure the value of Authorization header is formed correctly including the signature.
Transfer-Encoding: chunked
Server: Microsoft-HTTPAPI/2.0
x-ms-request-id: 0cc84a81-73e1-4a8c-bf16-098af2b21149
Date: Tue, 29 Apr 2014 15:26:29 GMT

我双重检查了凭证.它们是从manage.windowsazure.com的对话框中复制粘贴的.我在这里错过了什么？

消息传递提供程序的一个选项是消息队列,它提供FIFO排序,即队列.为什么消息的排序很重要？我想知道是不是因为消息的优先级或类似的东西.如果有人能用例子解释,我将不胜感激.

我已经在RabbitMQ for Java,Spring等中找到了很多设置消息优先级的例子,但到目前为止我还没有找到如何在PHP中实现它.

事实上,该$channel->basic_publish()函数似乎不支持提供其他参数(https://github.com/videlalvaro/php-amqplib/blob/master/PhpAmqpLib/Channel/AMQPChannel.php),即使您可以在RabbitMQ中执行此操作GUI.

有没有人在PHP中使用RabbitMQ的消息优先级？

我想使用protobuf而不是Json在消息队列之间进行通信。

当只有一条原始消息时，我知道如何处理。

假设原始文件为：

//person.proto
syntax = "proto3";

option java_outer_classname = "PersonProto";

message Person {
    int32 id = 2;
    string name = 1;
    string email = 3;
}

现在，我可以使用以下方法处理它：

PersonProto.Person person = PersonProto.Person.newBuilder()
        .setEmail("123@test.com")
        .setId(1)
        .setName("name-test")
        .build();

byte[] bytes = person.toByteArray();

//Transfer from publisher to consumer between message queue.

//I can deserialise it, because i know the proto message is Person.
PersonProto.Person.parseFrom(bytes);

但是，如果有多个原始消息怎么办？

假设还有另一个原始消息称为Address。

syntax = "proto3";

option java_outer_classname = "PersonProto";

message Person {
    int32 id = 2;
    string …

有一个TFrame后代类如下:

TCustomHistoryFrame = class(TFrame)
  tbMainFunction: TToolBar;
  // there's more, of course, but that is irrelevant to the question
end;

我注意到,当我Enabled将此框架的属性设置为时False,其组件tbMainFunction将不会(视觉上)被禁用.

我的第一个想法是覆盖虚方法TControl.SetEnabled.看看它的实现,我看到它在CM_ENABLEDCHANGED实际值不同时执行控制消息.

我不确定如何以Enabled正确的方式将框架的状态应用到工具栏.
常见的做法是什么？由于这个问题主要是以观点为基础的,所以让我重新说一下:

无论是重写SetEnabled还是处理都有哪些优点和缺点CM_ENABLEDCHANGED？

事情,我想到了自己:

• 覆盖SetEnabled:
  • 我必须重新检查新值是否与旧值不同.这将是一种冗余.(这对性能没有显着影响,但是 - 叫我一个头发分裂器 - 闻我.)
• 处理CM_ENABLEDCHANGED:
  • 如何维护此消息的继承代码？在(TControl和)中有(至少)此消息的实现TWinControl.如果我在课堂上处理这些信息,他们还会被执行TCustomHistoryFrame吗？

我有3个节点（nodes0，node1，node2）具有复制因子2的Kafka集群（broker0，broker1，broker2）和Zookeeper（使用Kafka tar打包的zookeeper）在不同的节点（node 4）上运行。

在启动zookeper之后，我又启动了代理0，然后启动了其余节点。在代理0日志中可以看到它正在读取__consumer_offsets，似乎它们存储在代理0中。以下是示例日志：

卡夫卡版本：kafka_2.10-0.10.2.0

    2017-06-30 10:50:47,381] INFO [GroupCoordinator 0]: Loading group metadata for console-consumer-85124 with generation 2 (kafka.coordinator.GroupCoordinator)
    [2017-06-30 10:50:47,382] INFO [Group Metadata Manager on Broker 0]: Finished loading offsets from __consumer_offsets-41 in 23 milliseconds. (kafka.coordinator.GroupMetadataManager)
    [2017-06-30 10:50:47,382] INFO [Group Metadata Manager on Broker 0]: Loading offsets and group metadata from __consumer_offsets-44 (kafka.coordinator.GroupMetadataManager)
    [2017-06-30 10:50:47,387] INFO [Group Metadata Manager on Broker 0]: Finished loading offsets from __consumer_offsets-44 in 5 milliseconds. (kafka.coordinator.GroupMetadataManager)
    [2017-06-30 10:50:47,387] INFO [Group Metadata Manager on …