zoukankan      html  css  js  c++  java

  • C/S—心跳检测—heartbeat

    heartbeat-server.c

    点击(此处)折叠或打开

    1. // gcc heartbeat-server.c -o heartbeat-server
    2. // indent -npro -kr -i8 -ts8 -sob -l280 -ss -ncs -cp1 *
    3. /* heartbeat-server.c
    4.  *
    5.  * Copyright (c) 2000 Sean Walton and Macmillan Publishers. Use may be in
    6.  * whole or in part in accordance to the General Public License (GPL).
    7.  *
    8.  * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
    9.  * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
    10.  * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
    11.  * ARE DISCLAIMED. IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
    12.  * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
    13.  * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
    14.  * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
    15.  * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
    16.  * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
    17.  * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
    18.  * SUCH DAMAGE.
    19. */
    20. /*****************************************************************************/
    21. /*** heartbeat-server.c ***/
    22. /*** ***/
    23. /*** Demonstrates how to keep track of the server using a "heartbeat". If ***/
    24. /*** the heartbeat is lost, the connection can be reestablished and the ***/
    25. /*** session resumed. ***/
    26. /*****************************************************************************/
    27. #include <stdio.h>
    28. #include <stdlib.h>
    29. #include <unistd.h>
    30. #include <strings.h>
    31. #include <errno.h>
    32. #include <fcntl.h>
    33. #include <sys/socket.h>
    34. #include <resolv.h>
    35. #include <signal.h>
    36. #include <sys/wait.h>
    37. int client;
    38. struct sigaction act;
    39. /*---------------------------------------------------------------------
    40.     sig_handler - catch and send heartbeat.
    41.  ---------------------------------------------------------------------*/
    42. void sig_handler(int signum)
    43. {
    44.     if (signum == SIGURG) {
    45.         char c;
    46.         recv(client, &c, sizeof(c), MSG_OOB);
    47.         if (c == '?')
    48.             /* Are you alive? */
    49.             send(client, "Y", 1, MSG_OOB);    /* */
    50.     } else if (signum == SIGCHLD)
    51.         wait(0);
    52. }

    54. /*---------------------------------------------------------------------
    55.     servlet - process requests
    56.  ---------------------------------------------------------------------*/
    57. void servlet(void)
    58. {
    59.     int bytes;
    60.     char buffer[1024];
    61.     bzero(&act, sizeof(act));
    62.     act.sa_handler = sig_handler;
    63.     act.sa_flags = SA_RESTART;
    64.     sigaction(SIGURG, &act, 0);    /* connect SIGURG signal */
    65.     if (fcntl(client, F_SETOWN, getpid()) != 0)
    66.         perror("Can't claim SIGIO and SIGURG");
    67.     do {
    68.         bytes = recv(client, buffer, sizeof(buffer), 0);
    69.         if (bytes > 0)
    70.             send(client, buffer, bytes, 0);
    71.     }
    72.     while (bytes > 0);
    73.     close(client);
    74.     exit(0);
    75. }

    77. /*---------------------------------------------------------------------
    78.     main - set up client and begin the heartbeat.
    79.  ---------------------------------------------------------------------*/
    80. int main(int count, char *strings[])
    81. {
    82.     int sd;
    83.     struct sockaddr_in addr;
    84.     if (count != 2) {
    85.         printf("usage: %s <port> ", strings[0]);
    86.         exit(0);
    87.     }
    88.     bzero(&act, sizeof(act));
    89.     act.sa_handler = sig_handler;
    90.     act.sa_flags = SA_NOCLDSTOP | SA_RESTART;
    91.     if (sigaction(SIGCHLD, &act, 0) != 0)
    92.         perror("sigaction()");
    93.     sd = socket(PF_INET, SOCK_STREAM, 0);
    94.     bzero(&addr, sizeof(addr));
    95.     addr.sin_family = AF_INET;
    96.     addr.sin_port = htons(atoi(strings[1]));
    97.     addr.sin_addr.s_addr = INADDR_ANY;
    98.     if (bind(sd, (struct sockaddr *)&addr, sizeof(addr)) != 0)
    99.         perror("bind()");
    100.     listen(sd, 15);
    101.     for (;;) {
    102.         client = accept(sd, 0, 0);
    103.         if (client > 0) {
    104.             if (fork() == 0) {
    105.                 close(sd);
    106.                 servlet();
    107.             } else
    108.                 close(client);
    109.         } else
    110.             perror("accept()");
    111.     }
    112.     close(sd);
    113.     return 0;
    114. }
    heartbeat-client.c

    点击(此处)折叠或打开

    1. // gcc heartbeat-client.c -o heartbeat-client
    2. // indent -npro -kr -i8 -ts8 -sob -l280 -ss -ncs -cp1 *
    3. /* heartbeat-client.c
    4.  *
    5.  * Copyright (c) 2000 Sean Walton and Macmillan Publishers. Use may be in
    6.  * whole or in part in accordance to the General Public License (GPL).
    7.  *
    8.  * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
    9.  * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
    10.  * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
    11.  * ARE DISCLAIMED. IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
    12.  * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
    13.  * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
    14.  * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
    15.  * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
    16.  * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
    17.  * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
    18.  * SUCH DAMAGE.
    19. */
    20. /*****************************************************************************/
    21. /*** heartbeat-client.c ***/
    22. /*** ***/
    23. /*** Demonstrates how to keep track of the server using a "heartbeat". If ***/
    24. /*** the heartbeat is lost, the connection can be reestablished and the ***/
    25. /*** session resumed. ***/
    26. /*****************************************************************************/
    27. #include <stdio.h>
    28. #include <stdlib.h>
    29. #include <unistd.h>
    30. #include <string.h>
    31. #include <errno.h>
    32. #include <fcntl.h>
    33. #include <signal.h>
    34. #include <resolv.h>
    35. #include <netinet/tcp.h>
    36. #include <netinet/in.h>
    37. #include <arpa/inet.h>
    38. #include <sys/socket.h>

    40. #define DELAY 5            /*seconds */
    41. int serverfd, got_reply = 1;

    43. /*---------------------------------------------------------------------
    44.     sig_handler - if the single is OOB, set flag. If ALARM, send heartbeat.
    45.  ---------------------------------------------------------------------*/
    46. void sig_handler(int signum)
    47. {
    48.     if (signum == SIGURG) {
    49.         char c;
    50.         recv(serverfd, &c, sizeof(c), MSG_OOB);
    51.         got_reply = (c == 'Y');    /* Got reply */
    52.         fprintf(stderr, "[server is alive]");
    53.     } else if (signum == SIGALRM)
    54.         if (got_reply) {
    55.             send(serverfd, "?", 1, MSG_OOB);    /* Alive?? */
    56.             alarm(DELAY);    /* Wait a while */
    57.             got_reply = 0;
    58.         } else
    59.             fprintf(stderr, "Lost connection to server!");
    60. }

    62. /*---------------------------------------------------------------------
    63.     main - set up client and begin the heartbeat.
    64.  ---------------------------------------------------------------------*/
    65. int main(int count, char *strings[])
    66. {
    67.     struct sockaddr_in addr;
    68.     struct sigaction act;
    69.     int bytes;
    70.     char line[100];
    71.     if (count != 3) {
    72.         printf("usage: %s <addr> <port> ", strings[0]);
    73.         exit(0);
    74.     }
    75.     bzero(&act, sizeof(act));
    76.     act.sa_handler = sig_handler;
    77.     act.sa_flags = SA_RESTART;
    78.     sigaction(SIGURG, &act, 0);
    79.     sigaction(SIGALRM, &act, 0);
    80.     serverfd = socket(PF_INET, SOCK_STREAM, 0);
    81.     /*---claim SIGIO/SIGURG signals---*/
    82.     if (fcntl(serverfd, F_SETOWN, getpid()) != 0)
    83.         perror("Can't claim SIGURG and SIGIO");

    85.     bzero(&addr, sizeof(addr));
    86.     addr.sin_family = AF_INET;
    87.     addr.sin_port = htons(atoi(strings[2]));
    88.     inet_aton(strings[1], &addr.sin_addr);
    89.     if (connect(serverfd, (struct sockaddr *)&addr, sizeof(addr)) == 0) {
    90.         alarm(DELAY);
    91.         do {
    92.             gets(line);
    93.             printf("send [%s] ", line);
    94.             send(serverfd, line, strlen(line), 0);
    95.             bytes = recv(serverfd, line, sizeof(line), 0);
    96.         }
    97.         while (bytes > 0);
    98.     } else
    99.         perror("connect failed");
    100.     close(serverfd);
    101.     return 0;
    102. }






    <script>window._bd_share_config={"common":{"bdSnsKey":{},"bdText":"","bdMini":"2","bdMiniList":false,"bdPic":"","bdStyle":"0","bdSize":"16"},"share":{}};with(document)0[(getElementsByTagName('head')[0]||body).appendChild(createElement('script')).src='http://bdimg.share.baidu.com/static/api/js/share.js?v=89860593.js?cdnversion='+~(-new Date()/36e5)];</script>
    阅读(133) | 评论(0) | 转发(0) |
    0

    上一篇：Linux—Network—Socket—Programming—heartbeat—源代码

    下一篇：accept() returns the same socket descriptor

    相关热门文章
    给主人留下些什么吧！~~
    评论热议
  • 相关阅读:
    使用指针的误区之指针未初始化
    实验室react项目名词解释
    生活感悟之大学
    git 快速入门
    口才锻炼
    narcissus
    crest value &minimum
    factorial
    Str_turn
    array_x
  • 原文地址：https://www.cnblogs.com/ztguang/p/12649386.html
Copyright © 2011-2022 走看看