iOS XMPP系列教程(Swift)三 代码实战

发表于 更新于 分类于
iOS XMPP系列教程(Swift)三 代码实战

初始化流转图

代码

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
class AppDelegate: UIResponder, UIApplicationDelegate ,XMPPStreamDelegate,XMPPRosterDelegate{
    var log = XCGLogger.defaultInstance();
    var window: UIWindow?
    var isImConnect: Bool = false;
    var isImLogin: Bool = false;
    var xmppStream: XMPPStream?;
    var xmppRoster:XMPPRoster?;
    var chatDelegate: ChatDelegate?;
    var messageDelegate: MessageDelegate?;
    var appMessageDelegate: MessageDelegate?;
    var jid:String?;
        ///入口
    func connect() -> Bool {
        log.info("连接IM服务器")
        setupStream();
        let defaults = NSUserDefaults.standardUserDefaults();
        LoadData.imServer = ZJ_PlistUtils.getProgramPlistStringValue("Config", keyName: "IMServer");
        if let imUserName = defaults.stringForKey(ProjectUserDefaults.ImUserName.rawValue){
            LoadData.imUserName = imUserName;
        }
        
        if let imUserPwd = defaults.stringForKey(ProjectUserDefaults.ImUserPwd.rawValue){
            LoadData.imUserPwd = imUserPwd;
        }
        
        if let imUserNick = defaults.stringForKey(ProjectUserDefaults.ImUserNick.rawValue){
            LoadData.imUserNick = imUserNick;
        }
        
        if let imUserPic = defaults.stringForKey(ProjectUserDefaults.ImUserPic.rawValue){
            LoadData.imUserPic = imUserPic;
        }
        
        if let imUserEmail = defaults.stringForKey(ProjectUserDefaults.ImUserEmail.rawValue){
            LoadData.imUserEmail = imUserEmail;
        }
        
        jid="\(LoadData.imUserName)@\(LoadData.imServer)"
        
        if let stream = xmppStream {
            if(stream.isConnected()){
                stream.disconnect();
            }
            xmppStream!.myJID =  XMPPJID.jidWithUser(LoadData.imUserName, domain: LoadData.imServer, resource: nil)
            xmppStream!.hostName=LoadData.imServer;
            xmppStream!.hostPort=5222;
            xmppStream?.enableBackgroundingOnSocket=true
            
            do {
                try xmppStream!.connectWithTimeout(10)
                return true
            } catch{
                return false;
            };
        }else{
            return false
        }
    }
    
    ///设置IM Stream对象
    func setupStream () {
        if(xmppStream == nil){
            xmppStream = XMPPStream();
            xmppStream!.addDelegate(self, delegateQueue: dispatch_get_main_queue());
            
            let xmppRosterDataStorage = XMPPRosterCoreDataStorage();
            xmppRoster = XMPPRoster(rosterStorage: xmppRosterDataStorage);
            xmppRoster?.activate(xmppStream);
            xmppRoster?.addDelegate(self, delegateQueue: dispatch_get_main_queue());
            
            //断线重连
            let xmppReconnect = XMPPReconnect();
            xmppReconnect.activate(xmppStream);
            xmppReconnect.addDelegate(self, delegateQueue: dispatch_get_main_queue());
        }
    }
    
    ///发送离线
    func goOffline() {
        let presence = XMPPPresence(type: "unavailable")
        xmppStream!.sendElement(presence)
    }
    
    ///发送在线
    func goOnline() {
        log.info("发送在线状态")
        let presence = XMPPPresence(type: "available")
        xmppStream!.sendElement(presence)
    }
    
    /**
     断开连接
     */
    func disconnect() {
        log.info("断开连接")
        goOffline()
        xmppStream!.disconnect()
    }
    
    //登录
    func login(){
        do {
            log.info("服务器:\(self.xmppStream?.hostName)")
            log.info("端口:\(self.xmppStream?.hostPort)")
            log.info("账号:\(self.xmppStream?.myJID.description)")
            log.info("密码:\(LoadData.imUserPwd)")
            try xmppStream!.authenticateWithPassword(LoadData.imUserPwd )
        } catch{
            print(error)
        };
    }
    
