ACE 收数 cpu 占用率高

jj601

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 编辑 ]

modern

你的意思是sock_.recv(buffer, sizeof (buffer))导致的cpu暴增，
还是 listTT2000.InsertNode(listTT2000.m_listLength+1,buffer);导致的数据暴增呢？

如果是前者，把接收缓存区设置大一点试一下，
如果是后者，那么将所有recv之后的代码都注释掉，
判断是否是自己处理链表的时候出的问题、、

jj601

谢谢了，确实是其他引起的

jj601

那可以怎么来处理我的数据呢，我需要在另外一个线程中处理我的数据

winston

使用消息队列进行缓冲。让另外一个线程进行处理即可。

jj601

我数据解析这一块，需要所有的数据是相关联的。我每次只取用其中的156byte做解析。如果采用消息队列的话，那每次取出来的数据我如果要保持连贯性的话，还不是一样要把数据取出来，串成链表，这样不回到原来的问题上去了么？
或者ace 的消息队列有其他的处理方法，能不能给个提示呢，我再看
谢谢了

steven99ca

你的问题和刚才看到的一个有点类似，
“现在的问题是：我如果使用超时，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来避免内存拷贝。

jj601

现在我已经发现内存爆增的情况是由于我将数据插入链表造成的。
我需要的数据是顺序解析，每次来的数据放到前一次收到数据的后面，使用message block 的话，我每次发送一次message 到解析线程，也需要将其中的data block 串行起来，这不是仍然要耗资源么，或者说，message block 还有其他的使用方法我不知道的

modern

解析的线程，可以使用ACE_Task,
ACE_Task自身提供的ACE_Message_Quene可以无缝的
与ACE_Message_Block结合起来。
看书C++NPV2第6.2节，有详细的而介绍与使用例子。

wishel

原帖由 jj601 于 2009-7-1 09:38 发表
现在我已经发现内存爆增的情况是由于我将数据插入链表造成的。
我需要的数据是顺序解析，每次来的数据放到前一次收到数据的后面，使用message block 的话，我每次发送一次message 到解析线程，也需要将其中的data block 串行 ...

是内存暴增还是cpu暴增？
现在确认问题是由于insert操作，而不是解析操作么？