标签: message-queue

我无法在 C 中创建和打开消息队列。

我尝试了各种函数参数mq_open()，但没有任何结果。

我检查过一些类似的问题，但未能找到解决方案。

我不确定我做错了什么。

我收到mq_open: Invalid argument错误。

// Create the message queue
mqd_t mq;

// Open the message queue
mq = mq_open(argv[1], O_RDONLY | O_CREAT, 0666, NULL);
if (mq == (mqd_t)-1) {
       perror("mq_open");
       exit(EXIT_FAILURE);
}

我随意给它命名为“a”。

我正在处理一个包含消息队列概念的项目.现在该项目采用PHP,并且在邮件发送或邮件发送方面造成更多延迟.所以我建议用Perl或Python脚本开发一个消息队列.你能否建议PHP或Perl或Python哪个最好？

在大学里,我们研究了IBM的MQ系列,这是一个可以发送消息的中间件,它将被保存在一个队列中.MQ Series具有所谓的保证消息传递,这意味着如果您将消息发送到队列,即使包含队列消息的服务器已关闭并再次打开,队列也将保持不变.

Microsoft是否有与C#和Sharepoint一起使用的类似技术？

我对需要消息队列的系统有一些要求:

1. 订户应获得个人队列.
2. 当用户断开连接时,不应删除各个队列
3. 如果订户失去连接,则订户应能够重新连接到自己的队列
4. 只有订户才能使用分配给它的队列
5. 很高兴:队列在服务器重启后仍然存在

可以使用RabbitMQ来实现这一点,在这种情况下如何实现？

我正在尝试使用标准SendMessageW() 方法从控制台应用程序取消静音.但是,我们有自己的应用程序作为shell运行,而不是explorer.exe.当我试图取消静音时,没有任何反应; 但是一旦我启动资源管理器它就可以了.是否必须运行资源管理器才能发送消息？
码:

private const int APPCOMMAND_VOLUME_MUTE = 0x80000; 
private const int WM_APPCOMMAND = 0x319;
SendMessageW(Process.GetCurrentProcess().MainWindowHandle, WM_APPCOMMAND, Process.GetCurrentProcess().MainWindowHandle, (IntPtr)APPCOMMAND_VOLUME_MUTE);

返回值为SendMessageW()0.
如果需要资源管理器,是否有人知道另一种取消静音方法？

Side Note
我刚刚尝试使用vbs:

Set WshShell = CreateObject("WScript.Shell")
WshShell.SendKeys(chr(&hAD))

并得到了相同的结果.只有在explorer.exe运行时才取消静音.

我正在设计一个 REST API，它根据此处详细介绍的异步设计工作。我正在使用 RabbitMQ 对初始请求进行排队 - 因此客户端发出调用，接收响应202 Accepted，并且作业由服务器排队。为了使客户端可以获得任务的状态更新（“完成百分比”），我们有一个辅助队列资源，就像链接的文章中一样。

鉴于每个任务都有自己的队列资源，似乎每个任务都需要一个临时 RabbitMQ 队列。我想知道这是否是一个明智的设计选择，尽管我看不到任何其他选择。这似乎不太高效，而且我对像这样创建大量临时队列的可能性感到不安，特别是因为我看不到一种方法来保证它们全部被清理（尽管 RabbitMQ 具有自动删除功能） 。在使用 RabbitMQ 之前，我使用 SQS 来实现此目的，并且对这方面可能发生的情况有痛苦的经验。

我注意到，对于那些使用 RPC 风格的 RabbitMQ 的人来说，类似类型的队列管理已经很熟悉了。然而，还有可能的替代方案吗？

我正在建立一个云系统,我有两个应用程序,包括完整功能的服务器应用程序,以及仅包含输入法的客户端应用程序,所以我在客户分支中安装客户端应用程序作为本地应用程序,

我希望在本地保存模型后覆盖应用程序中的任何模型,我将调用芹菜任务将此模型添加到队列中以确保它将到达,即使互联网已关闭,我将重试直到互联网起步,

现在我希望最佳实践能够以通用的方式对任何模型进行操作

我有两个选择

1-这样的覆盖保存方法

def save(self, *args, **kwargs):
    super(Model, self).save(*args, **kwargs)
    save_task.delay(self)

或使用这样的信号

post_save.connect(save-task.delay, sender=Model)

哪一个是最佳实践,我可以为这个项目的所有模型制作泛型？

我希望有一个环形缓冲区队列,它将接收对象并将它们从一个线程池中的多个线程分布到一个生产者中,然后分配给多个消费者时尚.如何使用disruptor模式实现这一目标？任何HelloDemux代码示例？谢谢!!!

当我尝试通过此 JS 连接到 Mosquitto 服务器时，收到此错误：

WebSocket connection to 'ws://xx.xxx.xxx.xxx:1883/mqtt' failed: Error during WebSocket handshake: net::ERR_CONNECTION_RESET 

