- android - 多次调用 OnPrimaryClipChangedListener
- android - 无法更新 RecyclerView 中的 TextView 字段
- android.database.CursorIndexOutOfBoundsException : Index 0 requested, 光标大小为 0
- android - 使用 AppCompat 时,我们是否需要明确指定其 UI 组件(Spinner、EditText)颜色
问题: 我有两个 c 程序,一个发送 UDP 消息,然后得到响应并打印它。另一个接收 UDP 消息,对其进行修改,然后发回。我正确收到消息,正确修改(打印正常)并发送。我在另一端收到消息,但 recv 返回值为 0。
问题:为什么我得到了正确的消息,但没有返回消息的长度?这很难检查我是否收到了正确长度的消息,因为我的目标是访问状态消息的第 320 个字节
我找到了 this但我没有使用 strlen(),加上缓冲区实际上包含正确的消息。我也没有断开套接字,因为我使用的是 UDP。
这是客户端的代码:
#include <stdlib.h>
#include <stdio.h>
#include <string.h>
#include <netdb.h>
#include <sys/socket.h>
#define SERVICE_PORT 9090
#define BUFLEN 2048
#define MSGS 5
int main(void)
{
struct sockaddr_in myaddr, remaddr;
int fd, i, slen=sizeof(remaddr);
char *server = "127.0.0.1";
char buf[BUFLEN];
ssize_t msglen;
if ((fd=socket(AF_INET, SOCK_DGRAM, 0))==-1)
printf("socket not created\n");
memset((char *)&myaddr, 0, sizeof(myaddr));
myaddr.sin_family = AF_INET;
myaddr.sin_addr.s_addr = htonl(INADDR_ANY);
myaddr.sin_port = htons(7096);
if (bind(fd, (struct sockaddr *)&myaddr, sizeof(myaddr)) < 0) {
perror("bind failed");
return 0;
}
memset((char *) &remaddr, 0, sizeof(remaddr));
remaddr.sin_family = AF_INET;
remaddr.sin_port = htons(SERVICE_PORT);
if (inet_aton(server, &remaddr.sin_addr)==0) {
fprintf(stderr, "inet_aton() failed\n");
exit(1);
}
char msg[4096];
memset(msg, 0, 4096);
for (i=0; i < MSGS; i++) {
printf("Sending packet %d to %s port %d\n", i, server, SERVICE_PORT);
sprintf(buf, "This is packet %d", i);
if (sendto(fd, buf, sizeof(buf), 0, (struct sockaddr *)&remaddr, slen)==-1)
perror("sendto");
memset(msg, 0, 4096);
if(msglen = recv(fd, msg, sizeof(msg), MSG_WAITALL) == -1){
printf("Bad recv\n");
}
printf("recieved %d bytes: %s\n", msglen, msg);
}
close(fd);
return 0;
}
这是服务器的代码:
#include <arpa/inet.h>
#include <netinet/in.h>
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <unistd.h>
#include <linux/ip.h> /* for ipv4 header */
#include <linux/udp.h> /* for upd header */
#define ADDR_TO_BIND "127.0.0.1"
#define PORT_TO_BIND 9090
#define SERVICE_PORT 7096
#define MSG_SIZE 256
#define HEADER_SIZE (sizeof(struct iphdr) + sizeof(struct udphdr))
int main(void) {
int raw_socket, fd;
struct sockaddr_in sockstr, remaddr;
socklen_t socklen;
int retval = 0;
char msg[MSG_SIZE];
ssize_t msglen;
if ((raw_socket = socket(AF_INET, SOCK_DGRAM, 0)) == -1) {
perror("socket");
return 1;
}
if ((fd = socket(AF_INET, SOCK_DGRAM, 0)) == -1) {
perror("socket");
return 1;
}
sockstr.sin_family = AF_INET;
sockstr.sin_port = htons(PORT_TO_BIND);
sockstr.sin_addr.s_addr = inet_addr(ADDR_TO_BIND);
socklen = (socklen_t) sizeof(sockstr);
if (bind(raw_socket, (struct sockaddr*) &sockstr, socklen) == -1) {
perror("bind");
retval = 1;
goto _go_close_socket;
}
if(bind(fd, (struct sockaddr*) &remaddr, socklen) == -1){
perror("bind");
}
memset(msg, 0, MSG_SIZE);
while(1){
if ((msglen = recv(raw_socket, msg, MSG_SIZE, 0)) == -1) {
perror("recv");
retval = 1;
goto _go_close_socket;
}
memset((char *) &remaddr, 0, sizeof(remaddr));
remaddr.sin_family = AF_INET;
remaddr.sin_port = htons(SERVICE_PORT);
if (inet_aton(ADDR_TO_BIND, &remaddr.sin_addr)==0) {
fprintf(stderr, "inet_aton() failed\n");
exit(1);
}
unsigned char buf[4096];
msg[msglen] = '\0';
printf("recieve %d bytes: %s\n", msglen, msg);
sprintf(buf, "Your msg is: %s\n",msg );
int slen=sizeof(remaddr);
if (sendto(fd, buf, sizeof(buf), 0, (struct sockaddr *)&remaddr, slen)==-1){
printf("send failed");
}
printf("sent: %s\n", buf);
}
_go_close_socket:
close(raw_socket);
return retval;
}
运行客户端的输出是:
Sending packet 0 to 127.0.0.1 port 9090
recieved 0 bytes: Your msg is: This is packet 0
Sending packet 1 to 127.0.0.1 port 9090
recieved 0 bytes: Your msg is: This is packet 1
Sending packet 2 to 127.0.0.1 port 9090
recieved 0 bytes: Your msg is: This is packet 2
Sending packet 3 to 127.0.0.1 port 9090
recieved 0 bytes: Your msg is: This is packet 3
Sending packet 4 to 127.0.0.1 port 9090
recieved 0 bytes: Your msg is: This is packet 4
运行服务器的输出是:
recieve 256 bytes: This is packet 0
sent: Your msg is: This is packet 0
recieve 256 bytes: This is packet 1
sent: Your msg is: This is packet 1
recieve 256 bytes: This is packet 2
sent: Your msg is: This is packet 2
recieve 256 bytes: This is packet 3
sent: Your msg is: This is packet 3
recieve 256 bytes: This is packet 4
sent: Your msg is: This is packet 4
如您所见,我在服务器上收到的消息更改为开头为“your msg is:”,我在客户端看到了这一点,但返回值的长度为 0。这是为什么?
这段代码只是对示例 UDP 服务器客户端的代码示例稍作修改,因此如果指出代码质量不好,我不会被冒犯!
编辑 这已解决,这是将 recv() 调用包装在括号中的问题,因此条件存储在 msglen 中而不是实际返回值中。请参阅下面的答案
最佳答案
我能够解决这个问题,似乎我忘记了将 recv 的 if 语句括在括号中,所以我为 msglen 分配了条件的 bool 值
recv(fd, msg, sizeof(msg), 0) == -1
当然是 0,因为返回值不等于 -1。
修复是
if((msglen = recv(fd, msg, sizeof(msg), 0)) = -1)
感谢那些试图帮助他们的人
关于c - 收到UDP报文但recv返回0,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/46592649/
我有一个静态类。 static class AppDirectory { public static string PACSTEMP = Path.Combine(Path.GetTempPa
我已经设置了一个启用了推送通知的 iOS 应用。 我可以将消息推送到应用程序,例如角标(Badge)计数工作并相应更新。 但我从未在锁屏或其他地方看到标准的推送通知弹出窗口,但手机会振动,因此消息会通
我们有一个带有 Web 应用程序和一堆 Windows 服务的系统,它们在做一些后台工作。 每当我们需要对系统进行更实质性的更改时,我们最终不得不发出 IIS 重置,然后手动重新启动所有相关的 Win
我有以下几行 John SMith: A Pedro Smith: B Jonathan B: A John B: B Luis Diaz: A Scarlet Diaz: B 我需要获得所有获得
我正在编写一个 Java 客户端(在 weblogic 10.3 上)来调用一个安全的网络服务。我已获得安装在 cacerts、DemoIdentity.jks 和 DemoTrust,jks 中的客
已关闭。此问题不符合Stack Overflow guidelines 。目前不接受答案。 这个问题似乎偏离主题,因为它缺乏足够的信息来诊断问题。 更详细地描述您的问题或 include a mini
我正在尝试调用void方法addToList,该方法将通过用户传递给它的两个字符串除外。我检查了dataSource类,以确保它确实接受了那些作为参数。问题是我在该方法调用上始终收到标识符>预期错误,
我的任务:使用scanner方法从一行数据中提取字符串、 float 和整数。 数据格式为: Random String, 240.5 51603 Another String, 41.6 59087
这个问题已经有答案了: What causes a java.lang.ArrayIndexOutOfBoundsException and how do I prevent it? (25 个回答)
首先我实例化一个游戏状态 class GameState extends state{ ArrayList levels; int currentLevelID; public GameState()
已关闭。这个问题是 not reproducible or was caused by typos 。目前不接受答案。 这个问题是由拼写错误或无法再重现的问题引起的。虽然类似的问题可能是 on-top
我有一个实现为单例的 Controller 对象,它有一个可以随时驱逐对象的缓存。当一个对象即将被删除时,我想通知任何使用此 Controller 的类,以便它们能够做出适当的响应。我对这种行为的第一
因此,我尝试跨集群发送消息,该消息将包含一个 User 对象,该对象是一个可序列化类。 当我发送 String 或 int 时,它工作正常,消息发送没有问题,并且集群上的所有 channel 都收到它
我试图创建的程序是一个基本游戏,用户输入网格大小,选择 block 接收增加分数的奖品、从分数中夺走分数的强盗或结束游戏的炸弹。我收到堆栈流错误,但我不明白为什么? 抱歉,代码量很大,我只是无法找到问
使用此代码我会得到什么ConcurrentModificationException?我有一个同步(监听器)锁。 private void notifyListeners(MediumRenditio
我想在捕获 DeadlineExceededError 后正确退出。我还剩下多少钱来清理? 例如, try: do_some_work() except DeadlineExceededError
我有 2 个 Intranet 站点: http://intranetv1/ http://intranetv2/ v1基于.NET 1.1,v2基于.NET 3.5 在 v1 上,我创建了一个网页,
我有一个在 Linux 3.12 上运行的 C 程序。该程序产生几个子进程。其中一个进程会生成一个线程,该线程运行一段时间然后终止。当该子进程运行时,它会执行 epoll_wait()。 epoll_
我能够将 APNS 集成到我的应用程序中。现在我想在用户点击它或用户在使用应用程序时收到通知时处理通知。我使用下面的代码在收到通知时显示警报对话框: func application(applicat
当我试图在浏览器上运行这段代码时,出现了以下错误。"错误响应错误代码:501消息:不支持的方法(“POST”)。错误码解释:501-服务器不支持该操作。" 浏览器控制台出现以下错误: "1.加载资源失
我是一名优秀的程序员,十分优秀!