    //注册
    func register(){
        log.info("注册IM用户");
        let arr = NSMutableArray();
        arr.addObject(XMPPElement.elementWithName("username", stringValue: LoadData.imUserName));
        arr.addObject(XMPPElement.elementWithName("password", stringValue: LoadData.imUserPwd));
        arr.addObject(XMPPElement.elementWithName("name", stringValue: LoadData.imUserNick));
        arr.addObject(XMPPElement.elementWithName("email", stringValue: LoadData.imUserEmail));
        do {
            try xmppStream?.registerWithElements(arr as [AnyObject])
        } catch{
            print(error)
        };

    }
    //发送好友列表请求
    func queryRoster()->Void{
        log.info("发送好友请求")
        let type = "get"
        let iq = XMPPIQ()
        
        iq.addAttributeWithName("type", stringValue: type )
        let child=DDXMLNode.elementWithName("query") as! DDXMLNode
        child.setValue("jabber:iq:roster", forKey: "xmlns")
        iq.addChild(child)
        xmppStream?.sendElement(iq)
    }
    
    ///发送信息
    func sendMsg(sendMsg:SendMsg)->Void{
        log.info("发消息")
        
        let msg=XMPPMessage();
        msg.addAttributeWithName("type", stringValue: "chat");
        msg.addAttributeWithName("to", stringValue: "\(sendMsg.receiverName)@\(LoadData.imServer)");
        msg.addAttributeWithName("senderId", stringValue: sendMsg.senderId);
        msg.addAttributeWithName("senderName", stringValue: sendMsg.senderName);
        msg.addAttributeWithName("senderNickname", stringValue: sendMsg.senderNickname);
        msg.addAttributeWithName("senderPic", stringValue: sendMsg.senderPic);
        msg.addAttributeWithName("receiverId", stringValue: sendMsg.receiverId);
        msg.addAttributeWithName("receiverName", stringValue: sendMsg.receiverName);
        msg.addAttributeWithName("receiverNickname", stringValue: sendMsg.receiverNickname);
        msg.addAttributeWithName("receiverPic", stringValue: sendMsg.receiverPic);
        msg.addAttributeWithName("msgtype", stringValue: sendMsg.msgtype);
        msg.addAttributeWithName("voiceDuration", stringValue: sendMsg.voiceDuration);
        msg.addBody(sendMsg.msgbody);
        xmppStream?.sendElement(msg)
    }
    
    //添加好友
    func addFriend(name:String,nickName:String,xmppRoster:XMPPRoster){
        let jid=XMPPJID.jidWithUser(name, domain: LoadData.imServer, resource: nil);
        xmppRoster.addUser(jid, withNickname: nickName);
    }
    
    
    //-----------------------------------------华丽的分割线 XMPP的代理方法-------------------------------------------//
    //连接成功调用
    func xmppStreamDidConnect(_ sender: XMPPStream) {
        logger.info("连接IM服务器成功，开始登录")
        isImConnect = true;
        //进行登录
        login();
    }
    
    //注册成功后调用
    func xmppStreamDidRegister(_ sender: XMPPStream!) {
        logger.info("注册成功，开始登录")
        login();
    }
    
    func xmppStream(_ sender: XMPPStream!, didNotRegister error: DDXMLElement!) {
        logger.info("注册失败,停止操作");
    }
    
    //连接超时后调用
    func xmppStreamConnectDidTimeout(_ sender: XMPPStream!) {
        logger.info("连接IM服务器超时")
    }
    
    //登录失败调用
    func xmppStream(_ sender: XMPPStream!, didNotAuthenticate error: DDXMLElement!) {
        logger.info("登录失败，注册账号");
        register();
    }
    
    //登录成功调用
    func xmppStreamDidAuthenticate(_ sender: XMPPStream) {
        logger.info("登录成功，发送在线状态");
        isImLogin = true;
        //发送在线
        goOnline();
    }
    
    // 发送信息时调用
    func xmppStream(_ sender: XMPPStream!, didSend message: XMPPMessage!) {
        logger.info("发送Message");
    }
    