我从控制台尝试过，它工作正常。我尝试使用 Java 客户端作为提供者和消费者，它工作正常。所以我无法理解我该怎么做才能让它工作。

这是JS：

client = new Paho.MQTT.Client("xx.xxx.xxx.xxx", 1883, "clientId");

client.onConnectionLost = onConnectionLost;
client.onMessageArrived = onMessageArrived;

// connect the client
client.connect({onSuccess:onConnect});

这是 Java（工作）：

@Stateless
@LocalBean
public class PahoManager implements MqttCallback {

  MqttClient client;

  public void init() {
      try {
          client = new MqttClient("tcp://192.168.50.10:1883", "pahomqttpublish1");

          client.connect();
          client.subscribe("pahodemo/test");
      } catch (MqttException e) {
          e.printStackTrace();
      }
  }    

  public void doDemo()  {
    try {

      MqttMessage message = new MqttMessage(); …

我正在反向设计一些将消息发送到Amazon SQS队列的代码.我知道队列的名称,可以在我的AWS控制台中找到它.但是,我不知道订阅了什么队列.我想看看消息是如何处理的.有没有一种简单的方法可以找到它？我在控制台或CLI中看不到任何东西......我希望能有类似于rabbitmqctl的东西,它可以显示订阅者列表.

我们正在与 PubSub 合作，将多个系统相互集成。某些系统可能会将数据作为 JSON 推送到 PubSub，而其他系统则可以提取该数据并使用它。（注意：由于接收应用程序的其他限制，我们必须从 PubSub 拉取而不是推送到应用程序）每个拉取应用程序都会获得每个主题的自己的订阅者。

我注意到，如果触发过于频繁，PubSub 拉取不会获取队列中当前的所有数据。该问题最初发生在具有相应库的 Java Spring 应用程序中，但云控制台中的 gcloud 命令表现出相同的行为，因此我将仅使用该示例。我删除了 ack-id 和边框以使其适合此窗口。请注意，我不使用“--auto-ack”标志，因此队列应保持不变，没有其他系统从该订阅者中提取数据。

首先拉取（完整内容）： \nmax_binnewies@cloudshell:~ $ gcloud pubsub subscriptions pull testSubscriber --limit=100

\xe2\x94\x82    DATA   \xe2\x94\x82    MESSAGE_ID   \xe2\x94\x82 \n\xe2\x94\x82 4 - FOUR  \xe2\x94\x82 189640873208084 \xe2\x94\x82\n\xe2\x94\x82 5 - FIVE  \xe2\x94\x82 189636274179799 \xe2\x94\x82 \n\xe2\x94\x82 2 - TWO   \xe2\x94\x82 189638666587304 \xe2\x94\x82 \n\xe2\x94\x82 3 - THREE \xe2\x94\x82 189627470480903 \xe2\x94\x82  \n\xe2\x94\x82 1 - ONE   \xe2\x94\x82 189639207684195 \xe2\x94\x82\n

第二次拉动（只有一次）： \nmax_binnewies@cloudshell:~ $ gcloud pubsub subscriptions pull testSubscriber --limit=100

\xe2\x94\x82 …

我有我的自定义 WndProc，它应该根据我的 ImGui 菜单是否打开来处理输入。

if (Menu::isOpen) {
    ImGui_ImplWin32_WndProcHandler(hWnd, msg, wParam, lParam);
    if    (msg == WM_LBUTTONDOWN
        || msg == WM_LBUTTONUP
        || msg == WM_LBUTTONDBLCLK

        || msg == WM_MBUTTONDOWN
        || msg == WM_MBUTTONUP
        || msg == WM_MBUTTONDBLCLK

        || msg == WM_RBUTTONDOWN
        || msg == WM_RBUTTONUP
        || msg == WM_RBUTTONDBLCLK

        || msg == WM_XBUTTONDOWN
        || msg == WM_XBUTTONUP
        || msg == WM_XBUTTONDBLCLK
        || msg == WM_MOUSEFIRST) return 0;
}
return CallWindowProc((WNDPROC)Get().m_ulOldWndProc, hWnd, msg, wParam, lParam);

我的目标是在我的 ImGui 打开时防止只有鼠标点击进入后台。我注意到如果我不阻止 WM_MOUSEFIRST 通过，一些点击仍然偶尔会在应用程序中注册。我还注意到，当我阻止 WM_MOUSEFIRST 通过时，将鼠标悬停在应用程序中的内容上不起作用，我想这样做。我以为我可以通过检查 wParams …

我意识到这是一个奇怪的问题,但我正在编写一个演示文稿,我想讨论可视化API和非直观API之间的区别.直觉与函数名称,复杂签名等有关.

我使用JMS作为我的直观示例(特别是因为它是面向对象的,示例代码非常明显).

我正在寻找一个令人信服的丑陋示例,最好不要面向对象,理想情况下我可以复制一些hello-world代码.