yanglu 53c7922b03 改成can通讯 | hace 3 meses | |
---|---|---|
ctn | hace 3 meses | |
examples | hace 3 meses | |
src | hace 3 meses | |
test | hace 3 meses | |
.clang-format | hace 3 meses | |
.clang-format:Zone.Identifier | hace 3 meses | |
.gitignore | hace 3 meses | |
.gitignore:Zone.Identifier | hace 3 meses | |
LICENSE | hace 3 meses | |
LICENSE:Zone.Identifier | hace 3 meses | |
Makefile | hace 3 meses | |
Makefile:Zone.Identifier | hace 3 meses | |
README.md | hace 3 meses | |
README.md:Zone.Identifier | hace 3 meses | |
mongoose.c | hace 3 meses | |
mongoose.c:Zone.Identifier | hace 3 meses | |
mongoose.h | hace 3 meses | |
mongoose.h:Zone.Identifier | hace 3 meses |
Mongoose is a network library for C/C++. It implements event-driven non-blocking APIs for TCP, UDP, HTTP, WebSocket, MQTT. It is designed for connecting devices and bringing them online. On the market since 2004, used by vast number of open source and commercial products - it even runs on the International Space Station! Mongoose makes embedded network programming fast, robust, and easy. Features include:
mongoose.c
and mongoose.h
files to your source tree. See
exact stepsCreate a simple web server that serves a directory. The behavior of the HTTP server is specified by its event handler function:
#include "mongoose.h"
int main(void) {
struct mg_mgr mgr; // Declare event manager
mg_mgr_init(&mgr); // Initialise event manager
mg_http_listen(&mgr, "http://0.0.0.0:8000", fn, NULL); // Setup listener
for (;;) {
mg_mgr_poll(&mgr, 1000); // Run an infinite event loop
}
return 0;
}
// HTTP server event handler function
void fn(struct mg_connection *c, int ev, void *ev_data) {
if (ev == MG_EV_HTTP_MSG) {
struct mg_http_message *hm = (struct mg_http_message *) ev_data;
struct mg_http_serve_opts opts = { .root_dir = "./web_root/" };
mg_http_serve_dir(c, hm, &opts);
}
}
HTTP server implements a REST API that returns current time. JSON formatting:
static void fn(struct mg_connection *c, int ev, void *ev_data) {
if (ev == MG_EV_HTTP_MSG) {
struct mg_http_message *hm = (struct mg_http_message *) ev_data;
if (mg_http_match_uri(hm, "/api/time/get")) {
mg_http_reply(c, 200, "", "{%m:%lu}\n", MG_ESC("time"), time(NULL));
} else {
mg_http_reply(c, 500, "", "{%m:%m}\n", MG_ESC("error"), MG_ESC("Unsupported URI"));
}
}
}
MQTT client that subscribes to a topic aa/bb
and prints all incoming messages:
static void fn(struct mg_connection *c, int ev, void *ev_data) {
if (ev == MG_EV_MQTT_OPEN) {
struct mg_mqtt_opts opts = {.qos = 1, .topic = mg_str("aa/bb")};
mg_mqtt_sub(c, &opts);
} else if (ev == MG_EV_MQTT_MSG) {
struct mg_mqtt_message *mm = (struct mg_mqtt_message *) ev_data;
printf("Topic: %.*s, Message: %.*s",
mm->topic.len, mm->topic.ptr,
mm->data.len, mm->data.ptr);
}
}
We take security seriously:
Contributions are welcome! Please follow the guidelines below: