标签: message-queue

我正在学习IPC编程。作为其中的一部分，我尝试了以下两个代码来了解消息队列......

消息队列创建者或消息发送者

struct my_msgbuf {
    long mtype;
    char mtext[200];
};

int main(void)
{
    struct my_msgbuf buf;
    int msqid;
    key_t key;
if ((key = ftok("kirk.c", 'B')) == -1) {
    perror("ftok");
    exit(1);
}

if ((msqid = msgget(key, 0644 | IPC_CREAT)) == -1) {
    perror("msgget");
    exit(1);
}

printf("Enter lines of text, ^D to quit:\n");

buf.mtype = 1; /* we don't really care in this case */

while(fgets(buf.mtext, sizeof buf.mtext, stdin) != NULL) {
    int len = strlen(buf.mtext);

    /* ditch newline at end, if …

我正在研究MFC C++应用程序.我正在开发一个SystemMenu属性设置为的对话框FALSE,因此它没有最大化的能力.我想处理标题栏上的双击消息.我怎样才能做到这一点？

编辑:

我希望这次对每个人都清楚.我有一个没有系统菜单(和系统按钮或图标)的对话框.当用户双击该对话框的标题栏时,我希望程序调用函数x();.

如果我阅读PostMessage API 的描述,它有这句话:

系统仅对系统消息进行编组(范围为0到(WM_USER-1)).要将其他消息(那些> = WM_USER)发送到另一个进程,您必须执行自定义编组.

我很好奇那个"消息编组"是什么？

我需要编写一个侦听消息队列（消费者）并将其读取的数据发送到数据库的服务器，以及另一个将信息（生产者）发布到该队列的服务器。

我正在关注Spring+JMS 上的官方 spring 参考。

我不明白以下内容：

1. JMS和ActiveMQ有什么关系？
2. 其中哪一个真正实现了消息队列？

3. 在我看到的例子中：

   FileSystemUtils.deleteRecursively(new File("activemq-data"));
   

   Run Code Online (Sandbox Code Playgroud)

   作为删除队列的一种手段。

   队列的数据是否保存在文件中？

4. 如果队列是由文件系统维护的，我如何将我的JMS服务器扩展到多于一台计算机（服务器）

谢谢！

以下代码注册一个低级鼠标钩子来全局监视鼠标事件。
这是我能得到的最简单的工作示例。
用VC++2010编译：cl test.cpp /link /entry:mainCRTStartup /subsystem:windows

#include <windows.h>

HWND label1 ;

//THE HOOK PROCEDURE
LRESULT CALLBACK mouseHookProc(int aCode, WPARAM wParam, LPARAM lParam){
    static int msgCount = 0 ;
    static char str[20] ;
    SetWindowText( label1, itoa(++msgCount, str, 10) ) ;
    return CallNextHookEx(NULL, aCode, wParam, lParam) ;
}

int main(){
    /**///  STANDARD WINDOW CREATION PART //////////////////////////////////////////////////////
    /**/        
    /**/    WNDCLASSEX classStruct = { sizeof(WNDCLASSEX), 0, DefWindowProc, 0, 0, GetModuleHandle(NULL), NULL,
    /**/                            LoadCursor(NULL, IDC_ARROW), HBRUSH(COLOR_BTNFACE+1), NULL, "winClass", NULL } ;
    /**/    RegisterClassEx(&classStruct) …

我一直在阅读 Azure Cosmos DB（新的文档数据库），并注意到它允许在数据写入数据库时​​执行 Azure 函数。

通常，我会写入服务总线，然后使用 Azure 函数处理消息，并将消息存储在文档数据库中以供历史记录。

我需要一些有关 CosmoDB 良好实践的帮助

当 msgget 运行时，我收到一个错误，当它到达 msgget 行时，我的代码给我一个返回：“:Function not Implemented”。我尝试了很多选项，我在 Windows 10 上运行 UBUNTU 请帮忙，这是我的代码和终端窗口结果：代码：

#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <string.h>
#include <sys/ipc.h>
#include <fcntl.h>
#include <sys/msg.h>
#include <sys/types.h>
#include "msg.h"
void main(int argc, char *argv[]){
    int msgQid;
    int flg = IPC_CREAT | 0644;
    key_t k;
    message_buf sndbuf;
    message_buf rdbuf;
    size_t buf_lng;
    k= atoi(argv[2]);
    if(argc == 3){
        if(k>1){
            if(strcmp(argv[1],"-c")==0 || strcmp(argv[1],"-C")==0){
                //Create Message Queue
                if((msgQid=msgget(k, flg))<0){
                    perror("msgget: EXITING...\n");
                    exit(EXIT_FAILURE);
                }
                else{
                    printf("Queue Created: %d\n",msgQid);
                }
                exit(0);
            }
            else if(strcmp(argv[1],"-d")==0 || strcmp(argv[1],"-D")==0){ …

这是我运行 main 时遇到的错误。我不太明白为什么第 44 行有问题：channel.basicConsume(Q,true,consumer); 我的目标是尝试将收到的消息存储到可以在其他文件中使用的变量中。

The error is: Exception in thread "main" java.io.IOException
at com.rabbitmq.client.impl.AMQChannel.wrap(AMQChannel.java:105)
at com.rabbitmq.client.impl.AMQChannel.wrap(AMQChannel.java:101)
at com.rabbitmq.client.impl.ChannelN.basicConsume(ChannelN.java:1255)
at com.rabbitmq.client.impl.recovery.AutorecoveringChannel.basicConsume(AutorecoveringChannel.java:471)
at com.rabbitmq.client.impl.recovery.AutorecoveringChannel.basicConsume(AutorecoveringChannel.java:461)
at com.rabbitmq.client.impl.recovery.AutorecoveringChannel.basicConsume(AutorecoveringChannel.java:456)
at Recv.recv(Recv.java:44)
at mainLaptop.main(mainLaptop.java:11)
Caused by: com.rabbitmq.client.ShutdownSignalException: channel error; protocol method: #method<channel.close>(reply-code=404, reply-text=NOT_FOUND - no queue 'Leonardo' in vhost '/', class-id=60, method-id=20)
at com.rabbitmq.utility.ValueOrException.getValue(ValueOrException.java:66)
at com.rabbitmq.utility.BlockingValueOrException.uninterruptibleGetValue(BlockingValueOrException.java:32)
at com.rabbitmq.client.impl.AMQChannel$BlockingRpcContinuation.getReply(AMQChannel.java:366)
at com.rabbitmq.client.impl.ChannelN.basicConsume(ChannelN.java:1253)
... 5 more

这是我的 Recv 文件代码

    public class Recv 
    {

public static String recv(String ip, String Q) throws Exception 
{

    ConnectionFactory factory = new …

如何在 kubernetes 中为 kafka、amqp 或任何其他可伸缩的消息代理部署消息使用者？我的假设是消费者运行一个循环来拉取消息。

我希望 kubernetes 在许多消息到达代理队列时创建更多 pod，并在队列中到达的消息太少时删除一些 pod。

哪个组件拥有结束pods的主动权？Pod 本身是因为它无法从队列中获取消息？还是 kubernetes 因为 pod 不消耗 cpu？

如果队列为空时任何 pod 结束，恐怕只要队列为空，pod 就会一直生和死。

我正在开发一个基于云的后端 HTTP 服务，该服务将公开用于与一些本地系统集成。客户端系统是由外部供应商定制的，它们是具有自己的数据库的后端系统。这些系统部署在我们客户的公司中，我们无权访问它们，也无法控制它们。我们向供应商提供我们的 API 规范，他们实施客户端代码。

我的服务与客户端交换的数据格式基于XML并遵循一定的标准。供应商用不同的编程语言实现他们的客户端系统，随着时间的推移，新的供应商将会出现。我希望尽可能多的客户能够使用我的服务。

我的大部分服务 API 都是类似 REST 的：它接收 HTTP 请求，处理它们，然后发回 HTTP 响应。

此外，我的服务积累了一些数据状态变化，需要定期将这些数据推送到客户端系统。由于以下限制，此用例似乎不适合传统的客户端-服务器 HTTP 请求-响应模型。

1. 由于业务的性质，客户端系统无法打开自己的 HTTP API 端点，因此我的服务无法与它们建立出站 HTTP 连接来传递数据状态通知。即使用 WebHooks 不是一种选择。

2. 同时，我的服务利益相关者需要记录确认数据状态通知已被客户端系统接受，因此像 Amazon SNS 这样的即发即忘系统似乎不适用。

我正在考虑解决这个问题的几种方法，但我不确定我是否错过了一些简单的选项或一些已经解决问题的技术。于是就有了这个问题。

问题文本已更新：选项移至我自己的答案。

相关问题和资源

• REST API，具有从服务器到客户端的主动推送通知
• 可以通过 Websocket 进行 ReST 吗？
• 我们可以使用 Web-Sockets 在微服务之间进行通信吗？
• grpc 和 websocket 有什么区别？哪一种更适合双向流连接？
• https://www.smashingmagazine.com/2018/02/sse-websockets-data-flow-http2/