0

私のアプリケーションでは、UDP ストリームを受信し、それを他の 2 つの UDP エンドポイントに転送します。私の問題は、2 つのストリーム間に遅延を設定する必要があることです。そのため、タイマーを使用することを考えました。これは私のコードです（関連するメソッドのみを示しています）：

public void Start()
{      
  Socket udpSocket = m_udpLocalClient.Client;

  udpSocket.ReceiveBufferSize = BUFFER_SIZE;

  // Enable broadcast
  udpSocket.SetSocketOption(SocketOptionLevel.Socket,
                            SocketOptionName.Broadcast,
                            1);
  // Enable reusing address
  udpSocket.SetSocketOption(SocketOptionLevel.Socket,
                            SocketOptionName.ReuseAddress,
                            true);

  // Bind the socket to the local endpoint and listen for incoming connections.
  udpSocket.Bind(new IPEndPoint(IPAddress.Any, m_ListenPort));

  m_udpLocalClient.JoinMulticastGroup(IPAddress.Parse(m_ListenIP));

  udpSocket.BeginReceiveFrom(m_data,
                             0,
                             m_data.Length,
                             SocketFlags.None,
                             ref m_ListenEndPoint,
                             new AsyncCallback(ReceiveData), 
                             m_udpLocalClient);
}

public void TimerCallback(object sender, ElapsedEventArgs e)
{
  byte[] Data = new byte[m_BytesReceived];

  m_Timer.Stop();

  m_Mutex.WaitOne();
  m_Buffer.Get(Data);
  m_Mutex.ReleaseMutex();

  //Send Packets lo LocalHost EndPoint
  m_udpLocalClient.Send(Data, Data.Length, m_LocalEndPoint);

}    

void ReceiveData(IAsyncResult iar)
{
  int recv = 0;

  try
  {
    UdpClient udpReceiver = (UdpClient)iar.AsyncState;

    recv = udpReceiver.Client.EndReceiveFrom(iar, ref m_ListenEndPoint);
    if (recv == 0)  return;

    //Forward packets on the FwEndpoint
    m_udpFwClient.Send(m_data, recv, m_FwEndPoint);

    //Send Packets lo LocalHost EndPoint
    //m_udpLocalClient.Send(m_data, recv, m_LocalEndPoint);

    m_Mutex.WaitOne();
    m_Buffer.Put(m_data);
    m_Mutex.ReleaseMutex();

    if (!m_Timer.Enabled) m_Timer.Start();

    udpReceiver.Client.BeginReceiveFrom(m_data, 
                                        0,
                                        m_data.Length, 
                                        SocketFlags.None,
                                        ref m_ListenEndPoint,
                                        new AsyncCallback(ReceiveData),
                                        udpReceiver);
  }
  catch (Exception e)
  {
     //...handle....
  }

}

ノート。m_Buffer メンバーはCodePlexの CircularBufferです。

ここでの問題は、

m_udpLocalClient.Send(Data, Data.Length, m_LocalEndPoint);

TimerCallBack に挿入しても効果がないようですが、同じものを ReceiveData にコメント解除すると機能します。

また、非同期メソッド BeginSend() を使用しようとしましたが、成功しませんでした。どこが間違っていますか？

よろしく、
ダニエレ。

4

1 に答える 1

0

データを受信した後すぐに受信状態に戻るため、タイマーコールバックで同じソケットを使用してデータを送信することは許可されていないと考えています。タイマーが実行されている時点で、さらにデータが入ってくるのを待つようにソケットに指示しています。

タイマー コールバックでデータを送信するには、別のソケット/UdpClient を使用する必要があります。

于 2012-06-19T14:27:41.007 に答える