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)いつも次のような異常があります。
http://jstun.javawi.de/.jstun-0.7.3.src.tar.gzをダウンロードして、その中のde.javawi.jstun.test.demo.ice.ICEN gociatorを実行して、やはり同じ問題があります。
ICENegociator類のgatherCanddidateAddreses()はcandidatesアドレスを収集するための方法であり、まずlocalアドレスを取得し、Host candidateとして、このアドレスから指定されたSTUNサーバにSTUN要求を送り、server reflexive candaddressを取得します。これらのアドレスに対して、Canddateのオブジェクトを作成します。まずCadidate構造関数を見ます。
したがって、以下のように変更しました。CanddateTypeを判断します。ServerReflexiveであれば、socketを作成しません。主なコードは:
(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;
}
}