我使用的是ejabberd16.09的linux版本铣缠，安裝教程網(wǎng)上有很多，我在這里只介紹一下android端連接昆禽、登錄和收發(fā)消息的方法蝗蛙。文章最后附上了我寫的一個demo，歡迎大家參考为狸。
ejabberd官網(wǎng)地址:點(diǎn)擊打開鏈接
進(jìn)入正題歼郭，我使用的是smack4.1.2包，需要在android studio的build.gradle文件中加入
compile ("org.igniterealtime.smack:smack-android-extensions:4.1.2") {
exclude group: 'xpp3', module: 'xpp3'
}
compile ("org.igniterealtime.smack:smack-android:4.1.2") {
exclude group: 'xpp3', module: 'xpp3'
}
// Optional for XMPPTCPConnection
compile ("org.igniterealtime.smack:smack-tcp:4.1.2") {
exclude group: 'xpp3', module: 'xpp3'
}
// Optional for XMPP-IM (RFC 6121) support (Roster, Threaded Chats, …)
compile ("org.igniterealtime.smack:smack-im:4.1.2") {
exclude group: 'xpp3', module: 'xpp3'
}
點(diǎn)擊 "Sync Project with Gradle Files"按鈕即可將smack4.1.2引入項(xiàng)目中
下面介紹連接和登錄的方法辐棒，并帶有監(jiān)聽收到消息的方法
private XMPPTCPConnection con;
private Runnable XmppThread = new Runnable(){
@Override
public void run() {
boolean tag = false;
XMPPTCPConnectionConfiguration.Builder config = XMPPTCPConnectionConfiguration.builder();
config.setHost("192.168.26.38"); //設(shè)置ejabberd主機(jī)IP
config.setServiceName("h.com"); //設(shè)置ejabberd服務(wù)器名稱
config.setPort(5222); //設(shè)置端口號：默認(rèn)5222
config.setUsernameAndPassword("admin", "111111"); //設(shè)置用戶名與密碼
config.setSecurityMode(ConnectionConfiguration.SecurityMode.disabled); //禁用SSL連接
config.setSendPresence(true);
config.setDebuggerEnabled(true);
con = new XMPPTCPConnection(config.build());
try {
con.connect();
tag = con.isConnected();
Roster roster = Roster.getInstanceFor(con);
try {
con.login();
Log.e("TAG", "login sucess!!");
} catch (Exception e) {
e.printStackTrace();
}
// 設(shè)置聊天監(jiān)聽器病曾，監(jiān)聽聊天消息
ChatManager chatm = ChatManager.getInstanceFor(con);
chatm.addChatListener(new ChatManagerListener() {
@Override
public void chatCreated(Chat chat, boolean b) {
if (!b) { //不是本地創(chuàng)建的會話
chat.addMessageListener(new ChatMessageListener() {
@Override
public void processMessage(Chat chat, Message message) {
Log.d("PushTest", message.toString());
Log.d("PushTest", message.getType().toString());
Log.d("PushTest", message.getExtension("extension").toString());
Log.d("PushTest", message.getExtension("extension").getNamespace());
Log.d("PushTest", message.getExtension("extension").getElementName());
DefaultExtensionElement defaultExtensionElement = message.getExtension(
ELEMENT_NAME,NAME_SPACE);
String name = defaultExtensionElement.getValue("name");
String url = defaultExtensionElement.getValue("url");
Log.d("PushTest", name);
Log.d("PushTest", url);
}
});
}
}
});
} catch (Exception e) {
Log.e("TAG", "connect failed!" + e.toString());
e.printStackTrace();
}
if(tag){
handler.sendEmptyMessage(0x00);
}else{
handler.sendEmptyMessage(0x01);
}
}
};
其中的
DefaultExtensionElement defaultExtensionElement = message.getExtension(
ELEMENT_NAME,NAME_SPACE);
String name = defaultExtensionElement.getValue("name");
String url = defaultExtensionElement.getValue("url");
是我在服務(wù)端發(fā)送消息時加的Message的屬性拓展，定義如下:
import org.jivesoftware.smack.packet.ExtensionElement;
public class Received implements ExtensionElement {
{
private static final String NAME_SPACE = "extension";
private static final String ELEMENT_NAME = "userinfo";
//用戶姓名元素名稱
private String nameElement = "name";
//用戶姓名元素文本(對外開放)
private String nameText = "";
//用戶地址元素名稱
private String urlElement = "url";
//用戶地址元素文本(對外開放)
private String urlText = "";
@Override
public String getElementName() {
return ELEMENT_NAME;
}
@Override
public String getNamespace() {
return NAME_SPACE;
}
@Override
public CharSequence toXML() {
StringBuilder sb = new StringBuilder();
sb.append(" <").append(ELEMENT_NAME).append(" xmlns=\"").append(NAME_SPACE).append("\">");
sb.append("<" + nameElement + ">").append(nameText).append("</"+nameElement+">");
sb.append("<" + urlElement + ">").append(urlText).append("</"+urlElement+">");
sb.append("</"+ELEMENT_NAME+">");
return sb.toString();
}
public String getNameText() {
return nameText;
}
public void setNameText(String nameText) {
this.nameText = nameText;
}
public String getUrlText() {
return urlText;
}
public void setUrlText(String urlText) {
this.urlText = urlText;
}
}
使用時的方法如下:
ChatManager chatm = ChatManager.getInstanceFor(mXmppConnection);
Chat chat = chatm.createChat("ly@h.com", new ChatMessageListener() { //創(chuàng)建與ly的會話
public void processMessage(Chat chat, Message message) {
System.out.println("Received message: " + message);
}
});
try {
/**
* 發(fā)送一條消息給ly
*/
Received received = new Received();
received.setNameText(name);
Message message = new Message();
message.setBody(context);
message.setTo("ly@h.com");
message.setFrom("gqw@h.com");
message.addExtension(received);
chat.sendMessage(message);
} catch (SmackException.NotConnectedException e) {
e.printStackTrace();
}
我寫了一個小demo漾根，歡迎大家指出不足之處!
Android使用smack連接ejabberd服務(wù)器注冊泰涂、收發(fā)消息
