2

Java multiCastSocket プログラミングを使用してボイスチャットを実装しようとしています。マイクからの入力を取り、スピーカーでそれを聞こうとします。問題は、声が聞こえないことです。Wireshark でデバッグしたところ、マルチキャスト グループ アドレスにパケットを送信でき、参加メッセージが表示されますが、マルチキャスト グループ アドレスから戻ってくるパケットはありません。誰でもコードを見て、何か間違っているかどうか教えてもらえますか? 前もって感謝します。

/送信者コード/

public class MulticastAudioSender {

public static final int IPM_PORT = 7778;

public static final String IPM_ADDRESS = "235.1.1.1";

public static final int SLEEP_MILLISECS = 1000;

private MulticastSocket sock;

private DatagramPacket sendPack;

public static final int BUFFER_SIZE = 20000;

public MulticastAudioSender(){

    try {
        sock = new MulticastSocket();
    } catch( Exception e ) {
        System.out.println( "Exception in creating socket or packet: "
                + e.getMessage() );
    }
}

private void sendMessage(byte[] soundData, int length) {
    try {
        sendPack = new DatagramPacket( soundData, length,
                InetAddress.getByName( IPM_ADDRESS ), IPM_PORT );
        sock.send( sendPack );
        //System.out.println( "Message sent." );
    } catch( Exception e ) {
        System.out.println( "Exception in sending packet: "
                + e.getMessage() );
    }
}

public static void main( String[] args ) throws Exception{

    MulticastAudioSender sender = new MulticastAudioSender();
    AudioFormat af = new AudioFormat(8000.0f,8,1,true,false);
    DataLine.Info info = new DataLine.Info(TargetDataLine.class, af);
    TargetDataLine microphone = (TargetDataLine)AudioSystem.getLine(info);
    microphone.open(af);
    microphone.start();
    int bytesRead = 0;
    byte[] soundData = new byte[1];
    //sender.receiveMessage();
    while(bytesRead != -1) {
        bytesRead = microphone.read(soundData, 0, soundData.length);
        if(bytesRead >= 0){
            sender.sendMessage(soundData, soundData.length);
        }
    }
}

}

/受信者コード/

パブリック クラス IPMulticastReceiver {

public static final int IPM_PORT = 7778;

public static final String IPM_ADDRESS = "235.1.1.1";

public static final int BUFFER_SIZE = 200;

private MulticastSocket sock;

private DatagramPacket pack;

private byte[] receiveBuffer;

byte[] inSound;
SourceDataLine inSpeaker = null;

public IPMulticastReceiver(){

    try {
        sock = new MulticastSocket( IPM_PORT );
        sock.joinGroup( InetAddress.getByName( IPM_ADDRESS ) );

        AudioFormat af = new AudioFormat(8000.0f,8,1,true,false);
        DataLine.Info info = new DataLine.Info(SourceDataLine.class, af);
        inSpeaker = (SourceDataLine)AudioSystem.getLine(info);
        inSpeaker.open(af);

    } catch( Exception e ) {
        System.out.println( "Exception in creating Socket or Packet: "
                + e.getMessage() );
    }
}

private void receiveMessage() {
    try {
        receiveBuffer = new byte[BUFFER_SIZE];
        //sock.joinGroup(InetAddress.getByName(IPM_ADDRESS));
        pack = new DatagramPacket( receiveBuffer, receiveBuffer.length );
        sock.receive( pack );
        /*Thread inThread = new Thread(new MultiCastSoundReceiver(receiveBuffer));
        inThread.start();*/
        inSpeaker.write(receiveBuffer, 0, receiveBuffer.length);
        inSpeaker.drain();
    } catch( Exception e ) {
        e.printStackTrace();
        System.out.println( "Exception in receiving packet: "
                + e.getMessage() );
    }
}

public static void main( String[] args ) throws LineUnavailableException {
    IPMulticastReceiver receiver = new IPMulticastReceiver();

    while( true ) {
        receiver.receiveMessage();
    }
}

}

4

1 に答える 1

0

ソケットでsetReuseAddr()メソッドを使用してみてください。

sock.setReuseAddress(true);

JavaDocs は次のように述べています。

SO_REUSEADDR ソケット オプションを有効/無効にします。UDP ソケットの場合、複数のソケットを同じソケット アドレスにバインドする必要がある場合があります。これは通常、マルチキャスト パケットを受信するためのものです (MulticastSocket を参照)。SO_REUSEADDR ソケット オプションを使用すると、bind(SocketAddress) を使用してソケットをバインドする前に SO_REUSEADDR ソケット オプションが有効になっている場合、複数のソケットを同じソケット アドレスにバインドできます。

注: この機能は既存のすべてのプラットフォームでサポートされているわけではないため、このオプションが無視されるかどうかは実装固有です。ただし、サポートされていない場合、getReuseAddress() は常に false を返します。

于 2014-04-15T20:20:13.873 に答える