2

Libevent 很棒，到目前为止我很喜欢它。但是，在回显服务器上，写入仅在第二次写入时发送到套接字。我的写作来自另一个线程，一个与数据库对话并进行一些最小数据按摩的泵线程。

我通过为写入设置回调来验证这一点：

bufferevent_setcb( GetBufferEvent(), DataAvailable, DataWritten, HandleSocketError, this );

调用 bufferevent_flush( m_bufferEvent, EV_READ|EV_WRITE, BEV_NORMAL ) 似乎没有任何效果。

这是设置，以防万一我把它搞砸了。为了获得一些帮助，我极大地简化了代码库中的开销。这包括套接字的初始化，我的线程初始化等。这是一个多线程的应用程序，所以那里可能存在一些问题。我从这个开始：

m_LibEventInstance = event_base_new();
evthread_use_windows_threads();
m_listener = evconnlistener_new_bind( m_LibEventInstance, 
         OnAccept, 
         this,
         LEV_OPT_CLOSE_ON_FREE | LEV_OPT_CLOSE_ON_EXEC | LEV_OPT_REUSEABLE, 
         -1,// no maximum number of backlog connections
         (struct sockaddr*)&ListenAddress, socketSize );

   if (!m_listener) {
          perror("Couldn't create listener");
          return false;
   }
   evconnlistener_set_error_cb( m_listener, OnSystemError );

AFAIK，这是从样本中复制和粘贴的，所以它应该可以工作。我的 OnAccept 执行以下操作：

void  OnAccept( evconnlistener* listenerObj, evutil_socket_t newConnectionId, sockaddr* ClientAddr, int socklen, void* context )
{
    // We got a new connection! Set up a bufferevent for it. 
    struct event_base*  base = evconnlistener_get_base( listenerObj );
    struct bufferevent* bufferEvent = bufferevent_socket_new( base, newConnectionId, BEV_OPT_CLOSE_ON_FREE );

   bufferevent_setcb( GetBufferEvent(), DataAvailable, DataWritten, 
                                   HandleSocketError, this );

  // We have to enable it before our callbacks will be called. 
  bufferevent_enable( GetBufferEvent(), EV_READ | EV_WRITE );

  DisableNagle( m_connectionId );
}

现在，我只需响应传入的数据并将其存储在缓冲区中以供以后处理。这是一个多线程的应用程序，所以我稍后会处理数据，按摩它，或者向客户端返回响应。

void     DataAvailable( struct bufferevent* bufferEventObj, void* arg )
{
const U32   MaxBufferSize = 8192;
   MyObj*   This = (MyObj*) arg;
   U8          data[ MaxBufferSize ];
   size_t      numBytesreceived;

   /* Read 8k at a time and send it to all connected clients. */
   while( 1 )
   {
      numBytesreceived = bufferevent_read( bufferEventObj, data, sizeof( data ) );
      if( numBytesreceived <= 0 ) // nothing to send
      {
         break;
      }

      if( This )
      {
         This->OnDataReceived( data, numBytesreceived );
      }
   }
}

发生的最后一件事是，一旦我查找数据，打包到缓冲区中，然后在线程时间片上执行以下操作：

bufferevent_write( m_bufferEvent, buffer, bufferOffset );

它永远不会第一次发送。为了让它发送，我必须发送第二个充满数据的缓冲区。

这种行为正在杀死我，我已经花了很多时间。有任何想法吗？

//------------------------------------------------ --------

我终于放弃了，改用了这个 hack……没有足够的信息告诉我为什么 libevent 没有写入套接字。这工作得很好。

int result = send( m_connectionId, (const char* )buffer, bufferOffset, 0 );
4

1 回答 1

-1

我也遇到了问题！我花了一天时间解决这个问题。最后，我解决了。

当您调用的线程时event_base_dispatch，它将处于休眠状态，直到任何信号量将其唤醒。因此，当它休眠时，您调用bufferevent_write，bufferevent 的 fd 会添加到事件列表中，但直到下一次才会 epoll。所以你必须在调用后发送信号量来唤醒调度线程bufferevent_write。您可以使用的方式是设置一个事件绑定对套接字并将其添加到event_base. 然后在需要唤醒调度线程时随时发送 1 个字节。

于 2016-04-07T09:26:47.163 回答