1
#include <stdio.h>
2
#include <signal.h>
3
#include <event2/event.h>
4

5
static void ignore_sigpipe(void) {
6
    struct event_base *base = event_base_new();
7
    struct event *sigpipe = evsignal_new(base, SIGPIPE, NULL, NULL);
8
    event_add(sigpipe, NULL);
9

10
    // 或者直接使用系统调用
11
    signal(SIGPIPE, SIG_IGN);
12

13
    event_free(sigpipe);
14
    event_base_free(base);
15
}
16

17
// 更简单的方法
18
static void setup_signals(void) {
19
    // 忽略SIGPIPE
20
    signal(SIGPIPE, SIG_IGN);
21
}

1
#include <stdio.h>
2
#include <stdlib.h>
3
#include <string.h>
4
#include <signal.h>
5
#include <unistd.h>
6
#include <arpa/inet.h>
7
#include <event2/buffer.h>
8
#include <event2/bufferevent.h>
9
#include <event2/listener.h>
10
#include <event2/event.h>
11

12
#define PORT 8080
13

14
static struct event_base *g_base = NULL;
15
static int g_reload_config = 0;
16

17
static void read_cb(struct bufferevent *bev, void *ctx) {
18
    struct evbuffer *input = bufferevent_get_input(bev);
19
    struct evbuffer *output = bufferevent_get_output(bev);
20
    evbuffer_add_buffer(output, input);
21
}
22

23
static void event_cb(struct bufferevent *bev, short events, void *ctx) {
24
    if (events & (BEV_EVENT_EOF | BEV_EVENT_ERROR)) {
25
        bufferevent_free(bev);
26
    }
27
}
28

29
static void accept_cb(struct evconnlistener *listener,
30
    evutil_socket_t fd, struct sockaddr *addr, int socklen, void *ctx) {
31

32
    struct event_base *base = evconnlistener_get_base(listener);
33
    struct bufferevent *bev = bufferevent_socket_new(base, fd, BEV_OPT_CLOSE_ON_FREE);
34

35
    bufferevent_setcb(bev, read_cb, NULL, event_cb, NULL);
36
    bufferevent_enable(bev, EV_READ | EV_WRITE);
37
}
38

39
static void sigint_cb(evutil_socket_t fd, short events, void *arg) {
40
    printf("\nCaught SIGINT, shutting down gracefully...\n");
41
    event_base_loopexit(g_base, NULL);
42
}
43

44
static void sigterm_cb(evutil_socket_t fd, short events, void *arg) {
45
    printf("\nCaught SIGTERM, shutting down...\n");
46
    event_base_loopexit(g_base, NULL);
47
}
48

49
static void sighup_cb(evutil_socket_t fd, short events, void *arg) {
50
    printf("\nCaught SIGHUP, reloading configuration...\n");
51
    g_reload_config = 1;
52
    // 在实际应用中，这里可以重新读取配置文件
53
}
54

55
int main() {
56
    // 忽略SIGPIPE
57
    signal(SIGPIPE, SIG_IGN);
58

59
    g_base = event_base_new();
60

61
    // 设置信号处理
62
    struct event *sigint = evsignal_new(g_base, SIGINT, sigint_cb, NULL);
63
    struct event *sigterm = evsignal_new(g_base, SIGTERM, sigterm_cb, NULL);
64
    struct event *sighup = evsignal_new(g_base, SIGHUP, sighup_cb, NULL);
65

66
    event_add(sigint, NULL);
67
    event_add(sigterm, NULL);
68
    event_add(sighup, NULL);
69

70
    // 创建监听器
71
    struct sockaddr_in sin;
72
    memset(&sin, 0, sizeof(sin));
73
    sin.sin_family = AF_INET;
74
    sin.sin_port = htons(PORT);
75
    sin.sin_addr.s_addr = htonl(INADDR_ANY);
76

77
    struct evconnlistener *listener = evconnlistener_new_bind(g_base,
78
        accept_cb, NULL, LEV_OPT_REUSEABLE | LEV_OPT_CLOSE_ON_FREE,
79
        -1, (struct sockaddr *)&sin, sizeof(sin));
80

81
    if (!listener) {
82
        fprintf(stderr, "Failed to create listener\n");
83
        return 1;
84
    }
85

86
    printf("Server running on port %d\n", PORT);
87
    printf("Press Ctrl+C to shutdown\n");
88
    printf("Send SIGHUP to reload config (kill -HUP %d)\n", getpid());
89

90
    event_base_dispatch(g_base);
91

92
    printf("Cleaning up...\n");
93

94
    evconnlistener_free(listener);
95
    event_free(sigint);
96
    event_free(sigterm);
97
    event_free(sighup);
98
    event_base_free(g_base);
99

100
    printf("Server shutdown complete\n");
101
    return 0;
102
}