JavaでGoogle Hangoutクライアントを作ってみよう
Node.js で Google Hangout をしてみようと思っていたのですが
Node.js は環境回りの変化が激しすぎるみたいで
バージョンによって動くもの動かないものの制約が厳しいようです。
別にNode.jsじゃなくってもいいやってことで
JavaによるSMPPクライアントを作ってみようとおもいました。
Google Hangout は XMPP プロトコルで動いているようです。
いろんなプロトコルがあるのねぇ。。
■XMPPプロトコル
http://ja.wikipedia.org/wiki/Extensible_Messaging_and_Presence_Protocol
http://dev.ariel-networks.com/column/tech/xmpp/view
さて、Javaで実装するなら何かライブラリがあるだろってことで
使えそうなライブラリを調べてみました
■Smack
http://news.mynavi.jp/column/tool/037/
http://rainbowdevil.jp/?p=903
さっそく試してみることに。
最新バージョン 4.0.6 をダウンロード
■XPP3
Smack は XPP3 が無いと動かないみたいなのでこれもDL。
※ダウンロードファイルを探すのに少し手間取った。。。
http://www.extreme.indiana.edu/dist/java-repository/xpp3/distributions/xpp3-1.1.3.4.C_all.zip
サンプル通り書いてみるとコンパイルエラー。。。><;
どうもAPIのバージョンが低いらしい。
また、認証の方式が変わったみたいで、信頼性の低いPGからのアクセスを有効にしないとログインすらできない。
なんとか動くようにごにょごにょしたらこんな感じに。
/* * To change this license header, choose License Headers in Project Properties. * To change this template file, choose Tools | Templates * and open the template in the editor. */ package xmppsample; import java.io.BufferedReader; import java.io.IOException; import java.io.InputStreamReader; import java.util.logging.Level; import java.util.logging.Logger; import org.jivesoftware.smack.Chat; import org.jivesoftware.smack.ChatManager; import org.jivesoftware.smack.ConnectionConfiguration; import org.jivesoftware.smack.MessageListener; import org.jivesoftware.smack.SASLAuthentication; import org.jivesoftware.smack.SmackConfiguration; import org.jivesoftware.smack.SmackException; import org.jivesoftware.smack.SmackException.ConnectionException; import org.jivesoftware.smack.XMPPConnection; import org.jivesoftware.smack.XMPPException; import org.jivesoftware.smack.packet.Message; import org.jivesoftware.smack.tcp.XMPPTCPConnection; import org.jivesoftware.smack.util.dns.HostAddress; /** * * @author moremagic */ public class XMPPSample { private XMPPConnection connection = null; private Chat chat = null; private boolean isRunning = true; /* サーバへの接続とログイン */ public void connect(String username, String password) { try { // 接続の設定 SmackConfiguration.setDefaultPacketReplyTimeout(5000); ConnectionConfiguration config = new ConnectionConfiguration("talk.google.com", 5222, "gmail.com"); config.setCompressionEnabled(true); config.setSecurityMode(ConnectionConfiguration.SecurityMode.enabled); // サーバに接続してログインする this.connection = new XMPPTCPConnection(config); this.connection.connect(); this.connection.login(username, password); } catch (ConnectionException ex) { ex.printStackTrace(); for(HostAddress adress: ex.getFailedAddresses()){ System.out.println(adress); } } catch (XMPPException ex) { Logger.getLogger(XMPPSample.class.getName()).log(Level.SEVERE, null, ex); } catch (SmackException ex) { Logger.getLogger(XMPPSample.class.getName()).log(Level.SEVERE, null, ex); } catch (IOException ex) { Logger.getLogger(XMPPSample.class.getName()).log(Level.SEVERE, null, ex); } } /* チャットの開始 */ public void chatOpen(String buddyId) { // ChatManagerを取得し、チャットを開始する ChatManager chatManager = ChatManager.getInstanceFor(this.connection); this.chat = chatManager.createChat(buddyId, new MessageListener() { /* メッセージを受信したら呼び出される */ @Override public void processMessage(Chat chat, Message message) { System.out.println(chat.getParticipant() + ": " + message.getBody()); } }); } /* メッセージの送信 */ public void sendMessage(String message) { try { this.chat.sendMessage(message); } catch (Exception ex) { ex.printStackTrace(); } } /* チャットが継続中か否か */ public boolean isRunning() { return this.isRunning; } /* チャットの終了 */ public void chatClose() { this.isRunning = false; } /* 接続の終了 */ public void destroy() throws SmackException.NotConnectedException { this.connection.disconnect(); } public static void main(String[] args) { System.out.println("srating chat..."); XMPPSample xmpp = new XMPPSample(); // 接続してチャットを開始 xmpp.connect("******@gmail.com", "<password>"); xmpp.chatOpen("@@@@@@@@gmail.com"); System.out.println("open chat..."); // メッセージの送信処理 while (xmpp.isRunning()) { try { BufferedReader reader = new BufferedReader(new InputStreamReader(System.in)); String message = reader.readLine(); if ("@close".equals(message.trim())) { xmpp.chatClose(); } else { xmpp.sendMessage(message); } } catch (IOException ex) { ex.printStackTrace(); } } try { // 終了 xmpp.destroy(); } catch (SmackException.NotConnectedException ex) { Logger.getLogger(XMPPSample.class.getName()).log(Level.SEVERE, null, ex); } } }
実行するとこんな感じ。
送信先で見てみても全然つながってない。。。orz
run: srating chat... open chat... aaa @close
さてどうしたもんかね
moremagic
2015-01-26