基本C++套接字客户端
Basic C++ sockets client
我正在尝试从头开始重新创建一个用于工作的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
阻塞线程,直到它连接或失败。
您需要使用非阻塞套接字,以便异步建立连接。
相关文章:
- 在 1 个服务器 n 客户端套接字 C++ MFC 应用程序中更新数据的客户端
- TCP 服务器的异步读取使用 boost::asio 打印客户端套接字发送的数据
- 我正在编写一个简单的客户端套接字应用程序,但在连接后服务器收到一个空缓冲区
- 防止客户端套接字程序崩溃CPP Google Protobuf
- 为什么在此 UDP 客户端/服务器示例中没有必要绑定客户端套接字?
- 客户端套接字是可绑定的,但不可连接,因为已在使用中
- 是否可以寻址另一个网络中的服务器/客户端套接字?(C++)
- 关闭客户端套接字时如何防止服务器关闭?C++
- 多连接客户端套接字应用程序C++
- C 选择仅检查最后一个客户端套接字
- 在两个客户端套接字之间发送数据
- Qt 5: 如何制作"pure c++"客户端套接字?
- Winsock 客户端套接字无效
- C++面向对象的客户端套接字应用程序设计
- 如何强制 udp 服务器接收的 udp 客户端套接字绑定到特定客户端端口
- 客户端套接字连接() 在服务器 accept() 超时后成功
- 如果客户端的互联网断开连接,客户端套接字不会关闭。如何在服务器中检测此事件?
- 客户端套接字在c++中发送到服务器
- 服务器和客户端套接字连接问题重新。send(), accept() 和多线程
- 使用c++ TCP客户端套接字在特定的网络接口Linux/Unix