Linux で TCP 接続の最大数をテストする方法

/*
 * g++ -o test_epoll ./test_epoll.c
 */
#include <unistd.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <sys/epoll.h>
#include <netinet/in.h>
#include <arpa/inet.h>

#include <stdio.h>
#include <stdlib.h>
#include <文字列.h>
#include <errno.h>

int SetReuseAddr(int fd)
{
 整数 最適値 = 1;
 socklen_t optlen = sizeof(optval);
 setsockopt(fd, SOL_SOCKET, SO_REUSEADDR, &optval, optlen) を返します。
}

int メイン()
{
 int fd = socket(AF_INET, SOCK_STREAM, 0);
 int iRet = SetReuseAddr(fd);
 (iRet != 0) の場合
 {
 printf("SO_REUSEADDR の setsockopt が失敗しました。エラー:%s\n", strerror(iRet));
 iRet を返します。
 }

 構造体 sockaddr_in アドレス;
 memset(&addr, 0, sizeof(addr));
 アドレス.sin_family = AF_INET;
 addr.sin_port = htons(8080);
 addr.sin_addr.s_addr = INADDR_ANY;
 (bind(fd, (struct sockaddr*)&addr, sizeof(addr)) == -1 の場合)
 {
 printf("バインドに失敗しました。エラー:%s\n", strerror(errno));
 errno を返します。
 }

 (listen(fd, 5) == -1)の場合
 {
 printf("listen に失敗しました。エラー:%s\n", strerror(errno));
 errno を返します。
 }
 printf("8080 でリッスンしています...\n");

 epfd = epoll_create(102400);
 構造体 epoll_event イベント;
 イベント.イベント = EPOLLIN;
 イベントデータfd = fd;
 epoll_ctl(epfd, EPOLL_CTL_ADD, fd, &event);

 構造体epoll_eventイベント[102400];
 int iOnline = 0;
 （１）
 {
 int num = epoll_wait(epfd, revents, 102400, 60 * 1000);
 printf("epoll_wait 戻り値 %d\n", num);
 （数値＞0）の場合
 {
  (int i = 0; i < num; i++) の場合
  {
  (revents[i].data.fd == fd)の場合
  {
   整数クライアント;
   構造体 sockaddr_in cli_addr;
   socklen_t cli_addr_len = sizeof(cli_addr);
   クライアント = accept(fd, (struct sockaddr*)&cli_addr, &cli_addr_len);
   (クライアント == -1)の場合
   {
   printf("受け入れに失敗しました、エラー:%s\n", strerror(errno));
   (errno == EMFILE)の場合
   {
    printf("プロセスごとの制限に達しました\n");
    終了(エラー番号);
   }
   (errno == ENFILE)の場合
   {
    printf("システム全体の制限に達しました\n");
    終了(エラー番号);
   }
   続く;
   }

   iOnline++;
   printf("%s:%d から新しい接続を受信しました\n", inet_ntoa(cli_addr.sin_addr), cli_addr.sin_port);
   イベント.イベント = EPOLLIN;
   イベントデータfd = クライアント;
   epoll_ctl(epfd, EPOLL_CTL_ADD, fd, &event);
  }
  }
 }
 printf("オンライン番号:%d\n", iOnline);
 }

 0を返します。
}

パッケージメイン

輸入 （
 "ネット"
 「fmt」
 "時間"
 「strconv」
 "ランタイム"
）

func Connect(ホスト文字列、ポート整数) {
 _, err := net.Dial("tcp", host+":"+strconv.Itoa(port))
 err != nil の場合 {
 fmt.Printf("%s:%d へのダイヤルに失敗しました\n", ホスト, ポート)
 戻る
 }

 のために {
 時間.スリープ(30 * 1000 * 時間.ミリ秒)
 }
}

関数main() {
 カウント:= 0
 のために {
 接続します("192.168.63.128", 8080)
 カウント++;
 fmt.Printf("Goroutie num:%d\n",runtime.NumGoroutine())
 時間.スリープ(100 * 時間.ミリ秒)
 }
}

1 * ソフトノーファイル 102400
2 * ハードノーファイル 102400