基本C++套接字客户端

Basic C++ sockets client

本文关键字:客户端 套接字 C++ 基本      更新时间:2023-10-16

我正在尝试从头开始重新创建一个用于工作的GUI,这将是我的第一个网络应用程序。为此,我一直在阅读我能找到的所有 C/C++ 套接字教程信息,但我用这些信息将自己编码成无用的几百行。

以下代码有两个问题(我知道):

1)一旦它连接到我应该侦听的端口,它应该立即收到字符串99999999%connect。此时,我应该能够发送0并开始接收当天数据的开始。但是,我没有收到第一条消息。

2)我不确定如何以不会导致GTK UI锁定的方式编写它。我知道这是一些基本的东西,但整个事情只是对插座的即兴尝试。

无论如何,这是代码:

#include <stdlib.h>
#include <string.h>
#include <sys/types.h>
#include <sys/time.h>
#include <sys/socket.h>
#include <netdb.h>
#include <arpa/inet.h>
#include <gtk/gtk.h>
#define UNUSED(x) (void) x
typedef struct
{
  GtkWidget *window, *grid,
            *labelHost, *labelPort, *textFieldHost, *textFieldPort,
            *buttonConnect;
}uiWidgets;
int sockfd = 0;
gboolean on_close_cleanup();
void buttonConnect_on_clicked(GtkButton *button, uiWidgets* widgets);
void connect_to_logview(struct addrinfo *hostname_result);
void listen_for_logview();
int main()
{
  uiWidgets widgets;
  gtk_init(NULL, NULL);
  widgets.window = gtk_window_new(GTK_WINDOW_TOPLEVEL);
  gtk_window_set_title(GTK_WINDOW(widgets.window), "SG GUI V3.00");
  g_signal_connect(widgets.window, "destroy", gtk_main_quit, nullptr);
  g_signal_connect(widgets.window, "delete-event", G_CALLBACK(on_close_cleanup),
                   nullptr);
  widgets.labelHost = gtk_label_new("Host");
  widgets.labelPort = gtk_label_new("Port");
  widgets.textFieldHost = gtk_entry_new();
  widgets.textFieldPort = gtk_entry_new();
  widgets.buttonConnect = gtk_button_new_with_label("Connect");
  g_signal_connect(widgets.buttonConnect, "clicked",
                   G_CALLBACK(buttonConnect_on_clicked),
                   &widgets);
  widgets.grid = gtk_grid_new();
  gtk_grid_set_row_spacing(GTK_GRID(widgets.grid), 5);
  gtk_grid_set_column_homogeneous(GTK_GRID(widgets.grid), true);
  gtk_grid_set_row_homogeneous(GTK_GRID(widgets.grid), true);
  gtk_grid_attach(GTK_GRID(widgets.grid), widgets.labelHost, 0, 0, 1, 1);
  gtk_grid_attach(GTK_GRID(widgets.grid), widgets.labelPort, 2, 0, 1, 1);
  gtk_grid_attach(GTK_GRID(widgets.grid), widgets.textFieldHost, 0, 1, 2, 1);
  gtk_grid_attach(GTK_GRID(widgets.grid), widgets.textFieldPort, 2, 1, 1, 1);
  gtk_grid_attach(GTK_GRID(widgets.grid), widgets.buttonConnect,  1, 2, 1, 1);
  gtk_container_add(GTK_CONTAINER(widgets.window), widgets.grid);
  gtk_widget_show_all(widgets.window);
  gtk_main();
  return 0;
}
gboolean on_close_cleanup()
{
  close(sockfd);
  return false;
}
void buttonConnect_on_clicked(GtkButton *button, uiWidgets* widgets)
{
  UNUSED(button);
  struct addrinfo hints, *hostname_result;
  struct sockaddr_in *hostname_address;
  const gchar *hostname = gtk_entry_get_text(GTK_ENTRY(widgets->textFieldHost));
  int return_value;
  gchar addr[INET_ADDRSTRLEN];
  memset(&hints, 0, sizeof(hints));
  hints.ai_family = AF_INET;
  hints.ai_socktype = SOCK_STREAM;
  if((return_value = getaddrinfo(hostname,
                          gtk_entry_get_text(GTK_ENTRY(widgets->textFieldPort)),
                          &hints, &hostname_result)) != 0)
  {
    g_print("getaddrinfo: %sn", gai_strerror(return_value));
    return;
  }
  for(struct addrinfo *info_itr = hostname_result; info_itr != nullptr;
      info_itr = info_itr->ai_next)
  {
    hostname_address = (struct sockaddr_in *)info_itr->ai_addr;
    inet_ntop(AF_INET, &(hostname_address->sin_addr), addr, INET_ADDRSTRLEN);
    g_print("%s:%sn", addr, gtk_entry_get_text(GTK_ENTRY(widgets->textFieldPort)));
  }
  connect_to_logview(hostname_result);
  freeaddrinfo(hostname_result);
}
void connect_to_logview(struct addrinfo *hostname_result)
{
  int rv = 0;
  sockfd = socket(hostname_result->ai_family, hostname_result->ai_socktype,
                      hostname_result->ai_protocol);
  if(sockfd == -1)
  {
    perror("socket");
  }
  else
  {
    rv = connect(sockfd, hostname_result->ai_addr, hostname_result->ai_addrlen);
    if(rv == -1)
    {
      perror("connect");
    }
    else
    {
      g_print("%s: Looks like we got something!n", __FUNCTION__);
      listen_for_logview();
    }
  }
}
void listen_for_logview()
{
  fd_set fdset;
  gchar buf[256];
  int nbytes = 0;
  bool exit = false;
  struct timeval tv;
  tv.tv_sec = 2;
  tv.tv_usec = 0;
  FD_ZERO(&fdset);
  while(!exit)
  {
    if(select(sockfd+1, &fdset, NULL, NULL, &tv) == -1)
    {
      perror("select");
      exit = true;
      break;
    }
    if(FD_ISSET(sockfd, &fdset))
    {
      if((nbytes = recv(sockfd, buf, sizeof buf, 0)) <= 0)
      {
        perror("recv");
        close(sockfd);
        FD_CLR(sockfd, &fdset);
        exit = true;
        break;
      }
      else
      {
        g_print("!!!n%snn", buf);
        close(sockfd);
        FD_CLR(sockfd, &fdset);
        exit = true;
        break;
      }
    }
    else
    {
      g_print("Timed out!n");
      tv.tv_sec = 2;
    }
  }
}

那么,这里出了什么问题呢?我猜答案是我只是滥用了我拥有的工具。除了上述两个不当行为之外,我很感激听到您在这里看到的任何其他结构/技术问题。

提前感谢您的帮助。

你正在将 FD 集归零并且从未在其中放入任何内容,因此您正在选择一个空的 FD 集,因此没有任何东西被选为可读、可写等等,所以你从来没有真正阅读过。您需要使用适当的FD_*宏将sockfd添加到 FD 集。

您还需要在循环中每次重置超时结构。

但是,由于您使用的是阻止模式,因此根本不需要使用select()。只需做recv().它会阻止。

注意 如果recv()返回零,则为流结束:对等方已断开连接。这不是错误,在这种情况下调用perror()只会打印随机错误消息。别这样。

您似乎使用了阻塞套接字。 connect阻塞线程,直到它连接或失败。

您需要使用非阻塞套接字,以便异步建立连接。