Smack Jingleライブラリ用のJSTUN在庫がある不具合


Smack Jingle demoを実行する場合
(http://fisheye.igniterealtime.org/browse/~raw、r=11613/smaack/trunk/jigle/extension/source/org/jivesoftware/smaackx/jigle/mediaimpl/demo/java)いつも次のような異常があります。
java.net.BindException: Cannot assign requested address: Cannot bind
	at java.net.PlainDatagramSocketImpl.bind0(Native Method)
	at java.net.PlainDatagramSocketImpl.bind(Unknown Source)
	at java.net.DatagramSocket.bind(Unknown Source)
	at java.net.DatagramSocket.<init>(Unknown Source)
	at java.net.DatagramSocket.<init>(Unknown Source)
	at de.javawi.jstun.test.demo.ice.Candidate.<init>(Candidate.java:44)
	at de.javawi.jstun.test.demo.ice.ICENegociator.gatherCandidateAddresses(ICENegociator.java:87)
	at org.jivesoftware.smackx.jingle.nat.ICEResolver.initialize(ICEResolver.java:81)
	at org.jivesoftware.smackx.jingle.nat.TransportResolver.initializeAndWait(TransportResolver.java:387)
	at org.jivesoftware.smackx.jingle.nat.ICETransportManager.<init>(ICETransportManager.java:36)
	at com.haojie.smack.demo.Demo.initialize(Demo.java:84)
	at com.haojie.smack.demo.Demo.<init>(Demo.java:76)
	at com.haojie.smack.demo.Demo.main(Demo.java:170)
使用しているJSTUNライブラリに問題がありました。JSTUNは位置しています。
http://jstun.javawi.de/.jstun-0.7.3.src.tar.gzをダウンロードして、その中のde.javawi.jstun.test.demo.ice.ICEN gociatorを実行して、やはり同じ問題があります。
java.net.BindException: Cannot assign requested address: Cannot bind
	at java.net.PlainDatagramSocketImpl.bind0(Native Method)
	at java.net.PlainDatagramSocketImpl.bind(Unknown Source)
	at java.net.DatagramSocket.bind(Unknown Source)
	at java.net.DatagramSocket.<init>(Unknown Source)
	at java.net.DatagramSocket.<init>(Unknown Source)
	at de.javawi.jstun.test.demo.ice.Candidate.<init>(Candidate.java:44)
	at de.javawi.jstun.test.demo.ice.ICENegociator.gatherCandidateAddresses(ICENegociator.java:89)
	at de.javawi.jstun.test.demo.ice.ICENegociator.main(ICENegociator.java:176)
デバッグしたところ、原因が分かりました。
ICENegociator類のgatherCanddidateAddreses()はcandidatesアドレスを収集するための方法であり、まずlocalアドレスを取得し、Host candidateとして、このアドレスから指定されたSTUNサーバにSTUN要求を送り、server reflexive candaddressを取得します。これらのアドレスに対して、Canddateのオブジェクトを作成します。まずCadidate構造関数を見ます。

	public Candidate(Address address, short componentId) throws SocketException, UnknownHostException, UtilityException {
		this.socket = new DatagramSocket(0, address.getInetAddress());
		this.type = CandidateType.Local;
		this.componentId = componentId;
		this.priority = 0;
		this.base = this;
		this.isInUse = false;
	}
	
	public Candidate(Address address, CandidateType type, short componentId, Candidate base) throws SocketException, UnknownHostException, UtilityException {
		this.socket = new DatagramSocket(0, address.getInetAddress());
		this.type = type;
		setComponentId(componentId);
		this.priority = 0;
		this.base = base;
		this.isInUse = false;
	}
キャンディート類の構造関数で、Datagram Socketを作成します。Datagram Socketコンストラクタの第二パラメータはsocketを結合するlocal addressです。host candidateに対して、Datagram Socketの作成には問題がありません。host candidateはlocadressです。しかし、server reflexive candidate addressに対して、問題が発生しました。この住所はNAT変換後の住所ですので、socketは紐付けられません。
したがって、以下のように変更しました。CanddateTypeを判断します。ServerReflexiveであれば、socketを作成しません。主なコードは:
public class DiscoveryInfo {
.......
    private int publicPort; //     NAT      
    public int getPublicPort() {
        return publicPort;
    }
    public void setPublicPort(int publicPort) {
        this.publicPort = publicPort;
    }
......
}

public class ICENegociator {
.......
    public void gatherCandidateAddresses() {
        ......
        DiscoveryTest test = new DiscoveryTest(iaddress, stunServer, stunPort);
        DiscoveryInfo di = test.test();
        if (di.getPublicIP() != null) {
            Candidate cand = new Candidate(new Address(di.getPublicIP().getAddress()), CandidateType.ServerReflexive, componentId, local);
            cand.setPort(di.getPublicPort());
            ......
        }
    }
......
}

public class DiscoveryTest {
    private boolean test1() throws UtilityException, SocketException, UnknownHostException, IOException, MessageAttributeParsingException, MessageHeaderParsingException {
        ......
        di.setPublicIP(ma.getAddress().getInetAddress());
        di.setPublicPort(ma.getPort());
        ......
    }
}

public class Candidate implements Comparable {
    ......
    private int port;
    
    public Candidate(Address address, CandidateType type, short componentId, Candidate base) throws SocketException, UnknownHostException, UtilityException {
        if (type == CandidateType.Local) {
        	this.socket = new DatagramSocket(0, address.getInetAddress());
        	this.address = null;
        } else {
        	this.address = address;
        	this.socket = null;
        }
        
        this.type = type;
        setComponentId(componentId);
        this.priority = 0;
        this.base = base;
        this.isInUse = false;
   }

   public Address getAddress() throws UtilityException {
       if (type == CandidateType.Local) {
            return new Address(socket.getLocalAddress().getAddress());
    	} else {
            return this.address;
    	}
    }
    
    public int getPort() {
    	if (type == CandidateType.Local) {
    		return socket.getLocalPort();
    	} else {
    		return this.port;
    	}
    }
    
    public void setPort(int port) {
    	this.port = port;
    }
}