Golang在服务器没有可用的后备队列时,TCP连接变慢。

huangapple go评论83阅读模式
英文:

Golang TCP Connection Slow when Server Doesn't Have Backlog Available

问题

更新

通过添加了pthreaded C客户端,重新创建了问题,表明长连接时间是TCP协议的一部分,而不是特定实现的一部分。修改这些协议似乎不容易。

初始问题

我相信我的问题主要是:当使用Golang的net包尝试通过TCP连接到服务器时,以下情况会发生:

  1. 服务器没有可用的连接,即使在后台也是如此。
  2. 连接没有被拒绝/失败。

连接到服务器的连接似乎存在大量开销,服务器响应时间从5 ms增加到几秒钟。这在生产环境和下面的最小示例中都看到了。正确的解决方案是使用连接池连接到服务器,这将被实现。这主要是我的好奇心。

复现步骤:

  1. 使用backlog = 1运行服务器,运行client.go。
    • 所有50个goroutine同时触发,总完成时间接近2分钟。
  2. 使用backlog = 100运行服务器,运行client.go。
    • 所有50个goroutine同时触发,连接到服务器排队,并在~260 ms内完成。
  3. 运行三个使用50 us重试时间的C客户端,平均能够在12 ms内完成连接,因此没有看到这个问题。

backlog = 1的示例输出(第一个时间是拨号时间,第二个时间是完成时间):

user@computer ~/tcp-tests $ go run client.go 127.0.0.1:46999
Long Elapsed Time: 216.579μs, 315.196μs
Long Elapsed Time: 274.169μs, 5.970873ms
Long Elapsed Time: 74.4μs, 10.753871ms
Long Elapsed Time: 590.965μs, 205.851066ms
Long Elapsed Time: 1.029287689s, 1.029574065s
Long Elapsed Time: 1.02945649s, 1.035098229s
...
Long Elapsed Time: 3.045881865s, 6.378597166s
Long Elapsed Time: 3.045314838s, 6.383783688s
Time taken stats: 2.85 +/- 1.59 s // 平均值 +/- STDEV
Main Taken: 6.384677948s

backlog = 100的示例输出:

...
Long Elapsed Time: 330.098μs, 251.004077ms
Long Elapsed Time: 298.146μs, 256.187795ms
Long Elapsed Time: 315.832μs, 261.523685ms
Time taken stats: 0.13 +/- 0.08 s
Main Taken: 263.186955ms

那么,在net.DialTCP的内部发生了什么(我们还使用了其他类型的拨号,没有明显的区别),导致拨号时间增加?

  • 在尝试建立连接之间的轮询时间?
  • RFC 5681全局拥塞控制(可能包括互斥锁?)变量,在所有初始失败的连接尝试上递增?
  • 其他原因?

我倾向于前两者,因为1s,3s,5s的值似乎是魔数。它们在我的普通本地机器和大规模生产环境中都出现过。

这是用C编写的最小服务器。感兴趣的配置值是listenbacklog参数。

/*
    Adapted from
    https://www.geeksforgeeks.org/tcp-server-client-implementation-in-c/
    
    Compile and run with:
        gcc server.c -o server; ./server
*/
#include <stdio.h>
#include <string.h>
#include <sys/socket.h>
#include <arpa/inet.h>
#include <unistd.h>
#include <sys/time.h>

