int ClientService::handle_input(ACE_HANDLE fd)
{
//printf("服务器连接上了");
const size_t INPUT_SIZE = 4096;
char buffer[INPUT_SIZE];
int i;
ssize_t recv_cnt;
if ((recv_cnt = this->sock_.recv(buffer, sizeof (buffer)),100) <= 0)
{
//接受到的数据为0个字节，表明对端已关闭其socket。
//返回-1，表示工作已完成。
return -1;
}
for(i=0;i<recv_cnt;i++)
{
printf("%d",buffer);
}
//将数据插入链表
for(i=0;i<recv_cnt;i++)
{
listTT2000.InsertNode(listTT2000.m_listLength+1,buffer);
}
return 0;
}
我需要做的事：链接成功，接收服务器端接收过来的数据，放入链表中坐解析。我使用的是reactor 模型。
现在的问题是：我如果使用超时，sock_.recv(buffer, sizeof (buffer)),100)，则基本处于超时状态，返回值一直为-1.这里，超时和退出分不开。
如果我不使用超时，sock_.recv(buffer, sizeof (buffer))，则当一批数据来时，cpu 使用率爆增。这种问题该怎样来解决呢，谢谢了
[ 本帖最后由 jj601 于 2009-6-30 11:16 编辑 ]
最新回复
还是 listTT2000.InsertNode(listTT2000.m_listLength+1,buffer);导致的数据暴增呢？
如果是前者，把接收缓存区设置大一点试一下，
如果是后者，那么将所有recv之后的代码都注释掉，
判断是否是自己处理链表的时候出的问题、、
或者ace 的消息队列有其他的处理方法，能不能给个提示呢，我再看
谢谢了
“现在的问题是：我如果使用超时，sock_.recv(buffer, sizeof (buffer)),100)，则基本处于超时状态，返回值一直为-1.这里，超时和退出分不开。”
在reactor的回教handle_input中，一定是select或waitformultiobjects返回，所以，recv一定不用延时。
“如果我不使用超时，sock_.recv(buffer, sizeof (buffer))，则当一批数据来时，cpu 使用率爆增。这种问题该怎样来解决呢，谢谢了”
recv一般不会导致CPU问题,可能你有大量的内存拷贝，好像不应该loop吧？
//for(i=0;i<recv_cnt;i++) //Why?
{
listTT2000.InsertNode(listTT2000.m_listLength+1,buffer);
}
"ace 的消息队列有其他的处理方法，能不能给个提示呢，我再看'
更好的办法是使用ACE_Message_block来避免内存拷贝。
我需要的数据是顺序解析，每次来的数据放到前一次收到数据的后面，使用message block 的话，我每次发送一次message 到解析线程，也需要将其中的data block 串行起来，这不是仍然要耗资源么，或者说，message block 还有其他的使用方法我不知道的
ACE_Task自身提供的ACE_Message_Quene可以无缝的
与ACE_Message_Block结合起来。
看书C++NPV2第6.2节，有详细的而介绍与使用例子。
QUOTE:
是内存暴增还是cpu暴增？现在确认问题是由于insert操作，而不是解析操作么？
按常理，链表的enque和deque操作都是O(1)的复杂度，cpu很忙可能是你一次传的数据过多，而现在的程序是一个byte循环一次，运算量不小。也有可能你的解析算法比较复杂，运算量大。
另外
for(i=0;i<recv_cnt;i++)
{
printf("%d",buffer);
}
这段代码有点问题