Cmakelist.txt之Liunx-rabbitmq

1.cmakelist.txt

2. cmake_minimum_required(VERSION 3.16)
4. ​
5. project(rabbitmq_linux_test LANGUAGES C)
7. ​
8. add_library(examples-common OBJECT)
9. target_sources(examples-common PRIVATE
10.   utils.h
11.   utils.c)
12. if(WIN32)
13.   target_sources(examples-common PRIVATE win32/platform_utils.c)
14. else()
15.   target_sources(examples-common PRIVATE unix/platform_utils.c)
16. endif()
17. target_link_libraries(examples-common PRIVATE rabbitmq)
19. ​
20. add_executable(rabbitmq_linux_test main.c)
22. ​
24. ​
25. target_link_libraries(rabbitmq_linux_test examples-common rabbitmq)
27. ​
29. ​
30. include(GNUInstallDirs)
31. install(TARGETS rabbitmq_linux_test
32.    LIBRARY DESTINATION ${CMAKE_INSTALL_LIBDIR}
33.    RUNTIME DESTINATION ${CMAKE_INSTALL_BINDIR}
34. )

复制代码

3. ​

复制代码

2.测试代码

2. // Copyright 2007 - 2021, Alan Antonuk and the rabbitmq-c contributors.
3. // SPDX-License-Identifier: mit
5. #include <stdint.h>
6. #include <stdio.h>
7. #include <stdlib.h>
8. #include <string.h>
10. #include <rabbitmq-c/amqp.h>
11. #include <rabbitmq-c/tcp_socket.h>
13. #include "utils.h"
15. #define SUMMARY_EVERY_US 1000000
17. static void send_batch(amqp_connection_state_t conn, char const *queue_name,
18.                        int rate_limit, int message_count) {
19.     uint64_t start_time = now_microseconds();
20.     int i;
21.     int sent = 0;
22.     int previous_sent = 0;
23.     uint64_t previous_report_time = start_time;
24.     uint64_t next_summary_time = start_time + SUMMARY_EVERY_US;
26.     char message[256];
27.     amqp_bytes_t message_bytes;
29.     for (i = 0; i < (int)sizeof(message); i++) {
30.         message[i] = i & 0xff;
31.     }
33.     message_bytes.len = sizeof(message);
34.     message_bytes.bytes = message;
36.     for (i = 0; i < message_count; i++) {
37.         uint64_t now = now_microseconds();
39.         die_on_error(amqp_basic_publish(conn, 1, amqp_cstring_bytes("amq.direct"),
40.                                         amqp_cstring_bytes(queue_name), 0, 0, NULL,
41.                                         message_bytes),
42.                      "Publishing");
43.         sent++;
44.         if (now > next_summary_time) {
45.             int countOverInterval = sent - previous_sent;
46.             double intervalRate =
47.                 countOverInterval / ((now - previous_report_time) / 1000000.0);
48.             printf("%d ms: Sent %d - %d since last report (%d Hz)\n",
49.                    (int)(now - start_time) / 1000, sent, countOverInterval,
50.                    (int)intervalRate);
52.             previous_sent = sent;
53.             previous_report_time = now;
54.             next_summary_time += SUMMARY_EVERY_US;
55.         }
57.         while (((i * 1000000.0) / (now - start_time)) > rate_limit) {
58.             microsleep(2000);
59.             now = now_microseconds();
60.         }
61.     }
63.     {
64.         uint64_t stop_time = now_microseconds();
65.         int total_delta = (int)(stop_time - start_time);
67.         printf("PRODUCER - Message count: %d\n", message_count);
68.         printf("Total time, milliseconds: %d\n", total_delta / 1000);
69.         printf("Overall messages-per-second: %g\n",
70.                (message_count / (total_delta / 1000000.0)));
71.     }
72. }
74. int main(int argc, char const *const *argv) {
75.     // char const *hostname;
76.     // int port, status;
77.     // int rate_limit;
78.     // int message_count;
79.     amqp_socket_t *socket = NULL;
80.     amqp_connection_state_t conn;
82.     // if (argc < 5) {
83.     //     fprintf(stderr,
84.     //             "Usage: amqp_producer host port rate_limit message_count\n");
85.     //     return 1;
86.     // }
88.     // hostname = argv[1];
89.     // port = atoi(argv[2]);
90.     // rate_limit = atoi(argv[3]);
91.     // message_count = atoi(argv[4]);
93.     char const *hostname = "localhost";// 直接定义主机名，这里假设为localhost
94.     int port = 5672; // 直接定义端口号，RabbitMQ默认端口是5672
95.     int rate_limit = 100; // 直接定义速率限制，这里假设为100
96.     int message_count = 1000; // 直接定义消息数量，这里假设为1000
97.     int status;
99.     conn = amqp_new_connection();
101.     socket = amqp_tcp_socket_new(conn);
102.     if (!socket) {
103.         die("creating TCP socket");
104.     }
106.     status = amqp_socket_open(socket, hostname, port);
107.     if (status) {
108.         die("opening TCP socket");
109.     }
111.     die_on_amqp_error(amqp_login(conn, "/", 0, 131072, 0, AMQP_SASL_METHOD_PLAIN,
112.                                  "guest", "guest"),
113.                       "Logging in");
114.     amqp_channel_open(conn, 1);
115.     die_on_amqp_error(amqp_get_rpc_reply(conn), "Opening channel");
117.     send_batch(conn, "test queue", rate_limit, message_count);
119.     die_on_amqp_error(amqp_channel_close(conn, 1, AMQP_REPLY_SUCCESS),
120.                       "Closing channel");
121.     die_on_amqp_error(amqp_connection_close(conn, AMQP_REPLY_SUCCESS),
122.                       "Closing connection");
123.     die_on_error(amqp_destroy_connection(conn), "Ending connection");
124.     return 0;
125. }

复制代码

3. ​

复制代码

3.结果