Android端末同士でのUDP・TCP通信
こんにちは。アスネット開発部の名倉です。
今回はUDP通信を使って、同一のWi-Fiに接続したホストとゲストが互いのIPアドレスを知らない状態からTCP通信を成立させるまでのプログラムを紹介します。
概要
処理の流れを簡単にまとめるとこんな感じです。
①ホスト：ゲストから発信されるブロードキャストを受信できる(受信待ち受け)状態にする。
②ゲスト：ホスト探索開始。ゲスト端末のIPアドレスを発信する。
③ホスト：ゲストから受信したIPアドレスに対してホスト端末のIPアドレスを送り返す。
④ゲスト：ホストから端末情報を受け取る
⑤ゲスト：ホストのIPアドレスが判明して、TCP通信を開始する。
それでは、ひとつずつ見ていきましょう。
①ホスト：ゲストから発信されるブロードキャストを受信できる(受信待ち受け)状態にする。
ゲストからいくらブロードキャスト送信をしていても、ホスト側で受け取り態勢が整っていなければ受け取ることが出来ません。まずはゲストが送信を開始する前に待ち受け状態にします。
DatagramSocket receiveUdpSocket; boolean waiting; int udpPort = 9999;//ホスト、ゲストで統一 //ブロードキャスト受信用ソケットの生成 //ブロードキャスト受信待ち状態を作る void createReceiveUdpSocket() { waiting = true; new Thread() { @Override public void run(){ String address = null; try { //waiting = trueの間、ブロードキャストを受け取る while(waiting){ //受信用ソケット DatagramSocket receiveUdpSocket = new DatagramSocket(udpPort); byte[] buf = new byte[256]; DatagramPacket packet = new DatagramPacket(buf, buf.length); //ゲスト端末からのブロードキャストを受け取る //受け取るまでは待ち状態になる receiveUdpSocket.receive(packet); //受信バイト数取得 int length = packet.getLength(); //受け取ったパケットを文字列にする address = new String(buf, 0, length); //↓③で使用 returnIpAdress(address); receiveUdpSocket.close(); } } catch (SocketException e) { e.printStackTrace(); } catch (IOException e) { e.printStackTrace(); } } }.start(); }
また、UDP通信とは別にTCP通信も待ち受け状態を作っておきます。 これをしないと、④でゲストから通信しようとしても通信先のホストが見つからず、Exceptionが発生しますのでご注意ください。
ServerSocket serverSocket; Socket connectedSocket; int tcpPort = 3333;//ホスト、ゲストで統一 //ゲストからの接続を待つ処理 void connect(){ new Thread(){ @Override public void run(){ try { //ServerSocketを生成する serverSocket = new ServerSocket(tcpPort); //ゲストからの接続が完了するまで待って処理を進める connectedSocket = serverSocket.accept(); //この後はconnectedSocketに対してInputStreamやOutputStreamを用いて入出力を行ったりするが、ここでは割愛 }catch (SocketException e){ e.printStackTrace(); }catch(IOException e){ e.printStackTrace(); } } }.start(); }
②ゲスト：ホスト探索開始。ゲスト端末のIPアドレスを発信する。
ホストが待ち受け態勢を作ったところで、次はゲスト側からブロードキャスト送信を行います。ここでは送信回数を10回、５秒間隔で送るように制限しています。
ブロードキャスト送信を行うとき、Wi-Fi設定が有効で、かつ、ネットワークに接続されていないとExceptionが発生しますので、対策が必要です。
boolean waiting; int udpPort = 9999;//ホスト、ゲストで統一 //同一Wi-fiに接続している全端末に対してブロードキャスト送信を行う void sendBroadcast(){ final String myIpAddress = getIpAddress(); waiting = true; new Thread() { @Override public void run() { int count = 0; //送信回数を10回に制限する while (count < 10) { try { DatagramSocket udpSocket = new DatagramSocket(udpPort); udpSocket.setBroadcast(true); DatagramPacket packet = new DatagramPacket(myIpAddress.getBytes(), myIpAddress.length(), getBroadcastAddress(), udpPort); udpSocket.send(packet); udpSocket.close(); } catch (SocketException e) { e.printStackTrace(); } catch (IOException e) { e.printStackTrace(); } //5秒待って再送信を行う try { Thread.sleep(5000); count++; } catch (InterruptedException e) { e.printStackTrace(); } } } }.start(); }
getIpAdress()、getBroadcastAdress()は端末のIPアドレスとブロードキャストアドレスを算出するメソッドを下記のように用意しています。
また、これらを取得可能にするために、あらかじめサービスのハンドルを取得しています。
WifiManager wifi;
/*コンストラクタ*/
public Sample_WifiConnection(Context context){
wifi = (WifiManager)context.getSystemService(Context.WIFI_SERVICE);
}
//IPアドレスの取得
String getIpAddress(){
int ipAddress_int = wifi.getConnectionInfo().getIpAddress();
if(ipAddress_int == 0){
ipAddress = null;
}else {
ipAddress = (ipAddress_int & 0xFF) + "." + (ipAddress_int >> 8 & 0xFF) + "." + (ipAddress_int >> 16 & 0xFF) + "." + (ipAddress_int >> 24 & 0xFF);
}
return ipAddress;
}
//ブロードキャストアドレスの取得
InetAddress getBroadcastAddress(){
DhcpInfo dhcpInfo = wifi.getDhcpInfo();
int broadcast = (dhcpInfo.ipAddress & dhcpInfo.netmask) | ~dhcpInfo.netmask;
byte[] quads = new byte[4];
for (int i = 0; i < 4; i++){
quads[i] = (byte)((broadcast >> i * 8) & 0xFF);
}
try {
return InetAddress.getByAddress(quads);
}catch (IOException e){
e.printStackTrace();
return null;
}
}
次に、ホストからTCP通信でIPアドレスが返されてくるので、受け取るための待ち受け状態を作っておきます。
//ホストからTCPでIPアドレスが返ってきたときに受け取るメソッド void receivedHostIp(){ new Thread() { @Override public void run() { while (waiting) { try { if(serverSocket == null) { serverSocket = new ServerSocket(tcpPort); } socket = serverSocket.accept(); //↓③で使用 inputDeviceNameAndIp(socket); if (serverSocket != null) { serverSocket.close(); serverSocket = null; } if (socket != null) { socket.close(); socket = null; } } catch (IOException e) { waiting = false; e.printStackTrace(); } } } }.start(); }
③ホスト：ゲストから受信したIPアドレスに対してホスト端末のIPアドレスを送り返す。
①でIPアドレスを受け取ると
receiveUdpSocket.receive(packet);
ここで止まっていた処理が再開します。
受信データ(IPアドレス)を文字列に変換して、
IPアドレスを返すために用意したメソッドに受け取ったアドレスを引数に渡します。
returnIpAdress(address);
処理はこんな感じです。
Socket returnSocket;
//ブロードキャスト発信者(ゲスト)にIPアドレスと端末名を返す
void returnIpAdress(final String address){
new Thread() {
@Override
public void run() {
try{
if(returnSocket != null){
returnSocket.close();
returnSocket = null;
}
if(returnSocket == null) {
returnSocket = new Socket(address, tcpPort);
}
//端末情報をゲストに送り返す
outputDeviceNameAndIp(returnSocket,getDeviceName(),getIpAddress);
}catch(UnknownHostException e){
e.printStackTrace();
}catch (java.net.ConnectException e){
e.printStackTrace();
try{
if(returnSocket != null) {
returnSocket.close();
returnSocket = null;
}
}catch(IOException e1) {
e.printStackTrace();
}
}catch(IOException e){
e.printStackTrace();
}
}
}.start();
}
//端末名とIPアドレスのセットを送る
void outputDeviceNameAndIp(final Socket outputSocket, final String deviceName, final String deviceAddress){
new Thread(){
@Override
public void run(){
final BufferedWriter bufferedWriter;
try {
bufferedWriter = new BufferedWriter(
new OutputStreamWriter(outputSocket.getOutputStream())
);
//デバイス名を書き込む
bufferedWriter.write(deviceName);
bufferedWriter.newLine();
//IPアドレスを書き込む
bufferedWriter.write(deviceAddress);
bufferedWriter.newLine();
//出力終了の文字列を書き込む
bufferedWriter.write("outputFinish");
//出力する
bufferedWriter.flush();
} catch (IOException e) {
e.printStackTrace();
}
}
}.start();
}
④ゲスト：ホストから端末情報を受け取る
ゲストからTCP通信が行われると待ち状態になっていた処理が再開し、②で準備していたinputDeviceNameAndIp()まで処理が進みます。
socket = serverSocket.accept();
//↓③で使用
inputDeviceNameAndIp(socket);
このメソッドはIPアドレスと端末名を取得して保持するために用意しています。
//端末名とIPアドレスのセットを受け取る void inputDeviceNameAndIp(Socket socket){ try { BufferedReader bufferedReader = new BufferedReader( new InputStreamReader(socket.getInputStream()) ); int infoCounter = 0; String remoteDeviceInfo; //ホスト端末情報(端末名とIPアドレス)を保持するためのクラスオブジェクト //※このクラスは別途作成しているもの SampleDevice hostDevice = new SampleDevice(); while((remoteDeviceInfo = bufferedReader.readLine()) != null && !remoteDeviceInfo.equals("outputFinish")){ switch(infoCounter){ case 0: //1行目、端末名の格納 hostDevice.setDeviceName(remoteDeviceInfo); infoCounter++; break; case 1: //2行目、IPアドレスの取得 hostDevice.setDeviceIpAddress(remoteDeviceInfo); infoCounter++; return; default: return; } } } catch (IOException e) { e.printStackTrace(); } }
ゲストが端末情報を受け取るとき、本来はreturnしなくていいのですが、どうにも読み込みが完了してくれなかったので無理やり処理を完了させるためreturnさせています。もっとスマートなやり方があるはず…。
⑤ゲスト：ホストのIPアドレスが判明して、TCP通信を開始する。
ゲスト端末でホストのIPアドレスを入手することが出来たので、あとはTCP通信を試みるだけです。
//IPアドレスが判明したホストに対して接続を行う void connect(String remoteIpAddress){ waiting = false; new Thread() { @Override public void run() { try{ if(socket == null) { socket = new Socket(remoteIpAddress, tcpPort); //この後はホストに対してInputStreamやOutputStreamを用いて入出力を行ったりするが、ここでは割愛 } }catch(UnknownHostException e){ e.printStackTrace(); }catch (ConnectException e){ e.printStackTrace(); }catch(IOException e){ e.printStackTrace(); } } }.start(); }
終わりに
いかがでしたでしょうか？
私がアスネット開発のMeetingForceに同一のWi-Fiに接続したホストとゲスト間でBluetoothと同様の通信を可能にするために苦戦した際の経験をもとに作成してみました。BufferdReader、BufferdWriterのサンプルが意外と出てこなかったり、UDP送受信をした後どうすればいい、というのが見つけられなかったり、いろいろ困ったので。UDP・TCP通信のサンプルをお探しの方に、ほんの少しでもお役にたてれば幸いです。
参考URL
MeetingForceって何？と思った方はこちらからどうぞ。
MeetingForce
