- android - 多次调用 OnPrimaryClipChangedListener
- android - 无法更新 RecyclerView 中的 TextView 字段
- android.database.CursorIndexOutOfBoundsException : Index 0 requested, 光标大小为 0
- android - 使用 AppCompat 时,我们是否需要明确指定其 UI 组件(Spinner、EditText)颜色
我的客户端程序首先连接到服务器,然后服务器发送一个文件,然后客户端输入一个命令并将其发送到服务器并接收结果。我想通过输入命令和非阻塞套接字的非阻塞io来实现这一点。但是我的程序无法从 stdin 读取输入。当我在 read_set 中仅设置 stdin 时它可以工作,但在这种情况下它不起作用。这是我的客户端代码:
main (int argc, char *argv[])
{
int len, rc,max_sd;
int sockfd;
int on=1;
char recv_buff[100]="";
char command[100]="";
char result[100]="";
char instr_buff[100]="";
struct sockaddr_in addr;
struct timeval timeout;
fd_set read_set,write_set;
/*************************************************/
/* Create an AF_INET stream socket */
/*************************************************/
sockfd = socket(AF_INET, SOCK_STREAM, 0);
if (sockfd < 0)
{
perror("socket() failed");
exit(-1);
}
rc = setsockopt(sockfd, SOL_SOCKET, SO_REUSEADDR,(char *)&on, sizeof(on)); // Allow socket descriptor to be reuseable
if(rc<0)
{
perror("setsockopt() failed");
close(sockfd);
exit(-1);
}
//Set socket to be non-blocking.
rc = ioctl(sockfd, FIONBIO, (char *)&on);
if(rc<0)
{
perror("ioctl() faild");
close(sockfd);
exit(-1);
}
//making stdin to be non-blocking
rc = ioctl(0, FIONBIO, (char *)&on);
if(rc<0)
{
perror("ioctl() faild");
close(sockfd);
exit(-1);
}
/*************************************************/
/* Initialize the socket address structure */
/*************************************************/
memset(&addr, 0, sizeof(addr));
addr.sin_family = AF_INET;
addr.sin_addr.s_addr = htonl(INADDR_ANY);
addr.sin_port = htons(SERVER_PORT);
/*************************************************/
/* Connect to the server */
/*************************************************/
int count=0;
do
{
rc = connect(sockfd,(struct sockaddr *)&addr,sizeof(struct sockaddr_in));
count++;
}while(rc<0&&count<20);
if(rc<0)
{
printf("can not connect to server\n");
exit(-1);
}
else
printf("Connect completed.\n");
timeout.tv_sec = 60;
timeout.tv_usec = 0;
FD_ZERO(&read_set);
FD_ZERO(&write_set);
FD_SET(sockfd,&read_set);
FD_SET(0,&read_set);
while(1)
{
rc=select(sockfd+1,&read_set,&write_set,NULL,&timeout);
if(rc<0)
{
perror("select failed()\n");
break;
}
if(rc==0)
{
printf("select timed out.End Program\n");
break;
}
if(FD_ISSET(sockfd,&write_set))
{
//sending data
rc=send(sockfd,command,strlen(command)+1,0);
if(rc<0)
{
perror("sending command failed");
break;
}
if(rc==0)
{
printf("connection closed by server\n");
break;
}
printf("command send\n");
FD_CLR(sockfd,&write_set);
}
if(FD_ISSET(sockfd,&read_set))
{
//receiving data
rc=recv(sockfd,recv_buff,sizeof(recv_buff),0);
if (rc < 0)
{
if(errno == EAGAIN||errno == EWOULDBLOCK)
{
printf("no message\n");
continue;
}
perror(" recv() failed");
break;
}
if(rc==0)
{
printf("connection closed by server\n");
break;
}
//data received
printf("data received\n");
//check to see if is instr.conf or result
if(recv_buff[strlen(recv_buff)-1]=='@') //is file
{
//save to instr_buff
strcpy(instr_buff,recv_buff);
}
else
{
//result received
printf("Result:\n");
printf("%s",recv_buff);
}
printf("Enter Command:\n");
}
if(FD_ISSET(0,&read_set))
{
scanf("%s",command);
FD_SET(sockfd,&write_set);
}
}//end of while
close(sockfd);
}
最佳答案
请记住,select
updates 您传入的读取、写入和异常 fd_set
项。这意味着如果您选择两个可能的输入并且其中一个准备就绪,读取集中只有一位设置:
/* read_set has two bits set here ... */
rc1 = select(maxfd, &read_set, ...);
/* but now read_set has only one bit set here */
rc2 = select(maxfd, &read_set, ...);
第二个 select
调用会检查多少个文件描述符?只有一个“准备好读取”,第一次调用清除了另一个描述符的位。
请注意,您的循环永远不会重新初始化 read_set
。因此,即使您没有直接连续调用两次 select
,您实际上是在调用 select
并在第二次和以后的行程中清除了一些位循环。
(使用 select
时的一个典型习惯是拥有用于输入的“主集”,并复制它们以在调用中进行修改:
copy_reads = master_reads;
copy_writes = master_writes;
rc = select(maxfd, ©_reads, ©_writes, ...);
然后根据需要在 ©_reads 和 ©_writes 上使用 FD_ISSET
。或者,您可以使用 FD_ZERO
并在循环的每次行程中重建整个集合。另一种完全绕过这个问题的方法是使用 poll
,甚至 epoll
或 kqueues 或类似的。)
关于c - 非阻塞套接字和io,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/9748568/
我正在维护一些 Java 代码,我目前正在将它们转换为 C#。 Java 代码是这样做的: sendString(somedata + '\000'); 在 C# 中,我正在尝试做同样的事情: sen
如何确定函数中传递的参数是字符串还是字符(不确定如何正确调用它)文字? 我的函数(不正确): void check(const char* str) { // some code here }
我真的不知道如何准确地提出这个问题,但我希望标题已经说明了这一点。 我正在寻找一种方法(一个框架/库),它提供了执行 String.contains() 函数的能力,该函数告诉我给定的字符串是否与搜索
我正在尝试编写一些读取 Lambda 表达式并输出 beta 缩减版本的东西。 Lambda 的类型如下:\variable -> expression,应用程序的形式为 (表达式) (表达式)。因此
StackOverflow 上的第 1 篇文章,如果我没能把它做好,我深表歉意。我陷入了一个愚蠢的练习,我需要制作一个“刽子手游戏”,我尝试从“.txt”文件中读取单词,然后我得到了我的加密函数,它将
我想在 Groovy 中测试我的 Java 自定义注释,但由于字符问题而未能成功。 Groovyc: Expected 'a' to be an inline constant of type cha
当我尝试在单击按钮期间运行 javascript location.href 时,出现以下错误“字 rune 字中的字符过多”。 最佳答案 这应该使用 OnClientClick相反? 您可能还想停
我想要类似的东西: let a = ["v".utf8[0], 1, 2] 我想到的最接近的是: let a = [0x76, 1, 2] 和 "v".data(using: String.Encod
有没有办法在 MySQL 中指定 Unicode 字 rune 字? 我想用 Ascii 字符替换 Unicode 字符,如下所示: Update MyTbl Set MyFld = Replace(
阅读 PNG 规范后,我有点惊讶。我读过字 rune 字应该用像 0x41 这样的二进制值进行硬编码,而不是在(程序员友好的)'A' 中。问题似乎是在具有不同底层字符集的不同系统上编译期间字 rune
考虑一个具有 UTF-8 执行字符集的 C++11 编译器(并且符合要求 char 类型为有符号 8 位字节的 x86-64 ABI) . 字母 Ä(元音变音)具有 0xC4 的 unicode 代码
为什么即使有 UTF-8 字符串文字,C11 或 C++11 中也没有 UTF-8 字 rune 字?我知道,一般来说,字 rune 字表示单个 ASCII 字符,它与单字节 UTF-8 代码点相同,
我怎样才能用 Jade 做到这一点? how would I do this 我几乎可以做任何事情,除了引入一个 span 中间句子。 最佳答案 h3.blur. how would I do t
这似乎是一个非常简单的问题,但我只是想澄清我的疑问。我正在查看其他开发人员编写的代码。有一些涉及 float 的计算。 示例:Float fNotAvlbl = new Float(-99); 他为什
我想知道第 3 行“if dec:”中的“dec”是什么意思 1 def dec2bin(dec): 2 result='' 3 if dec:
我试图在字符串中查找不包含任何“a”字符的单词。我写了下面的代码,但它不起作用。我怎么能对正则表达式说“不包括”?我不能用“^”符号表示“不是”吗? import re string2 = "asfd
这个问题在这里已经有了答案: Is floating point math broken? (31 个答案) Is floating point arbitrary precision availa
我正在创建一个时尚的文本应用程序,但在某些地方出现错误(“字 rune 字中的字符太多”)。我只写了一个字母,但是当我粘贴它时,它会转换成许多这样的字母:“\uD83C\uDD89”,原始字母是“🆉
我正在尝试检查用户是否在文本框中输入了一个数字值,是否接受了小数位。非常感谢任何帮助。 Private Sub textbox1_AfterUpdate() If IsNumeric(textbox1
我知道一个 Byte 是 8 位,但其他的代表什么?我正在参加一个使用摩托罗拉 68k 架构的汇编类(class),我对目前的词汇感到困惑。 最佳答案 如 operator's manual for
我是一名优秀的程序员,十分优秀!