package cn.pmsaas.smack;
import java.util.Collection;
import java.util.Iterator;
import javax.net.SocketFactory;
import org.jivesoftware.smack.AccountManager;
import org.jivesoftware.smack.Chat;
import org.jivesoftware.smack.ChatManager;
import org.jivesoftware.smack.Connection;
import org.jivesoftware.smack.ConnectionConfiguration;
import org.jivesoftware.smack.MessageListener;
import org.jivesoftware.smack.Roster;
import org.jivesoftware.smack.RosterEntry;
import org.jivesoftware.smack.XMPPConnection;
import org.jivesoftware.smack.XMPPException;
import org.jivesoftware.smack.packet.Message;
import org.jivesoftware.smack.packet.Presence;
import org.jivesoftware.smack.packet.Session;
import org.jivesoftware.smack.packet.Message.Type;
import org.junit.After;import org.junit.Before;
import org.junit.Test;
public class SmackXMPPTest {
private Connection connection;
private ConnectionConfiguration config;
/**openfire服务器address**/
private final static String server="192.168.3.112";
private final void fail(Object o){
if(o!=null){
System.out.println(o);
}
}
private final void fail(Object o,Object ...args){
if (o != null && args != null && args.length > 0) {
String s = o.toString();
for (int i = 0; i < args.length; i++) {
String item = args[i] == null ? "" : args[i].toString();
if (s.contains("{" + i + "}")) {
s = s.replace("{" + i + "}", item);
} else {
s += " " + item;
}
}
System.out.println(s);
}
}
/**
* 初始化smack对openfire的基本设置
* */
@Before
public void init() {
try {
//connection = new XMPPConnection(server);
//connection.connect();
/** 5222是openfire服务器默认的通信端口,你可以登录http://192.168.8.32:9090/到管理员控制台查看客户端到服务器端口 */
config = new ConnectionConfiguration(server, 5222);
/** 是否启用压缩 */
config.setCompressionEnabled(true);
/** 是否启用安全验证 */
config.setSASLAuthenticationEnabled(true);
/** 是否启用调试 */
config.setDebuggerEnabled(false);
//config.setReconnectionAllowed(true);
//config.setRosterLoadedAtLogin(true);
/** 创建connection链接 */
connection = new XMPPConnection(config);
/** 建立连接 */
connection.connect();
} catch (XMPPException e) {
e.printStackTrace();
}
fail(connection);
fail(connection.getConnectionID());
}
@After
public void destroy(){
if(connection!=null){
connection.disconnect();
connection=null;
}
}
/**
* ConnectionConfiguration基本配置的相关信息
* */
//@Test
public void testConfig(){
fail("PKCS11Library: " + config.getPKCS11Library());
fail("ServiceName: {0}", config.getServiceName());
// ssl证书密码
fail("TruststorePassword: {0}", config.getTruststorePassword());
fail("TruststorePath: {0}", config.getTruststorePath());
fail("TruststoreType: {0}", config.getTruststoreType());
SocketFactory socketFactory = config.getSocketFactory();
fail("SocketFactory: {0}", socketFactory);
/*try {
* fail("createSocket: {0}", socketFactory.createSocket("localhost", 3333));
* } catch (IOException e) {
* e.printStackTrace();
* }
* */
}
/**
* 基本方法信息
* */
//@Test
public void testConnection(){
/** 用户管理 */
AccountManager accountManager = connection.getAccountManager();
for (String attr : accountManager.getAccountAttributes()) {
fail("AccountAttribute: {0}", attr);
}
fail("AccountInstructions: {0}", accountManager.getAccountInstructions());
/** 是否链接 */
fail("isConnected:", connection.isConnected());
fail("isAnonymous:", connection.isAnonymous());
/** 是否有权限 */
fail("isAuthenticated:", connection.isAuthenticated());
fail("isSecureConnection:", connection.isSecureConnection());
/** 是否使用压缩 */
fail("isUsingCompression:", connection.isUsingCompression());
}
/**
* 用户管理器
* */
//@Test
public void testAccountManager(){
AccountManager accountManager = connection.getAccountManager();
for (String attr : accountManager.getAccountAttributes()) {
fail("AccountAttribute: {0}", attr);
}
fail("AccountInstructions: {0}", accountManager.getAccountInstructions());
fail("supportsAccountCreation: {0}", accountManager.supportsAccountCreation());
try {
/** 创建一个用户boy,密码为boy;你可以在管理员控制台页面http://192.168.8.32:9090/user-summary.jsp查看用户/组的相关信息,来查看是否成功创建用户 */
accountManager.createAccount("boy", "boy");
/** 修改密码 */
accountManager.changePassword("abc");
} catch (XMPPException e) {
e.printStackTrace();
}
}
//@Test
public void testUser(){
try {
/** 用户登陆,用户名、密码 */
connection.login("alien@163.com", "123456");
} catch (XMPPException e) {
e.printStackTrace();
}
/** 获取当前登陆用户 */
fail("User:", connection.getUser());
/** 所有用户组 */
Roster roster = connection.getRoster();
/** 好友用户组,你可以用Spark添加用户好友,这样这里就可以查询到相关的数据 */
Collection rosterEntiry = roster.getEntries();
Iterator iter = rosterEntiry.iterator();
while (iter.hasNext()) {
RosterEntry entry = iter.next();
fail("Groups: {0}, Name: {1}, Status: {2}, Type: {3}, User: {4}", entry.getGroups(), entry.getName(), entry.getStatus(),
entry.getType(), entry);
}
fail("-------------------------------");
/** 未处理、验证好友,添加过的好友,没有得到对方同意 */
Collection unfiledEntries = roster.getUnfiledEntries();
iter = unfiledEntries.iterator();
while (iter.hasNext()) {
RosterEntry entry = iter.next();
fail("Groups: {0}, Name: {1}, Status: {2}, Type: {3}, User: {4}", entry.getGroups(), entry.getName(), entry.getStatus(),
entry.getType(), entry);
}
}
@Test
@SuppressWarnings("static-access")
public void testPacket(){
try {
connection.login("boy", "abc");
} catch (XMPPException e) {
e.printStackTrace();
}
//Packet packet = new Data(new DataPacketExtension("jojo@" + server, 2, "this is a message"));
//connection.sendPacket(packet);
/** 更改用户状态,available=true表示在线,false表示离线,status状态签名;当你登陆后,在Spark客户端软件中就可以看到你登陆的状态 */
Presence presence = new Presence(Presence.Type.available);
presence.setStatus("Q我吧");
connection.sendPacket(presence);
Session session = new Session();
String sessid = session.nextID();
connection.sendPacket(session);
/** 向jojo@192.168.8.32 发送聊天消息,此时你需要用Spark软件登陆jojo这个用户, * 这样代码就可以向jojo这个用户发送聊天消息,Spark登陆的jojo用户就可以接收到消息 **/
/** Type.chat 表示聊天,groupchat多人聊天,error错误,headline在线用户; */
Message message = new Message("jojo@" + server, Type.chat);
//Message message = new Message(sessid, Type.chat);
message.setBody("h!~ jojo, I'am is hoojo!");
connection.sendPacket(message);
try {
Thread.sleep(1);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
/**
* 测试聊天消息管理类
* */
//@Test
public void testChatManager(){
/** 设置状态 */
try {
connection.login("hoojo", "hoojo");
} catch (XMPPException e) {
e.printStackTrace();
}
/** 设置状态 */
Presence presence = new Presence(Presence.Type.available);
presence.setStatus("Q我吧");
connection.sendPacket(presence);
/** 获取当前登陆用户的聊天管理器 */
ChatManager chatManager = connection.getChatManager();
/** 为指定用户创建一个chat,MyMessageListeners用于监听对方发过来的消息 */
Chat chat = chatManager.createChat("jojo@" + server, new MyMessageListeners());
try {
/** 发送消息 */
chat.sendMessage("h!~ jojo……");
/** 用message对象发送消息 */
Message message = new Message();
message.setBody("message");
message.setProperty("color", "red");
chat.sendMessage(message);
} catch (XMPPException e) {
e.printStackTrace();
}
try {
Thread.sleep(1000 * 1000);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
/**
* 消息监听器,用户监听对方发送消息,也可以向对方发送消息
* */
class MyMessageListeners implements MessageListener {
public void processMessage(Chat chat, Message message) {
try {
/** 发送消息 */
chat.sendMessage("dingding……" + message.getBody());
} catch (XMPPException e) {
e.printStackTrace();
}
/** 接收消息 */
fail("From: {0}, To: {1}, Type: {2}, Sub: {3}", message.getFrom(), message.getTo(), message.getType(), message.toXML());
/*Collection
bodys = message.getBodies();* for (Body body : bodys) {
* fail("bodies[{0}]", body.getMessage());
* }
* //fail(message.getLanguage());
* //fail(message.getThread());
* //fail(message.getXmlns());*/
fail("body: ", message.getBody());
}
}
}