标签: message-queue

如果两个pthreads在"相同"时间调用msgsnd()函数,将消息发布到同一个消息队列会发生什么？

如果两个进程相同怎么办？它们是线程还是进程是否重要？

特别感兴趣的Linux 2.6.15-2.5#1 SMP PREEMPT Tue Sep 19 10:56:25 CDT 2006 x86_64 x86_64 x86_64 GNU/Linux

我有一个从msmq队列接收消息的方法.

我在msmq中有6个不同的队列,id就像一个接收消息的通用方法.这是工作,但我需要为每个队列编写6个方法.我想让它更通用.

public List<QueMessage> getMessagesFromObj1Queue()
{
    List<QueMessage> messageList = new List<QueMessage>();

    QueObj1 que = new QueObj1();

    while (que.ReceiveAll().Count > 0)
    {
        varmessage = que.Receive(new TimeSpan(0, 1, 0));
        messageList.Add(message);
    }

    return messageList;
}

我有5个不同的对象,它只扩展了一个抽象类.下面的工作.

public List<QueMessage> getMessagesFromObj1Queue<T>(T que)
{
    List<QueMessage> messageList = new List<QueMessage>();

    while (que.ReceiveAll().Count > 0)
    {
        varmessage = que.Receive(new TimeSpan(0, 1, 0));
        messageList.Add(message);
    }

    return messageList;
}

以上不起作用

怎么解决这个问题？

所以,我正在编写一个类的代码,这个类将进入一个将被其他人使用的库.该类将拦截并处理传入的消息(详细信息并不重要,但它使用的是activemq-cpp库).这个消费者类的概要是

class MessageConsumer {
    ...
    public:
        void runConsumer();
        virtual void onMessage(const Message* message);
}

其中,runConsumer()建立连接并开始监听和onMessage()接收消息时被调用.

我的问题是:使用此代码的人将各自拥有处理不同消息的方式.如何保持MessageConsumer通用但提供这种灵活性,同时保持代码简单？

两种选择:

• 他们应该继承MessageConsumer自己的新课onMessage()吗？
• 他们应该将指针传递给消息处理函数MessageConsumer吗？

您怎么看？哪个选项更好,为什么？

谢谢!

为什么在POSIX中创建消息队列时出现"无法分配内存"的错误？

也许我在这里问错了问题.

我正在尝试做的事情:多个生产者将动态类别中的数据推送到命名交换中.多个消费者需要从这些动态命名的队列中获取这些数据并对其进行操作.

问题是我看到的所有消费示例都要求消费者/订阅具有特定的队列名称,而我的消费者不知道队列的名称,他们也不需要知道这一点.

我为什么要这样做？两个原因:

1. 我一次可以拥有N个这些动态类别.我希望队列能够平等地为这些类别提供服务.目前我们有一个队列(msmq),它接受所有这些类别并在FIFO中提供它们(这意味着某些类别在一段时间内处于饥饿状态).

2. 能够平等地服务所有类别,而不是fifo,让我想出有趣的QoS(默认情况下,我知道Rabbit将循环服务消息).

所以,回到我的问题(如果它有效):是否可以消耗队列中的消息？

我正处于一个项目的中间,我们将基于一系列基于OSGi服务的定制技术迁移一个主要的软件系统.为此,我们可能需要一种与OSGi服务兼容的消息总线.

• 同步和异步传递
• 仅限点对点
• 保证交付 - 最好通过文件持久化
• 从同一客户端(异步模式)订购的严格消息,但必须来自不同的客户端
• 支持进程到进程和节点到节点的良好但不严格要求

开源解决方案将是首选,但不是必需的.

我查看了eventbus(按照/sf/answers/136741741/中的建议),但似乎效果不佳.

那么问题是,哪些技术与上述相匹配？

