- android - RelativeLayout 背景可绘制重叠内容
- android - 如何链接 cpufeatures lib 以获取 native android 库?
- java - OnItemClickListener 不起作用,但 OnLongItemClickListener 在自定义 ListView 中起作用
- java - Android 文件转字符串
我正在开发客户端和服务器之间的 TCP 握手。具体在客户端向服务器发送消息,服务器分析消息并提供答案。问题是,当服务器必须发回消息时,似乎出现了一些问题,即客户端和服务器被阻塞。
这是我的代码客户端:
if (connect(sock, (struct sockaddr *) &server_addr, sizeof(struct sockaddr))
== -1) {
perror("Connect");
exit(1);
}
char recv_data[2048];
first_message(user, mode, sock);
do {
bytes_recieved = recv(sock, recv_data, 1024, 0);
if (bytes_recieved == -1) {
printf("Error");
exit(1);
}
printf("BYTE RECEIVED: %d\n", bytes_recieved);
} while (bytes_recieved != 0);
recv_data[bytes_recieved] = '\0';
printf("%s", recv_data);
服务器端:
sin_size = sizeof(struct sockaddr_in);
connected = accept(sock, (struct sockaddr *) &client_addr, &sin_size);
printf("\n I got a connection from (%s , %d)",
inet_ntoa(client_addr.sin_addr), ntohs(client_addr.sin_port));
char recv_data[2048];
do {
res = length_true - total;
bytes_recieved = recv(connected, recv_data + total, res, 0);
if (bytes_recieved == -1) {
printf("Recv() failed\n");
break;
}
if (bytes_recieved > 0) {
total += bytes_recieved;
}
} while (bytes_recieved != 0);
int size_rcv = total;
recv_data[length_true - 1] = '\0';
int b = 0;
printf("DATA RECEIVED:%s\n", recv_data);
send(connected,r,strlen(r),0);
fflush(stdout);
close (sock);
exit(1);
pause();
return 0;
编辑:
void common_frame(int sock, char *mode) {
const char *string_course = "DISTRIB2016";
char *buf = (char*) malloc(22 * sizeof(char));
char *buf_first = (char*) malloc(2 * sizeof(char));
gethexes(buf_first, mode); //1 byte di modalità
gethexes(buf, string_course); //11 byte lunghezza del corso stringa
send(sock, buf, 22, 0);
send(sock, buf_first, 2, 0);
free(buf_first);
free(buf);
}
void first_command(int sock, char* user) {
char *frame = "T1";
char *buf_second = (char*) malloc(4 * sizeof(char));
char *username_length = (char*) malloc(sizeof(char));
int user_len = strlen(user);
char *us = (char*) malloc(user_len *2 * (sizeof(char)));
gethexes(us, user);
gethexes(buf_second, frame); //2 byte of first command label T1
sprintf(username_length, "%d", user_len);
send(sock, buf_second, 4, 0);
send(sock, username_length, strlen(username_length), 0); //n byte username length
send(sock, us, strlen(us), 0); //username
free(username_length);
free(buf_second);
}
void first_message(char *user, char*mode, int sock) {
unsigned short int message_length;
char *length;
int user_len;
message_length = htons(17 + strlen(user));
length = decimal_to_binary(message_length); //2 byte di lunghezza binaria in network order
send(sock, length, strlen(length), 0);
common_frame(sock, mode);
first_command(sock, user);
}
在这个实现中,客户端和服务器都停止了,服务器无法接收任何消息,但是如果我神奇地停止客户端,服务器就会正常工作,它会正确地接收和发送数据。
最佳答案
如注释中所述,您的服务器在 recv()
返回零或 -1 之前不执行任何操作,这分别意味着客户端已断开连接或中止连接。由于您的客户端没有执行任何这些操作,因此您会遇到应用程序引发的死锁。
关于c - Socket C 同时处理 recv() 和 send(),我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/36567114/
基于 socket.io 的官方网站 http://socket.io/#how-to-use , 我找不到任何术语。socket.emit 、 socket.on 和 socket.send 之间有
我正在使用 lua-socket 3.0rc1.3(Ubuntu Trusty 附带)和 lua 5.1。我正在尝试监听 unix 域套接字,我能找到的唯一示例代码是 this -- send std
这两者有什么区别? 我注意到如果我在一个工作程序中从 socket.emit 更改为 socket.send ,服务器无法接收到消息,虽然我不明白为什么。 我还注意到,在我的程序中,如果我从 sock
使用套接字在两台服务器之间发送数据是个好主意,还是应该使用 MQ 之类的东西来移动数据。 我的问题:套接字是否可靠,如果我只需要一次/有保证的数据传输? 还有其他解决方案吗? 谢谢。 最佳答案 套接字
引自 this socket tutorial : Sockets come in two primary flavors. An active socket is connected to a
我已经安装了在端口81上运行的流服务器“Lighttpd”(light-tpd)。 我有一个C程序,它使用套接字api创建的服务器套接字在端口80上监听http请求。 我希望从客户端收到端口80上的请
这是我正在尝试做的事情: 当有新消息可用时,服务器会将消息发送给已连接的客户端。另一方面,客户端在连接时尝试使用send()向服务器发送消息,然后使用recv()接收消息,此后,客户端调用close(
如何将消息发送到动态 session 室,以及当服务器收到该消息时,如何将该消息发送到其他成员所在的同一个 session 室? table_id是房间,它将动态设置。 客户: var table_i
这是我尝试但不起作用的方法。我可以将传入的消息从WebSocket连接转发到NetSocket,但是只有NetSocket收到的第一个消息才到达WebSocket后面的客户端。 const WebSo
我正在实现使用boost将xml发送到客户端的服务器。我面临的问题是缓冲区不会立即发送并累积到一个点,然后发送整个内容。这在我的客户端造成了一个问题,当它解析xml时,它可能具有不完整的xml标记(不
尝试使用Nginx代理Gunicorn套接字。 /etc/systemd/system/gunicorn.service文件 [Unit] Description=gunicorn daemon Af
我正在使用Lua套接字和TCP制作像聊天客户端和服务器这样的IRC。我要弄清楚的主要事情是如何使客户端和服务器监听消息并同时发送它们。由于在服务器上执行socket:accept()时,它将暂停程序,
我看了一下ZMQ PUSH/PULL套接字,尽管我非常喜欢简单性(特别是与我现在正在通过UDP套接字在系统中实现的自定义碎片/ack相比),但我还是希望有自定义负载平衡功能,而不是幼稚的回合-robi
我正在编写一个应用程序,其中有多个 socket.io 自定义事件,并且所有工作正常,除了这个: socket.on("incomingImg", function(data) {
在我的应用程序中,我向服务器发送了两条小消息(类似 memcached 的服务)。在类似 Python 的伪代码中,这看起来像: sock.send("add some-key 0") ignored
很抱歉再次发布此问题,但大多数相关帖子都没有回答我的问题。我在使用 socket.io 的多个连接时遇到问题我没有使用“socket.socket.connect”方法,但我从第一次连接中得到了反馈。
我尝试使用 socket.io 客户端连接到非 socket.io websocket 服务器。但我做不到。我正在尝试像这样连接到套接字服务器: var socket = io.connect('ws
我遇到了一个奇怪的问题。在我非常基本的服务器中,我有: server.listen(8001); io.listen(server); var sockets = io.sockets; 不幸的是,套
我正在使用带套接字 io 的sailsjs。帆的版本是 0.10.5。我有以下套接字客户端进行测试: var socketIOClient = require('socket.io-client');
这个问题在这里已经有了答案: What is the fundamental difference between WebSockets and pure TCP? (4 个答案) 关闭 4 年前。
我是一名优秀的程序员,十分优秀!