    //接收信息后调用
    func xmppStream(_ sender: XMPPStream?, didReceive didReceiveMessage: XMPPMessage?) {
        if let message:XMPPMessage = didReceiveMessage {
            let msgbody = ZJ_Xmpp.stringValue(message.forName("body"));
            let senderId = ZJ_Xmpp.stringValue(message.attribute(forName: "senderId"));
            let senderName = ZJ_Xmpp.stringValue(message.attribute(forName: "senderName"));
            let senderNickname = ZJ_Xmpp.stringValue(message.attribute(forName: "senderNickname"));
            let senderPic = ZJ_Xmpp.stringValue(message.attribute(forName: "senderPic"));
            let receiverId = ZJ_Xmpp.stringValue(message.attribute(forName: "receiverId"));
            let receiverName = ZJ_Xmpp.stringValue(message.attribute(forName: "receiverName"));
            let receiverNickname = ZJ_Xmpp.stringValue(message.attribute(forName: "receiverNickname"));
            let receiverPic = ZJ_Xmpp.stringValue(message.attribute(forName: "receiverPic"));
            let msgtype = ZJ_Xmpp.stringValue(message.attribute(forName: "msgtype"));
            let voiceDuration = ZJ_Xmpp.stringValue(message.attribute(forName: "voiceDuration"));
            let sendMsg = SendMsg(senderId: senderId, senderPic: senderPic, senderName: senderName, senderNickname: senderNickname, receiverId: receiverId, receiverPic: receiverPic, receiverName: receiverName, receiverNickname: receiverNickname, msgtype: msgtype, msgbody: msgbody,voiceDuration:voiceDuration);

            logger.info(sendMsg.toString());

            //播放提示音
            AudioServicesPlaySystemSound(SystemSoundID(1312));
            ZJ_Func.async({
                SQLiteDB.sharedInstance.execute(sql: "insert into talkmessage(msgType,message,senderName,senderPic,read,sender,receiver,srdate,isReceive,voiceDuration) values(?,?,?,?,?,?,?,?,?,?)",
                    parameters: [
                        msgtype,
                        msgbody,
                        senderNickname,
                        senderPic,
                        0,
                        senderName,
                        receiverName,
                        Date(),
                        1,
                        voiceDuration
                    ]
                );
                let loginUserId = UserDefaults.standard.string(forKey: ProjectUserDefaults.UserId.rawValue)!;
                let id = SQLiteDB.sharedInstance.execute(sql: "insert into appmessage(userId,loginName,name,image,detail,time,type,msgType,loginUserId) values(?,?,?,?,?,?,?,?,?)",
                    parameters: [
                        senderId,
                        senderName,
                        senderNickname,
                        senderPic,
                        msgbody,
                        Date(),
                        "talk",
                        msgtype,
                        loginUserId
                    ]
                );
                sendMsg.id = "\(id)";
                
                }, callBack: {
                    self.messageDelegate?.newMessageReceived(sendMsg);
                    self.appMessageDelegate?.newMessageReceived(sendMsg);
            });
        }
    }

    func xmppStream(_ sender: XMPPStream!, willSend iq: XMPPIQ!) -> XMPPIQ! {
        logger.info("发送IQ")
        return iq;
    }
    
    func xmppStream(_ sender: XMPPStream!, didReceive iq: XMPPIQ!) -> Bool {
        logger.info("接收IQ")
        return true
    }
    
    func xmppStream(_ sender: XMPPStream!, didSend presence: XMPPPresence!) {
        
    }
    
    func xmppStream(_ sender: XMPPStream?, didReceive didReceivePresence: XMPPPresence?) {
        logger.info("接收Presence");
        if let presence = didReceivePresence {
            let presenceType = presence.type()
            let myUsername = sender?.myJID.user
            let presenceFromUser = presence.from().user
            
            if presenceFromUser != myUsername {
                if presenceType == "available" {
                    logger.info("在线用户:\(presenceFromUser)");
                    if chatDelegate != nil {
                        chatDelegate?.newBuddyOnline("\(presenceFromUser)" + "@" + "\(LoadData.imServer)")
                    }
                } else if presenceType == "unavailable" {
                    logger.info("离线用户:\(presenceFromUser)");
                    if chatDelegate != nil {
                        chatDelegate?.buddyWentOffline("\(presenceFromUser)" + "@" + "\(LoadData.imServer)")
                    }
                }
            }
            
        }
    }
}

代码中用到的工具类

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
import Foundation
import XMPPFramework

class ZJ_Xmpp{
    static func stringValue(_ element:DDXMLElement?) -> String{
 
        if(element == nil){
            return "";
        }else{

            return element!.stringValue!;
        }
    }
    
    static func stringValue(_ node:DDXMLNode?) -> String{

        if(node == nil){
            return "";
        }else{
            
            return node!.stringValue!;
        }
    }
}

用户状态改变的代理(暂时没用)

1
2
3
4
5
6
import Foundation
protocol ChatDelegate{
    func newBuddyOnline(buddyName:String)
    func buddyWentOffline(buddyName:String)
    func didDisconnect()
}

接受消息的代理(通知消息列表页面刷新)

1
2
3
4
import Foundation
protocol MessageDelegate {
    func newMessageReceived(sendMsg: SendMsg)
}