如何轻松解决Wsock2上的10040消息过长错误

How to easily solve the 10040 message too long error on Wsock2

本文关键字:消息 错误 10040 上的 何轻松 解决 Wsock2      更新时间:2023-10-16

我从发送。Net应用程序1404通过udp套接字构成5616个字节的浮点值。这次行动我没有任何例外。

然而,接收这些数据的程序是一个C++应用程序,当接收到如此多的数据时,我会得到一个10040消息太长的错误。

显然,1480字节是Wsock2中可能的最长消息大小。

解决这个问题最简单、最干净的方法是什么?

谢谢!

编辑:发布一些代码:

这是我的插座J_接收类:

#include "J_Receive.h"

#include <stdio.h>
#include <fcntl.h>
#include <sys/types.h>
#if defined (WIN32) && !defined(__CYGWIN__)
#include <winsock.h>
#else
#include <unistd.h>
#include <sys/uio.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <netdb.h>
#include <arpa/inet.h>
#include <sys/time.h>
#endif
#include <string.h>
#include <iostream>
using namespace sockets;
J_Recibir::J_Recibir( void )
{
    _port = 0;
    _initialized = false;
    _buffer = 0L;
}
J_Recibir::~J_Recibir( void )
{
#if defined (WIN32) && !defined(__CYGWIN__)
    closesocket( _so);
#else
    close( _so );
#endif
}
bool J_Recibir::init( void )
{
#if defined(WIN32) && !defined(__CYGWIN__)
    WORD version = MAKEWORD(1,1);
    WSADATA wsaData;
    // First, we start up Winsock
    WSAStartup(version, &wsaData);
#endif
    if( _port == 0 )
    {
    fprintf( stderr, "Receiver::init() - port not definedn" );
    return false;
    }
    if( (_so = socket( AF_INET, SOCK_DGRAM, 0 )) < 0 )
    {
        perror( "Socket" );
    return false;
    }

    /*int buffsize  = 50000;
    setsockopt( _so, SOL_SOCKET, SO_RCVBUF, (const char*)&buffsize, sizeof(buffsize));*/
#if defined (WIN32) && !defined(__CYGWIN__)
//    const BOOL on = TRUE;
//    setsockopt( _so, SOL_SOCKET, SO_REUSEADDR, (const char*) &on, sizeof(int));
#else
    int on = 1;
    setsockopt( _so, SOL_SOCKET, SO_REUSEADDR, &on, sizeof(on));
#endif


//    struct sockaddr_in saddr;
    saddr.sin_family = AF_INET;
    saddr.sin_port   = htons( _port );
#if defined (WIN32) && !defined(__CYGWIN__)
    saddr.sin_addr.s_addr =  htonl(INADDR_ANY);
#else
    saddr.sin_addr.s_addr =  0;
#endif
    if( bind( _so, (struct sockaddr *)&saddr, sizeof( saddr )) < 0 )
    {
        perror( "bind" );
        return false;
    }
    u_long iMode = 1;       // 1 para No bloqueante, 0 para bloqueante
    ioctlsocket(_so, FIONBIO, &iMode);
    _initialized = true;
    return _initialized;
}

void J_Recibir::setPort( const short port )
{
    _port = port;
}
void J_Recibir::setBuffer( void *buffer, const unsigned int size )
{
    _buffer = buffer;
    _buffer_size = size;
}
int J_Recibir::sync( void )
{
    if(!_initialized) init();
    if( _buffer == 0L )
    {
        fprintf( stderr, "Receiver::sync() - No buffern" );
        return -1;
    }
#if defined(__linux) || defined(__FreeBSD__) || defined( __APPLE__ )
    socklen_t 
#else
    int
#endif
        size = sizeof( struct sockaddr_in );
    fd_set fdset;
    FD_ZERO( &fdset );
    FD_SET( _so, &fdset );
    struct timeval tv;
    tv.tv_sec = 0;
    tv.tv_usec = 0;
#if defined (WIN32) && !defined(__CYGWIN__)
//    saddr.sin_port   = htons( _port );
    recvfrom( _so, (char *)_buffer, _buffer_size, 0, (sockaddr*)&saddr, &size );

//    recvfrom(sock_Receive, szMessage, 256, 0, (sockaddr*)&addr_Cli, &clilen)
    int err = WSAGetLastError ();
    if (err!=0){
        fprintf( stderr, "Receiver::sync() - error %dn",err );
        perror("Error: ");
    }
    while( select( _so+1, &fdset, 0L, 0L, &tv ) )
    {
        if( FD_ISSET( _so, &fdset ) )
        {
            recvfrom( _so, (char *)_buffer, _buffer_size, 0, (sockaddr*)&saddr, &size );
        }
    }
#else
    recvfrom( _so, (caddr_t)_buffer, _buffer_size, 0, 0, &size );
    while( select( _so+1, &fdset, 0L, 0L, &tv ) )
    {
        if( FD_ISSET( _so, &fdset ) )
        {
            recvfrom( _so, (caddr_t)_buffer, _buffer_size, 0, 0, &size );
        }
    }
#endif
    if (err!=0) return -1;
    else        return 0;
}

这就是我如何调用接收函数:

     sockets::J_Receiver receiverGUI = new sockets::J_Recibir();
     receiverGUI->setPort(4020);
     nDatosGUI = 1404;
     float* datosGUI = new datosGUI[nDatosGUI ];
     receiverGUI->setBuffer((void *)datosGUI, sizeof(float)*nDatosGUI);

WSAEMSGSIZE通常表示您提供给recvfrom()的缓冲区小于传入的数据报。检查或发布您的recvfrom()代码,以确保您使用的缓冲区足够大且声明正确。因为IPv4数据包(理论上)的大小可以高达64千字节,所以总是使用这么大的缓冲区是最安全的。

10040告诉您在调用recvfrom()时使用更大的缓冲区。这并不意味着要增加套接字内部接收缓冲区的大小。

由于您已经知道您期望接收的浮点数,因此只需声明一个足够大的缓冲区即可接收所有浮点数,例如:

float buffer[1404];
int ret = recvfrom(..., (char*)&buffer[0], sizeof(buffer), ...);

Winsock在消息上肯定没有1480字节的限制。

从MSDN文档中读取错误WSAEMSGSIZE(10040):

消息太长。

在数据报套接字上发送的消息大于内部消息缓冲区或其他网络限制,或者用于接收数据报的缓冲区小于数据报本身。

这可能意味着你的接收缓冲区太小,你需要放大它。这是通过setsockopt函数和SO_RCVBUF选项来完成的。