int main(void)
{
    int socket_desc, client_sock, client_size;
    struct sockaddr_in server_addr, client_addr;
    char server_message[2000], client_message[2000];

    // Clean buffers:
    memset(server_message, '
/*
Adapted from
https://www.geeksforgeeks.org/tcp-server-client-implementation-in-c/
Compile and run with:
gcc server.c -o server; ./server
*/
#include <stdio.h>
#include <string.h>
#include <sys/socket.h>
#include <arpa/inet.h>
#include <unistd.h>
#include <sys/time.h>
int main(void)
{
int socket_desc, client_sock, client_size;
struct sockaddr_in server_addr, client_addr;
char server_message[2000], client_message[2000];
// Clean buffers:
memset(server_message, '\0', sizeof(server_message));
memset(client_message, '\0', sizeof(client_message));
// Create socket:
socket_desc = socket(AF_INET, SOCK_STREAM, 0);
if(socket_desc < 0){
printf("Error while creating socket\n");
return -1;
}
printf("Socket created successfully\n");
// Set port and IP:
server_addr.sin_family = AF_INET;
server_addr.sin_port = htons(46999);
server_addr.sin_addr.s_addr = inet_addr("127.0.0.1");
// Bind to the set port and IP:
if(bind(socket_desc, (struct sockaddr*)&server_addr, sizeof(server_addr))<0){
printf("Couldn't bind to the port\n");
return -1;
}
printf("Done with binding\n");
// Listen for clients:
// Increasing the backlog allows the Go client to connect and wait
// rather than poll/retry.
if(listen(socket_desc, 100) < 0){
printf("Error while listening\n");
return -1;
}
printf("\nListening for incoming connections.....\n");
// Accept an incoming connection:
client_size = sizeof(client_addr);
int server_run = 1;
do
{
struct timeval start, end;
double cpu_time_used;
gettimeofday(&start, NULL);
client_sock = accept(socket_desc, (struct sockaddr*)&client_addr, &client_size);
if (client_sock < 0){
printf("Can't accept\n");
return -1;
}
// Receive client's message:
if (recv(client_sock, client_message, sizeof(client_message), 0) < 0){
printf("Couldn't receive\n");
return -1;
}
if (strcmp(client_message, "stop") == 0)
{
server_run = 0;
printf("Received stop message.\n");
}
// Respond to client:
strcpy(server_message, "This is the server's message.");
if (send(client_sock, server_message, strlen(server_message), 0) < 0){
printf("Can't send\n");
return -1;
}
// sleep for 5 ms
usleep(5000);
// Closing the socket:
close(client_sock);
gettimeofday(&end, NULL);
cpu_time_used = (end.tv_usec - start.tv_usec) / 1000.0;
if (cpu_time_used > 0.0) // overflow in tv_usec if negative
printf("Server Time: %.4f ms\n", cpu_time_used);
} while(server_run);
close(socket_desc);
return 0;
}
', sizeof(server_message)); memset(client_message, '
/*
Adapted from
https://www.geeksforgeeks.org/tcp-server-client-implementation-in-c/
Compile and run with:
gcc server.c -o server; ./server
*/
#include <stdio.h>
#include <string.h>
#include <sys/socket.h>
#include <arpa/inet.h>
#include <unistd.h>
#include <sys/time.h>
int main(void)
{
int socket_desc, client_sock, client_size;
struct sockaddr_in server_addr, client_addr;
char server_message[2000], client_message[2000];
// Clean buffers:
memset(server_message, '\0', sizeof(server_message));
memset(client_message, '\0', sizeof(client_message));
// Create socket:
socket_desc = socket(AF_INET, SOCK_STREAM, 0);
if(socket_desc < 0){
printf("Error while creating socket\n");
return -1;
}
printf("Socket created successfully\n");
// Set port and IP:
server_addr.sin_family = AF_INET;
server_addr.sin_port = htons(46999);
server_addr.sin_addr.s_addr = inet_addr("127.0.0.1");
// Bind to the set port and IP:
if(bind(socket_desc, (struct sockaddr*)&server_addr, sizeof(server_addr))<0){
printf("Couldn't bind to the port\n");
return -1;
}
printf("Done with binding\n");
// Listen for clients:
// Increasing the backlog allows the Go client to connect and wait
// rather than poll/retry.
if(listen(socket_desc, 100) < 0){
printf("Error while listening\n");
return -1;
}
printf("\nListening for incoming connections.....\n");
// Accept an incoming connection:
client_size = sizeof(client_addr);
int server_run = 1;
do
{
struct timeval start, end;
double cpu_time_used;
gettimeofday(&start, NULL);
client_sock = accept(socket_desc, (struct sockaddr*)&client_addr, &client_size);
if (client_sock < 0){
printf("Can't accept\n");
return -1;
}
// Receive client's message:
if (recv(client_sock, client_message, sizeof(client_message), 0) < 0){
printf("Couldn't receive\n");
return -1;
}
if (strcmp(client_message, "stop") == 0)
{
server_run = 0;
printf("Received stop message.\n");
}
// Respond to client:
strcpy(server_message, "This is the server's message.");
if (send(client_sock, server_message, strlen(server_message), 0) < 0){
printf("Can't send\n");
return -1;
}
// sleep for 5 ms
usleep(5000);
// Closing the socket:
close(client_sock);
gettimeofday(&end, NULL);
cpu_time_used = (end.tv_usec - start.tv_usec) / 1000.0;
if (cpu_time_used > 0.0) // overflow in tv_usec if negative
printf("Server Time: %.4f ms\n", cpu_time_used);
} while(server_run);
close(socket_desc);
return 0;
}
', sizeof(client_message)); // Create socket: socket_desc = socket(AF_INET, SOCK_STREAM, 0); if(socket_desc < 0){ printf("Error while creating socket\n"); return -1; } printf("Socket created successfully\n"); // Set port and IP: server_addr.sin_family = AF_INET; server_addr.sin_port = htons(46999); server_addr.sin_addr.s_addr = inet_addr("127.0.0.1"); // Bind to the set port and IP: if(bind(socket_desc, (struct sockaddr*)&server_addr, sizeof(server_addr))<0){ printf("Couldn't bind to the port\n"); return -1; } printf("Done with binding\n"); // Listen for clients: // Increasing the backlog allows the Go client to connect and wait // rather than poll/retry. if(listen(socket_desc, 100) < 0){ printf("Error while listening\n"); return -1; } printf("\nListening for incoming connections.....\n"); // Accept an incoming connection: client_size = sizeof(client_addr); int server_run = 1; do { struct timeval start, end; double cpu_time_used; gettimeofday(&start, NULL); client_sock = accept(socket_desc, (struct sockaddr*)&client_addr, &client_size); if (client_sock < 0){ printf("Can't accept\n"); return -1; } // Receive client's message: if (recv(client_sock, client_message, sizeof(client_message), 0) < 0){ printf("Couldn't receive\n"); return -1; } if (strcmp(client_message, "stop") == 0) { server_run = 0; printf("Received stop message.\n"); } // Respond to client: strcpy(server_message, "This is the server's message."); if (send(client_sock, server_message, strlen(server_message), 0) < 0){ printf("Can't send\n"); return -1; } // sleep for 5 ms usleep(5000); // Closing the socket: close(client_sock); gettimeofday(&end, NULL); cpu_time_used = (end.tv_usec - start.tv_usec) / 1000.0; if (cpu_time_used > 0.0) // overflow in tv_usec if negative printf("Server Time: %.4f ms\n", cpu_time_used); } while(server_run); close(socket_desc); return 0; }

这是测试用的Go客户端

/*
    Adapted from
    https://www.linode.com/docs/guides/developing-udp-and-tcp-clients-and-servers-in-go/

    Run once the server.c is compiled and running with:
        go run client.go 127.0.0.1:46999
*/
package main

import (
    "fmt"
    "net"
    "os"
    "time"
    "github.com/montanaflynn/stats"
    "sync"
)
func do_message(wg *sync.WaitGroup, connect string, time_taken *float64) {
    defer wg.Done()
    message := make([]byte, 128)
    start_time := time.Now()
    pAddr, err := net.ResolveTCPAddr("tcp", connect)
    if err != nil {
        return
    }

    c, err := net.DialTCP("tcp", nil, pAddr)
    if err != nil {
        fmt.Println(err)
        return
    }
    c.SetLinger(0)
    dialed_time := time.Since(start_time)

    defer func() {
        c.Close()
        elapsed_time := time.Since(start_time)
        if elapsed_time.Microseconds() > 60 { // microseconds
            fmt.Println("Long Elapsed Time: " + dialed_time.String() + ", " + elapsed_time.String())
        }
        *time_taken = float64(elapsed_time.Microseconds())
    }()

    text := "{\"service\": \"magic_service_str\"}"
    c.Write([]byte(text))
    code, _ := c.Read(message) // Does not actually wait for response.
    code = code
}
func main() {
    main_start := time.Now()
    arguments := os.Args
    if len(arguments) == 1 {
            fmt.Println("Please provide host:port.")
            return
    }
    n_messages := 50
    wg := new(sync.WaitGroup)
    wg.Add(n_messages)
    times := make([]float64, n_messages)
    for i := 0; i < n_messages; i++ {
        // Used to turn the goroutines into serial implementation
        // time.Sleep(5500 * time.Microsecond)
        go do_message(wg, arguments[1], &times[i])
    }
    wg.Wait()
    avg, _ := stats.Mean(times)
    std, _ := stats.StandardDeviation(times)
    fmt.Println("Time taken stats: " + fmt.Sprintf("%.2f", avg / 1000000.0) + " +/- " + fmt.Sprintf("%.2f", std / 1000000.0) + " s")
    main_taken := time.Since(main_start)
    fmt.Println("Main Taken: " + main_taken.String())
}

在C中更新了pthreaded客户端,并确认问题不是Golang实现:

// gcc client_p.c -o pclient -lpthread
#include <stdio.h>
#include <string.h>
#include <sys/socket.h>
#include <arpa/inet.h>
#include <unistd.h>
#include <stdlib.h>
#include<sys/time.h>


#include <pthread.h>
#include <errno.h>

#ifndef THREAD_LOOP_COUNT
#define THREAD_LOOP_COUNT 1
#endif

/* Subtract the ‘struct timeval’ values X and Y,
   storing the result in RESULT.
   Return 1 if the difference is negative, otherwise 0.
   https://www.gnu.org/software/libc/manual/html_node/Calculating-Elapsed-Time.html
*/

int
timeval_subtract (struct timeval *result, struct timeval *x, struct timeval *y)
{
  /* Perform the carry for the later subtraction by updating y. */
  if (x->tv_usec < y->tv_usec) {
    int nsec = (y->tv_usec - x->tv_usec) / 1000000 + 1;
    y->tv_usec -= 1000000 * nsec;
    y->tv_sec += nsec;
  }
  if (x->tv_usec - y->tv_usec > 1000000) {
    int nsec = (x->tv_usec - y->tv_usec) / 1000000;
    y->tv_usec += 1000000 * nsec;
    y->tv_sec -= nsec;
  }

  /* Compute the time remaining to wait.
     tv_usec is certainly positive. */
  result->tv_sec = x->tv_sec - y->tv_sec;
  result->tv_usec = x->tv_usec - y->tv_usec;

  /* Return 1 if result is negative. */
  return x->tv_sec < y->tv_sec;
}


static void* workerThreadFunc(void* arg)
{
    int socket_desc;
    struct sockaddr_in server_addr;
    char server_message[2000], client_message[2000];
    // Clean buffers:
    memset(server_message,'
// gcc client_p.c -o pclient -lpthread
#include <stdio.h>
#include <string.h>
#include <sys/socket.h>
#include <arpa/inet.h>
#include <unistd.h>
#include <stdlib.h>
#include<sys/time.h>
#include <pthread.h>
#include <errno.h>
#ifndef THREAD_LOOP_COUNT
#define THREAD_LOOP_COUNT 1
#endif
/* Subtract the ‘struct timeval’ values X and Y,
storing the result in RESULT.
Return 1 if the difference is negative, otherwise 0.
https://www.gnu.org/software/libc/manual/html_node/Calculating-Elapsed-Time.html
*/
int
timeval_subtract (struct timeval *result, struct timeval *x, struct timeval *y)
{
/* Perform the carry for the later subtraction by updating y. */
if (x->tv_usec < y->tv_usec) {
int nsec = (y->tv_usec - x->tv_usec) / 1000000 + 1;
y->tv_usec -= 1000000 * nsec;
y->tv_sec += nsec;
}
if (x->tv_usec - y->tv_usec > 1000000) {
int nsec = (x->tv_usec - y->tv_usec) / 1000000;
y->tv_usec += 1000000 * nsec;
y->tv_sec -= nsec;
}
/* Compute the time remaining to wait.
tv_usec is certainly positive. */
result->tv_sec = x->tv_sec - y->tv_sec;
result->tv_usec = x->tv_usec - y->tv_usec;
/* Return 1 if result is negative. */
return x->tv_sec < y->tv_sec;
}
static void* workerThreadFunc(void* arg)
{
int socket_desc;
struct sockaddr_in server_addr;
char server_message[2000], client_message[2000];
// Clean buffers:
memset(server_message,'\0',sizeof(server_message));
memset(client_message,'\0',sizeof(client_message));
// Set port and IP the same as server-side:
server_addr.sin_family = AF_INET;
server_addr.sin_port = htons(46999);
server_addr.sin_addr.s_addr = inet_addr("127.0.0.1");
int retries = 0;
struct timeval start, end, difference;
double cpu_time_used;
for(int i = 0; i < THREAD_LOOP_COUNT; i++)
{
gettimeofday(&start, NULL);
// Create socket:
socket_desc = socket(AF_INET, SOCK_STREAM, 0);
if(socket_desc < 0){
printf("Unable to create socket\n");
return;
}
// Send connection request to server:
while(connect(socket_desc, (struct sockaddr*)&server_addr, sizeof(server_addr)) < 0){
retries++;
if (retries > 10)
{
printf("Unable to connect\n");
retries = 0;
}
usleep(5);
}
int retries = 0;
// Send the message to server:
if(send(socket_desc, client_message, strlen("client message."), 0) < 0){
printf("Unable to send message\n");
close(socket_desc);
return;
}
// Receive the server's response:
if(recv(socket_desc, server_message, sizeof(server_message), 0) < 0){
printf("Error while receiving server's msg\n");
close(socket_desc);
return;
}
// Close the socket:
close(socket_desc);
gettimeofday(&end, NULL);
timeval_subtract (&difference, &end, &start);
double cpu_time_used = (double)difference.tv_sec + (double)difference.tv_usec / 1000000.0;
printf("Client Time: %.4e s\n", cpu_time_used);
}
}
int main(int argc, char **argv)
{
int n_threads = 50;  // default value
if (argc > 1)
n_threads = atoi(argv[1]);
pthread_t *threads = (pthread_t*)malloc(n_threads * sizeof(pthread_t));
struct timeval start, end, difference;
gettimeofday(&start, NULL);
for(int i = 0; i < n_threads; i++)
{
int createRet = pthread_create(&threads[i], NULL, workerThreadFunc, NULL);
if (createRet != 0)
{
printf("failed to create thread\n");
}
}
for(int i = 0; i < n_threads; i++)
pthread_join(threads[i], NULL);
gettimeofday(&end, NULL);
timeval_subtract (&difference, &end, &start);
double cpu_time_used = (double)difference.tv_sec + (double)difference.tv_usec / 1000000.0;
printf("Total Client Time: %.4e s\n", cpu_time_used);
free(threads);
return 0;
}
',sizeof(server_message)); memset(client_message,'
// gcc client_p.c -o pclient -lpthread
#include <stdio.h>
#include <string.h>
#include <sys/socket.h>
#include <arpa/inet.h>
#include <unistd.h>
#include <stdlib.h>
#include<sys/time.h>
#include <pthread.h>
#include <errno.h>
#ifndef THREAD_LOOP_COUNT
#define THREAD_LOOP_COUNT 1
#endif
/* Subtract the ‘struct timeval’ values X and Y,
storing the result in RESULT.
Return 1 if the difference is negative, otherwise 0.
https://www.gnu.org/software/libc/manual/html_node/Calculating-Elapsed-Time.html
*/
int
timeval_subtract (struct timeval *result, struct timeval *x, struct timeval *y)
{
/* Perform the carry for the later subtraction by updating y. */
if (x->tv_usec < y->tv_usec) {
int nsec = (y->tv_usec - x->tv_usec) / 1000000 + 1;
y->tv_usec -= 1000000 * nsec;
y->tv_sec += nsec;
}
if (x->tv_usec - y->tv_usec > 1000000) {
int nsec = (x->tv_usec - y->tv_usec) / 1000000;
y->tv_usec += 1000000 * nsec;
y->tv_sec -= nsec;
}
/* Compute the time remaining to wait.
tv_usec is certainly positive. */
result->tv_sec = x->tv_sec - y->tv_sec;
result->tv_usec = x->tv_usec - y->tv_usec;
/* Return 1 if result is negative. */
return x->tv_sec < y->tv_sec;
}
static void* workerThreadFunc(void* arg)
{
int socket_desc;
struct sockaddr_in server_addr;
char server_message[2000], client_message[2000];
// Clean buffers:
memset(server_message,'\0',sizeof(server_message));
memset(client_message,'\0',sizeof(client_message));
// Set port and IP the same as server-side:
server_addr.sin_family = AF_INET;
server_addr.sin_port = htons(46999);
server_addr.sin_addr.s_addr = inet_addr("127.0.0.1");
int retries = 0;
struct timeval start, end, difference;
double cpu_time_used;
for(int i = 0; i < THREAD_LOOP_COUNT; i++)
{
gettimeofday(&start, NULL);
// Create socket:
socket_desc = socket(AF_INET, SOCK_STREAM, 0);
if(socket_desc < 0){
printf("Unable to create socket\n");
return;
}
// Send connection request to server:
while(connect(socket_desc, (struct sockaddr*)&server_addr, sizeof(server_addr)) < 0){
retries++;
if (retries > 10)
{
printf("Unable to connect\n");
retries = 0;
}
usleep(5);
}
int retries = 0;
// Send the message to server:
if(send(socket_desc, client_message, strlen("client message."), 0) < 0){
printf("Unable to send message\n");
close(socket_desc);
return;
}
// Receive the server's response:
if(recv(socket_desc, server_message, sizeof(server_message), 0) < 0){
printf("Error while receiving server's msg\n");
close(socket_desc);
return;
}
// Close the socket:
close(socket_desc);
gettimeofday(&end, NULL);
timeval_subtract (&difference, &end, &start);
double cpu_time_used = (double)difference.tv_sec + (double)difference.tv_usec / 1000000.0;
printf("Client Time: %.4e s\n", cpu_time_used);
}
}
int main(int argc, char **argv)
{
int n_threads = 50;  // default value
if (argc > 1)
n_threads = atoi(argv[1]);
pthread_t *threads = (pthread_t*)malloc(n_threads * sizeof(pthread_t));
struct timeval start, end, difference;
gettimeofday(&start, NULL);
for(int i = 0; i < n_threads; i++)
{
int createRet = pthread_create(&threads[i], NULL, workerThreadFunc, NULL);
if (createRet != 0)
{
printf("failed to create thread\n");
}
}
for(int i = 0; i < n_threads; i++)
pthread_join(threads[i], NULL);
gettimeofday(&end, NULL);
timeval_subtract (&difference, &end, &start);
double cpu_time_used = (double)difference.tv_sec + (double)difference.tv_usec / 1000000.0;
printf("Total Client Time: %.4e s\n", cpu_time_used);
free(threads);
return 0;
}
',sizeof(client_message)); // Set port and IP the same as server-side: server_addr.sin_family = AF_INET; server_addr.sin_port = htons(46999); server_addr.sin_addr.s_addr = inet_addr("127.0.0.1"); int retries = 0; struct timeval start, end, difference; double cpu_time_used; for(int i = 0; i < THREAD_LOOP_COUNT; i++) { gettimeofday(&start, NULL); // Create socket: socket_desc = socket(AF_INET, SOCK_STREAM, 0); if(socket_desc < 0){ printf("Unable to create socket\n"); return; } // Send connection request to server: while(connect(socket_desc, (struct sockaddr*)&server_addr, sizeof(server_addr)) < 0){ retries++; if (retries > 10) { printf("Unable to connect\n"); retries = 0; } usleep(5); } int retries = 0; // Send the message to server: if(send(socket_desc, client_message, strlen("client message."), 0) < 0){ printf("Unable to send message\n"); close(socket_desc); return; } // Receive the server's response: if(recv(socket_desc, server_message, sizeof(server_message), 0) < 0){ printf("Error while receiving server's msg\n"); close(socket_desc); return; } // Close the socket: close(socket_desc); gettimeofday(&end, NULL); timeval_subtract (&difference, &end, &start); double cpu_time_used = (double)difference.tv_sec + (double)difference.tv_usec / 1000000.0; printf("Client Time: %.4e s\n", cpu_time_used); } } int main(int argc, char **argv) { int n_threads = 50; // default value if (argc > 1) n_threads = atoi(argv[1]); pthread_t *threads = (pthread_t*)malloc(n_threads * sizeof(pthread_t)); struct timeval start, end, difference; gettimeofday(&start, NULL); for(int i = 0; i < n_threads; i++) { int createRet = pthread_create(&threads[i], NULL, workerThreadFunc, NULL); if (createRet != 0) { printf("failed to create thread\n"); } } for(int i = 0; i < n_threads; i++) pthread_join(threads[i], NULL); gettimeofday(&end, NULL); timeval_subtract (&difference, &end, &start); double cpu_time_used = (double)difference.tv_sec + (double)difference.tv_usec / 1000000.0; printf("Total Client Time: %.4e s\n", cpu_time_used); free(threads); return 0; }
英文:

Update

With the added pthreaded C client, the problem is recreated, indicating the long connection times are part of the TCP protocol, rather than specific implementations. Altering those protocols doesn't seem easily available.

Initial Question

I believe my question is largely: What does the Golang net package do when attempting to connect to a server over TCP and:

  1. The server has no connections available, even in backlog.
  2. The connection is not refused/failed.

There seems to be a large amount of overhead in that connection with server response times ramping up from 5 ms to several seconds. This was seen both in a production environment and in the minimal example below. The proper solution is to use connection pools to the server, which will be implemented. This is largely my curiosity.

To reproduce:

  1. Run server with backlog = 1, run client.go.
    • All 50 goroutines fire at once, with a total completion time of almost 2 minutes.
  2. Run server with backlog = 100, run client.go.
    • All 50 goroutines fire at once, queue up connected to the server, and complete in ~260 ms.
  3. Running three C clients utilizing 50 us retry times was able to complete connections within 12 ms on average, so didn't see this issue.

Example output for backlog = 1 (first time is time to dial, second is time to completion):

user@computer ~/tcp-tests $ go run client.go 127.0.0.1:46999
Long Elapsed Time: 216.579&#181;s, 315.196&#181;s
Long Elapsed Time: 274.169&#181;s, 5.970873ms
Long Elapsed Time: 74.4&#181;s, 10.753871ms
Long Elapsed Time: 590.965&#181;s, 205.851066ms
Long Elapsed Time: 1.029287689s, 1.029574065s
Long Elapsed Time: 1.02945649s, 1.035098229s
...
Long Elapsed Time: 3.045881865s, 6.378597166s
Long Elapsed Time: 3.045314838s, 6.383783688s
Time taken stats: 2.85 +/- 1.59 s // average +/- STDEV
Main Taken: 6.384677948s

Example output for backlog = 100:

...
Long Elapsed Time: 330.098&#181;s, 251.004077ms
Long Elapsed Time: 298.146&#181;s, 256.187795ms
Long Elapsed Time: 315.832&#181;s, 261.523685ms
Time taken stats: 0.13 +/- 0.08 s
Main Taken: 263.186955ms

So what's going on under the hood of net.DialTCP (we used other flavors of dial as well, with no discernible difference) that causes the dial time to grow?

  • Polling time between attempts to make a connection?
  • An RFC 5681 Global Congestion Control (likely including mutex lock?) variable that gets incremented on all the initial failed connection attempts?
  • Something else?

I'm leaning towards the first two, as the 1s, 3s, 5s values seem to be magic numbers. They show up both on my modest local machine, and a large scale production environment.

Here is the minimal server written in C. The configuration value of interest is the backlog argument to listen.

/*
    Adapted from
    https://www.geeksforgeeks.org/tcp-server-client-implementation-in-c/
    
    Compile and run with:
        gcc server.c -o server; ./server
*/
#include &lt;stdio.h&gt;
#include &lt;string.h&gt;
#include &lt;sys/socket.h&gt;
#include &lt;arpa/inet.h&gt;
#include &lt;unistd.h&gt;
#include &lt;sys/time.h&gt;

int main(void)
{
    int socket_desc, client_sock, client_size;
    struct sockaddr_in server_addr, client_addr;
    char server_message[2000], client_message[2000];

    // Clean buffers:
    memset(server_message, &#39;
/*
Adapted from
https://www.geeksforgeeks.org/tcp-server-client-implementation-in-c/
Compile and run with:
gcc server.c -o server; ./server
*/
#include &lt;stdio.h&gt;
#include &lt;string.h&gt;
#include &lt;sys/socket.h&gt;
#include &lt;arpa/inet.h&gt;
#include &lt;unistd.h&gt;
#include &lt;sys/time.h&gt;
int main(void)
{
int socket_desc, client_sock, client_size;
struct sockaddr_in server_addr, client_addr;
char server_message[2000], client_message[2000];
// Clean buffers:
memset(server_message, &#39;\0&#39;, sizeof(server_message));
memset(client_message, &#39;\0&#39;, sizeof(client_message));
// Create socket:
socket_desc = socket(AF_INET, SOCK_STREAM, 0);
if(socket_desc &lt; 0){
printf(&quot;Error while creating socket\n&quot;);
return -1;
}
printf(&quot;Socket created successfully\n&quot;);
// Set port and IP:
server_addr.sin_family = AF_INET;
server_addr.sin_port = htons(46999);
server_addr.sin_addr.s_addr = inet_addr(&quot;127.0.0.1&quot;);
// Bind to the set port and IP:
if(bind(socket_desc, (struct sockaddr*)&amp;server_addr, sizeof(server_addr))&lt;0){
printf(&quot;Couldn&#39;t bind to the port\n&quot;);
return -1;
}
printf(&quot;Done with binding\n&quot;);
// Listen for clients:
// Increasing the backlog allows the Go client to connect and wait
// rather than poll/retry.
if(listen(socket_desc, 100) &lt; 0){
printf(&quot;Error while listening\n&quot;);
return -1;
}
printf(&quot;\nListening for incoming connections.....\n&quot;);
// Accept an incoming connection:
client_size = sizeof(client_addr);
int server_run = 1;
do
{
struct timeval start, end;
double cpu_time_used;
gettimeofday(&amp;start, NULL);
client_sock = accept(socket_desc, (struct sockaddr*)&amp;client_addr, &amp;client_size);
if (client_sock &lt; 0){
printf(&quot;Can&#39;t accept\n&quot;);
return -1;
}
// Receive client&#39;s message:
if (recv(client_sock, client_message, sizeof(client_message), 0) &lt; 0){
printf(&quot;Couldn&#39;t receive\n&quot;);
return -1;
}
if (strcmp(client_message, &quot;stop&quot;) == 0)
{
server_run = 0;
printf(&quot;Received stop message.\n&quot;);
}
// Respond to client:
strcpy(server_message, &quot;This is the server&#39;s message.&quot;);
if (send(client_sock, server_message, strlen(server_message), 0) &lt; 0){
printf(&quot;Can&#39;t send\n&quot;);
return -1;
}
// sleep for 5 ms
usleep(5000);
// Closing the socket:
close(client_sock);
gettimeofday(&amp;end, NULL);
cpu_time_used = (end.tv_usec - start.tv_usec) / 1000.0;
if (cpu_time_used &gt; 0.0) // overflow in tv_usec if negative
printf(&quot;Server Time: %.4f ms\n&quot;, cpu_time_used);
} while(server_run);
close(socket_desc);
return 0;
}
&#39;, sizeof(server_message)); memset(client_message, &#39;
/*
Adapted from
https://www.geeksforgeeks.org/tcp-server-client-implementation-in-c/
Compile and run with:
gcc server.c -o server; ./server
*/
#include &lt;stdio.h&gt;
#include &lt;string.h&gt;
#include &lt;sys/socket.h&gt;
#include &lt;arpa/inet.h&gt;
#include &lt;unistd.h&gt;
#include &lt;sys/time.h&gt;
int main(void)
{
int socket_desc, client_sock, client_size;
struct sockaddr_in server_addr, client_addr;
char server_message[2000], client_message[2000];
// Clean buffers:
memset(server_message, &#39;\0&#39;, sizeof(server_message));
memset(client_message, &#39;\0&#39;, sizeof(client_message));
// Create socket:
socket_desc = socket(AF_INET, SOCK_STREAM, 0);
if(socket_desc &lt; 0){
printf(&quot;Error while creating socket\n&quot;);
return -1;
}
printf(&quot;Socket created successfully\n&quot;);
// Set port and IP:
server_addr.sin_family = AF_INET;
server_addr.sin_port = htons(46999);
server_addr.sin_addr.s_addr = inet_addr(&quot;127.0.0.1&quot;);
// Bind to the set port and IP:
if(bind(socket_desc, (struct sockaddr*)&amp;server_addr, sizeof(server_addr))&lt;0){
printf(&quot;Couldn&#39;t bind to the port\n&quot;);
return -1;
}
printf(&quot;Done with binding\n&quot;);
// Listen for clients:
// Increasing the backlog allows the Go client to connect and wait
// rather than poll/retry.
if(listen(socket_desc, 100) &lt; 0){
printf(&quot;Error while listening\n&quot;);
return -1;
}
printf(&quot;\nListening for incoming connections.....\n&quot;);
// Accept an incoming connection:
client_size = sizeof(client_addr);
int server_run = 1;
do
{
struct timeval start, end;
double cpu_time_used;
gettimeofday(&amp;start, NULL);
client_sock = accept(socket_desc, (struct sockaddr*)&amp;client_addr, &amp;client_size);
if (client_sock &lt; 0){
printf(&quot;Can&#39;t accept\n&quot;);
return -1;
}
// Receive client&#39;s message:
if (recv(client_sock, client_message, sizeof(client_message), 0) &lt; 0){
printf(&quot;Couldn&#39;t receive\n&quot;);
return -1;
}
if (strcmp(client_message, &quot;stop&quot;) == 0)
{
server_run = 0;
printf(&quot;Received stop message.\n&quot;);
}
// Respond to client:
strcpy(server_message, &quot;This is the server&#39;s message.&quot;);
if (send(client_sock, server_message, strlen(server_message), 0) &lt; 0){
printf(&quot;Can&#39;t send\n&quot;);
return -1;
}
// sleep for 5 ms
usleep(5000);
// Closing the socket:
close(client_sock);
gettimeofday(&amp;end, NULL);
cpu_time_used = (end.tv_usec - start.tv_usec) / 1000.0;
if (cpu_time_used &gt; 0.0) // overflow in tv_usec if negative
printf(&quot;Server Time: %.4f ms\n&quot;, cpu_time_used);
} while(server_run);
close(socket_desc);
return 0;
}
&#39;, sizeof(client_message)); // Create socket: socket_desc = socket(AF_INET, SOCK_STREAM, 0); if(socket_desc &lt; 0){ printf(&quot;Error while creating socket\n&quot;); return -1; } printf(&quot;Socket created successfully\n&quot;); // Set port and IP: server_addr.sin_family = AF_INET; server_addr.sin_port = htons(46999); server_addr.sin_addr.s_addr = inet_addr(&quot;127.0.0.1&quot;); // Bind to the set port and IP: if(bind(socket_desc, (struct sockaddr*)&amp;server_addr, sizeof(server_addr))&lt;0){ printf(&quot;Couldn&#39;t bind to the port\n&quot;); return -1; } printf(&quot;Done with binding\n&quot;); // Listen for clients: // Increasing the backlog allows the Go client to connect and wait // rather than poll/retry. if(listen(socket_desc, 100) &lt; 0){ printf(&quot;Error while listening\n&quot;); return -1; } printf(&quot;\nListening for incoming connections.....\n&quot;); // Accept an incoming connection: client_size = sizeof(client_addr); int server_run = 1; do { struct timeval start, end; double cpu_time_used; gettimeofday(&amp;start, NULL); client_sock = accept(socket_desc, (struct sockaddr*)&amp;client_addr, &amp;client_size); if (client_sock &lt; 0){ printf(&quot;Can&#39;t accept\n&quot;); return -1; } // Receive client&#39;s message: if (recv(client_sock, client_message, sizeof(client_message), 0) &lt; 0){ printf(&quot;Couldn&#39;t receive\n&quot;); return -1; } if (strcmp(client_message, &quot;stop&quot;) == 0) { server_run = 0; printf(&quot;Received stop message.\n&quot;); } // Respond to client: strcpy(server_message, &quot;This is the server&#39;s message.&quot;); if (send(client_sock, server_message, strlen(server_message), 0) &lt; 0){ printf(&quot;Can&#39;t send\n&quot;); return -1; } // sleep for 5 ms usleep(5000); // Closing the socket: close(client_sock); gettimeofday(&amp;end, NULL); cpu_time_used = (end.tv_usec - start.tv_usec) / 1000.0; if (cpu_time_used &gt; 0.0) // overflow in tv_usec if negative printf(&quot;Server Time: %.4f ms\n&quot;, cpu_time_used); } while(server_run); close(socket_desc); return 0; }

Here is the testing Go client

/*
    Adapted from
    https://www.linode.com/docs/guides/developing-udp-and-tcp-clients-and-servers-in-go/

    Run once the server.c is compiled and running with:
        go run client.go 127.0.0.1:46999
*/
package main

import (
    &quot;fmt&quot;
    &quot;net&quot;
    &quot;os&quot;
    &quot;time&quot;
    &quot;github.com/montanaflynn/stats&quot;
    &quot;sync&quot;
)
func do_message(wg *sync.WaitGroup, connect string, time_taken *float64) {
    defer wg.Done()
    message := make([]byte, 128)
    start_time := time.Now()
    pAddr, err := net.ResolveTCPAddr(&quot;tcp&quot;, connect)
    if err != nil {
        return
    }

    c, err := net.DialTCP(&quot;tcp&quot;, nil, pAddr)
    if err != nil {
        fmt.Println(err)
        return
    }
    c.SetLinger(0)
    dialed_time := time.Since(start_time)

    defer func() {
        c.Close()
        elapsed_time := time.Since(start_time)
        if elapsed_time.Microseconds() &gt; 60 { // microseconds
            fmt.Println(&quot;Long Elapsed Time: &quot; + dialed_time.String() + &quot;, &quot; + elapsed_time.String())
        }
        *time_taken = float64(elapsed_time.Microseconds())
    }()

    text := &quot;{\&quot;service\&quot;: \&quot;magic_service_str\&quot;}&quot;
    c.Write([]byte(text))
    code, _ := c.Read(message) // Does not actually wait for response.
    code = code
}
func main() {
    main_start := time.Now()
    arguments := os.Args
    if len(arguments) == 1 {
            fmt.Println(&quot;Please provide host:port.&quot;)
            return
    }
    n_messages := 50
    wg := new(sync.WaitGroup)
    wg.Add(n_messages)
    times := make([]float64, n_messages)
    for i := 0; i &lt; n_messages; i++ {
        // Used to turn the goroutines into serial implementation
        // time.Sleep(5500 * time.Microsecond)
        go do_message(wg, arguments[1], &amp;times[i])
    }
    wg.Wait()
    avg, _ := stats.Mean(times)
    std, _ := stats.StandardDeviation(times)
    fmt.Println(&quot;Time taken stats: &quot; + fmt.Sprintf(&quot;%.2f&quot;, avg / 1000000.0) + &quot; +/- &quot; + fmt.Sprintf(&quot;%.2f&quot;, std / 1000000.0) + &quot; s&quot;)
    main_taken := time.Since(main_start)
    fmt.Println(&quot;Main Taken: &quot; + main_taken.String())
}

Updated pthreaded client in C and confirmed the issue is not the Golang implementation:

// gcc client_p.c -o pclient -lpthread
#include &lt;stdio.h&gt;
#include &lt;string.h&gt;
#include &lt;sys/socket.h&gt;
#include &lt;arpa/inet.h&gt;
#include &lt;unistd.h&gt;
#include &lt;stdlib.h&gt;
#include&lt;sys/time.h&gt;


#include &lt;pthread.h&gt;
#include &lt;errno.h&gt;

#ifndef THREAD_LOOP_COUNT
#define THREAD_LOOP_COUNT 1
#endif

/* Subtract the ‘struct timeval’ values X and Y,
   storing the result in RESULT.
   Return 1 if the difference is negative, otherwise 0.
   https://www.gnu.org/software/libc/manual/html_node/Calculating-Elapsed-Time.html
*/

int
timeval_subtract (struct timeval *result, struct timeval *x, struct timeval *y)
{
  /* Perform the carry for the later subtraction by updating y. */
  if (x-&gt;tv_usec &lt; y-&gt;tv_usec) {
    int nsec = (y-&gt;tv_usec - x-&gt;tv_usec) / 1000000 + 1;
    y-&gt;tv_usec -= 1000000 * nsec;
    y-&gt;tv_sec += nsec;
  }
  if (x-&gt;tv_usec - y-&gt;tv_usec &gt; 1000000) {
    int nsec = (x-&gt;tv_usec - y-&gt;tv_usec) / 1000000;
    y-&gt;tv_usec += 1000000 * nsec;
    y-&gt;tv_sec -= nsec;
  }

  /* Compute the time remaining to wait.
     tv_usec is certainly positive. */
  result-&gt;tv_sec = x-&gt;tv_sec - y-&gt;tv_sec;
  result-&gt;tv_usec = x-&gt;tv_usec - y-&gt;tv_usec;

  /* Return 1 if result is negative. */
  return x-&gt;tv_sec &lt; y-&gt;tv_sec;
}


static void* workerThreadFunc(void* arg)
{
    int socket_desc;
    struct sockaddr_in server_addr;
    char server_message[2000], client_message[2000];
    // Clean buffers:
    memset(server_message,&#39;
// gcc client_p.c -o pclient -lpthread
#include &lt;stdio.h&gt;
#include &lt;string.h&gt;
#include &lt;sys/socket.h&gt;
#include &lt;arpa/inet.h&gt;
#include &lt;unistd.h&gt;
#include &lt;stdlib.h&gt;
#include&lt;sys/time.h&gt;
#include &lt;pthread.h&gt;
#include &lt;errno.h&gt;
#ifndef THREAD_LOOP_COUNT
#define THREAD_LOOP_COUNT 1
#endif
/* Subtract the ‘struct timeval’ values X and Y,
storing the result in RESULT.
Return 1 if the difference is negative, otherwise 0.
https://www.gnu.org/software/libc/manual/html_node/Calculating-Elapsed-Time.html
*/
int
timeval_subtract (struct timeval *result, struct timeval *x, struct timeval *y)
{
/* Perform the carry for the later subtraction by updating y. */
if (x-&gt;tv_usec &lt; y-&gt;tv_usec) {
int nsec = (y-&gt;tv_usec - x-&gt;tv_usec) / 1000000 + 1;
y-&gt;tv_usec -= 1000000 * nsec;
y-&gt;tv_sec += nsec;
}
if (x-&gt;tv_usec - y-&gt;tv_usec &gt; 1000000) {
int nsec = (x-&gt;tv_usec - y-&gt;tv_usec) / 1000000;
y-&gt;tv_usec += 1000000 * nsec;
y-&gt;tv_sec -= nsec;
}
/* Compute the time remaining to wait.
tv_usec is certainly positive. */
result-&gt;tv_sec = x-&gt;tv_sec - y-&gt;tv_sec;
result-&gt;tv_usec = x-&gt;tv_usec - y-&gt;tv_usec;
/* Return 1 if result is negative. */
return x-&gt;tv_sec &lt; y-&gt;tv_sec;
}
static void* workerThreadFunc(void* arg)
{
int socket_desc;
struct sockaddr_in server_addr;
char server_message[2000], client_message[2000];
// Clean buffers:
memset(server_message,&#39;\0&#39;,sizeof(server_message));
memset(client_message,&#39;\0&#39;,sizeof(client_message));
// Set port and IP the same as server-side:
server_addr.sin_family = AF_INET;
server_addr.sin_port = htons(46999);
server_addr.sin_addr.s_addr = inet_addr(&quot;127.0.0.1&quot;);
int retries = 0;
struct timeval start, end, difference;
double cpu_time_used;
for(int i = 0; i &lt; THREAD_LOOP_COUNT; i++)
{
gettimeofday(&amp;start, NULL);
// Create socket:
socket_desc = socket(AF_INET, SOCK_STREAM, 0);
if(socket_desc &lt; 0){
printf(&quot;Unable to create socket\n&quot;);
return;
}
// Send connection request to server:
while(connect(socket_desc, (struct sockaddr*)&amp;server_addr, sizeof(server_addr)) &lt; 0){
retries++;
if (retries &gt; 10)
{
printf(&quot;Unable to connect\n&quot;);
retries = 0;
}
usleep(5);
}
int retries = 0;
// Send the message to server:
if(send(socket_desc, client_message, strlen(&quot;client message.&quot;), 0) &lt; 0){
printf(&quot;Unable to send message\n&quot;);
close(socket_desc);
return;
}
// Receive the server&#39;s response:
if(recv(socket_desc, server_message, sizeof(server_message), 0) &lt; 0){
printf(&quot;Error while receiving server&#39;s msg\n&quot;);
close(socket_desc);
return;
}
// Close the socket:
close(socket_desc);
gettimeofday(&amp;end, NULL);
timeval_subtract (&amp;difference, &amp;end, &amp;start);
double cpu_time_used = (double)difference.tv_sec + (double)difference.tv_usec / 1000000.0;
printf(&quot;Client Time: %.4e s\n&quot;, cpu_time_used);
}
}
int main(int argc, char **argv)
{
int n_threads = 50;  // default value
if (argc &gt; 1)
n_threads = atoi(argv[1]);
pthread_t *threads = (pthread_t*)malloc(n_threads * sizeof(pthread_t));
struct timeval start, end, difference;
gettimeofday(&amp;start, NULL);
for(int i = 0; i &lt; n_threads; i++)
{
int createRet = pthread_create(&amp;threads[i], NULL, workerThreadFunc, NULL);
if (createRet != 0)
{
printf(&quot;failed to create thread\n&quot;);
}
}
for(int i = 0; i &lt; n_threads; i++)
pthread_join(threads[i], NULL);
gettimeofday(&amp;end, NULL);
timeval_subtract (&amp;difference, &amp;end, &amp;start);
double cpu_time_used = (double)difference.tv_sec + (double)difference.tv_usec / 1000000.0;
printf(&quot;Total Client Time: %.4e s\n&quot;, cpu_time_used);
free(threads);
return 0;
}
&#39;,sizeof(server_message)); memset(client_message,&#39;
// gcc client_p.c -o pclient -lpthread
#include &lt;stdio.h&gt;
#include &lt;string.h&gt;
#include &lt;sys/socket.h&gt;
#include &lt;arpa/inet.h&gt;
#include &lt;unistd.h&gt;
#include &lt;stdlib.h&gt;
#include&lt;sys/time.h&gt;
#include &lt;pthread.h&gt;
#include &lt;errno.h&gt;
#ifndef THREAD_LOOP_COUNT
#define THREAD_LOOP_COUNT 1
#endif
/* Subtract the ‘struct timeval’ values X and Y,
storing the result in RESULT.
Return 1 if the difference is negative, otherwise 0.
https://www.gnu.org/software/libc/manual/html_node/Calculating-Elapsed-Time.html
*/
int
timeval_subtract (struct timeval *result, struct timeval *x, struct timeval *y)
{
/* Perform the carry for the later subtraction by updating y. */
if (x-&gt;tv_usec &lt; y-&gt;tv_usec) {
int nsec = (y-&gt;tv_usec - x-&gt;tv_usec) / 1000000 + 1;
y-&gt;tv_usec -= 1000000 * nsec;
y-&gt;tv_sec += nsec;
}
if (x-&gt;tv_usec - y-&gt;tv_usec &gt; 1000000) {
int nsec = (x-&gt;tv_usec - y-&gt;tv_usec) / 1000000;
y-&gt;tv_usec += 1000000 * nsec;
y-&gt;tv_sec -= nsec;
}
/* Compute the time remaining to wait.
tv_usec is certainly positive. */
result-&gt;tv_sec = x-&gt;tv_sec - y-&gt;tv_sec;
result-&gt;tv_usec = x-&gt;tv_usec - y-&gt;tv_usec;
/* Return 1 if result is negative. */
return x-&gt;tv_sec &lt; y-&gt;tv_sec;
}
static void* workerThreadFunc(void* arg)
{
int socket_desc;
struct sockaddr_in server_addr;
char server_message[2000], client_message[2000];
// Clean buffers:
memset(server_message,&#39;\0&#39;,sizeof(server_message));
memset(client_message,&#39;\0&#39;,sizeof(client_message));
// Set port and IP the same as server-side:
server_addr.sin_family = AF_INET;
server_addr.sin_port = htons(46999);
server_addr.sin_addr.s_addr = inet_addr(&quot;127.0.0.1&quot;);
int retries = 0;
struct timeval start, end, difference;
double cpu_time_used;
for(int i = 0; i &lt; THREAD_LOOP_COUNT; i++)
{
gettimeofday(&amp;start, NULL);
// Create socket:
socket_desc = socket(AF_INET, SOCK_STREAM, 0);
if(socket_desc &lt; 0){
printf(&quot;Unable to create socket\n&quot;);
return;
}
// Send connection request to server:
while(connect(socket_desc, (struct sockaddr*)&amp;server_addr, sizeof(server_addr)) &lt; 0){
retries++;
if (retries &gt; 10)
{
printf(&quot;Unable to connect\n&quot;);
retries = 0;
}
usleep(5);
}
int retries = 0;
// Send the message to server:
if(send(socket_desc, client_message, strlen(&quot;client message.&quot;), 0) &lt; 0){
printf(&quot;Unable to send message\n&quot;);
close(socket_desc);
return;
}
// Receive the server&#39;s response:
if(recv(socket_desc, server_message, sizeof(server_message), 0) &lt; 0){
printf(&quot;Error while receiving server&#39;s msg\n&quot;);
close(socket_desc);
return;
}
// Close the socket:
close(socket_desc);
gettimeofday(&amp;end, NULL);
timeval_subtract (&amp;difference, &amp;end, &amp;start);
double cpu_time_used = (double)difference.tv_sec + (double)difference.tv_usec / 1000000.0;
printf(&quot;Client Time: %.4e s\n&quot;, cpu_time_used);
}
}
int main(int argc, char **argv)
{
int n_threads = 50;  // default value
if (argc &gt; 1)
n_threads = atoi(argv[1]);
pthread_t *threads = (pthread_t*)malloc(n_threads * sizeof(pthread_t));
struct timeval start, end, difference;
gettimeofday(&amp;start, NULL);
for(int i = 0; i &lt; n_threads; i++)
{
int createRet = pthread_create(&amp;threads[i], NULL, workerThreadFunc, NULL);
if (createRet != 0)
{
printf(&quot;failed to create thread\n&quot;);
}
}
for(int i = 0; i &lt; n_threads; i++)
pthread_join(threads[i], NULL);
gettimeofday(&amp;end, NULL);
timeval_subtract (&amp;difference, &amp;end, &amp;start);
double cpu_time_used = (double)difference.tv_sec + (double)difference.tv_usec / 1000000.0;
printf(&quot;Total Client Time: %.4e s\n&quot;, cpu_time_used);
free(threads);
return 0;
}
&#39;,sizeof(client_message)); // Set port and IP the same as server-side: server_addr.sin_family = AF_INET; server_addr.sin_port = htons(46999); server_addr.sin_addr.s_addr = inet_addr(&quot;127.0.0.1&quot;); int retries = 0; struct timeval start, end, difference; double cpu_time_used; for(int i = 0; i &lt; THREAD_LOOP_COUNT; i++) { gettimeofday(&amp;start, NULL); // Create socket: socket_desc = socket(AF_INET, SOCK_STREAM, 0); if(socket_desc &lt; 0){ printf(&quot;Unable to create socket\n&quot;); return; } // Send connection request to server: while(connect(socket_desc, (struct sockaddr*)&amp;server_addr, sizeof(server_addr)) &lt; 0){ retries++; if (retries &gt; 10) { printf(&quot;Unable to connect\n&quot;); retries = 0; } usleep(5); } int retries = 0; // Send the message to server: if(send(socket_desc, client_message, strlen(&quot;client message.&quot;), 0) &lt; 0){ printf(&quot;Unable to send message\n&quot;); close(socket_desc); return; } // Receive the server&#39;s response: if(recv(socket_desc, server_message, sizeof(server_message), 0) &lt; 0){ printf(&quot;Error while receiving server&#39;s msg\n&quot;); close(socket_desc); return; } // Close the socket: close(socket_desc); gettimeofday(&amp;end, NULL); timeval_subtract (&amp;difference, &amp;end, &amp;start); double cpu_time_used = (double)difference.tv_sec + (double)difference.tv_usec / 1000000.0; printf(&quot;Client Time: %.4e s\n&quot;, cpu_time_used); } } int main(int argc, char **argv) { int n_threads = 50; // default value if (argc &gt; 1) n_threads = atoi(argv[1]); pthread_t *threads = (pthread_t*)malloc(n_threads * sizeof(pthread_t)); struct timeval start, end, difference; gettimeofday(&amp;start, NULL); for(int i = 0; i &lt; n_threads; i++) { int createRet = pthread_create(&amp;threads[i], NULL, workerThreadFunc, NULL); if (createRet != 0) { printf(&quot;failed to create thread\n&quot;); } } for(int i = 0; i &lt; n_threads; i++) pthread_join(threads[i], NULL); gettimeofday(&amp;end, NULL); timeval_subtract (&amp;difference, &amp;end, &amp;start); double cpu_time_used = (double)difference.tv_sec + (double)difference.tv_usec / 1000000.0; printf(&quot;Total Client Time: %.4e s\n&quot;, cpu_time_used); free(threads); return 0; }

答案1

得分: 0

根据@user207421的说法,问题出在TCP实现上,其中包括对重试的指数退避。无论是Golang还是C,似乎都没有一种简单的方法来改变这种行为。

答案是:如果你需要高吞吐量,不要频繁打开和关闭TCP连接,而是使用连接池。

有一些工作正在研究如何去除指数退避,下面是相关链接,但对于特定情况可能有更好的解决方案。对我来说确实有更好的解决方案。

ACM SIGCOMM计算机通信评论,“从TCP中去除指数退避”,第38卷,第5期,2008年10月。

英文:

As indicated by @user207421, the issue lies in the TCP implementation, which includes an exponential backoff on retries. Neither Golang nor C appear to have an easy way to alter this behavior.

The answer is: Don't open and close connections of TCP if you high throughput--use a connection pool.

There was some work looking at removing the exponential backoff, linked below, but there is likely a better solution for specific cases. There was for me.

ACM SIGCOMM Computer Communication Review, "Removing Exponential Backoff from TCP", Volume 38, Number 5, October 2008.

huangapple
  • 本文由 发表于 2022年4月12日 19:23:46
  • 转载请务必保留本文链接:https://go.coder-hub.com/71841771.html
匿名

发表评论

匿名网友

:?: :razz: :sad: :evil: :!: :smile: :oops: :grin: :eek: :shock: :???: :cool: :lol: :mad: :twisted: :roll: :wink: :idea: :arrow: :neutral: :cry: :mrgreen:

确定