我有一个严重多线程的Delphi 6应用程序.我有一个我创建的组件,它来自TWinControl.当我第一次构建它时,我使用了一个隐藏窗口,它是WndProc来处理使用AllocateHwnd()分配的消息.最近我开始在我的代码中清理WndProc并决定删除辅助WndProc().我更改了组件以覆盖基类WndProc()方法,并从那里进行自定义窗口消息处理.在那个WndProc()中,我首先调用了继承的处理程序,然后处理了我的自定义消息(WM_USER偏移),如果找到我的一个自定义消息并将其处理,则将消息Result字段设置为1.

一个重要的说明.我在WndProc()覆盖的顶部放置了一行代码,如果当前线程id不是VCL主线程,则抛出异常.我想确保WndProc()仅在主VCL线程的上下文中执行.

在完成这个并运行我的程序后,我遇到了一些看起来很奇怪的东西.我正常运行我的程序并完成各种任务而没有错误.然后,当我转到与我的TWinControl后代位于同一页面的TMemo控件时.如果我在TMemo控件内部单击,则在我的WndProc()覆盖中触发主线程检查.我设置了断点,当我进入调用堆栈时,我的WndProc()覆盖上方没有任何内容.

据我所知,我已经仔细检查过,我没有明确调用WndProc()覆盖.那不是我做过的事.但鉴于我的TWinControl组件已经在主VCL线程上创建,就像所有其他组件一样,我无法理解WndProc()覆盖如何在后台线程的上下文中执行,尤其是在像UI这样的UI操作时鼠标点击会发生.我理解我的WndProc()是如何绑定到TMemo控件的,因为所有子窗口都挂在顶级窗口WndProc()上,至少这是我的理解.但由于所有组件窗口都是在主VCL线程上创建的,因此它们的所有消息队列也应该在该上下文中执行,对吧？

那么我可以创建什么样的情况来使我的WndProc()运行,有时只在后台线程的上下文中运行？

我创建了一个通过MSMQ发送消息但在执行时获得异常的函数.以下是我的功能.

public void SendMessageToQueue(ChessQueue chessQueue)
{
    MessageQueue queue = null;
    Message m = null;
    if (!MessageQueue.Exists(".\\Private$\\" + chessQueue.QueueName))
    {
        queue = new MessageQueue(".\\Private$\\chessqueue");
        chessQueue.Messages = new List<MessageObject>();
        chessQueue.Messages.Add(chessQueue.Message);
        queue.Formatter = new BinaryMessageFormatter();
        m = new Message();
        m.Body = chessQueue;
    }
    else
    {
        queue = new MessageQueue(".\\Private$\\" + chessQueue.QueueName);
        queue.Formatter = new BinaryMessageFormatter();
        m = queue.Receive();
        ChessQueue ExistingChessQueue = m.Body as ChessQueue;
        ExistingChessQueue.Messages.Add(chessQueue.Message);
        m.Body = ExistingChessQueue;
    }            
    queue.Send(m);
    // Getting Exception at this Line
}

例外: - 队列不存在或您没有足够的权限来执行操作.

此外,我无法在"计算机管理"下打开"消息队列"的安全选项卡.请参见附件截图.

我尝试在私人手动下创建消息队列,系统允许我这样做.见下文

下面是mmc跨度.

我是MQTT的初学者，但令我困惑的是它的基本定义

MQTT是基于发布-订阅的“轻量级”消息传递协议。

根据我以前对MQ（消息队列）的理解，MQ和MQTT在我看来听起来非常相同。谁能详细说明MQ和MQTT之间的真正区别是什么以及它们的用例？谢谢！！

CQRS/ES架构中的有界上下文之间的通信是通过事件实现的; context A生成事件作为对命令的响应,然后通过事件总线(消息队列)将这些事件转发到上下文B.

或者......您可以将事件存储在eventstore中(属于上下文A).或者......两者(存储和转发).

我的问题是:从上下文B,我应该从上下文存储中提取事件吗？或者只是消费通过事件总线推送的事件？

我倾向于拉动方式.因为那时我们可以在上下文B中进行一些追赶.相反,在推送方法中,上下文B可能不知道在B遇到停机时传递的事件.

所以......这意味着......当我们有eventstore时,我们可以简单地忘记消息队列(似乎是多余的)？

或者我在这里遗漏了什么？