美文网首页
SocketDemo,实时通讯

SocketDemo,实时通讯

作者: Daniel01 | 来源:发表于2016-11-04 11:49 被阅读0次

    实时通讯简化相互通讯,俗称QQ,先输入IP地址进行相互连接,在进行内容相互传递。

    步骤

    Socket实现通讯的步骤
    1.建立连接:服务端持续监听---客户端发起连接请求--服务端收到连接请求--连接成功
    2.发送数据:服务端持续监听---客户端发送数据--服务端接收到数据--数据发送成功
    3.断开连接:

    1.用storyBoard创建简化的界面。

    屏幕快照 2016-11-04 10.05.51.png

    ,并且对界面进行关联

    2.先创建客户端和接收端-加入socket数组-初始化socket-让服务器处于持续监听状态,此时会抛出异常,用do catch解决。

      客户端/发送端
        var sendSocket:AsyncSocket!
      服务端/接收端
        var acceptSocket:AsyncSocket!
    
    socket数组
        var dataArray = NSMutableArray()
        
        override func viewDidLoad() {
            super.viewDidLoad()
    
            
            
            //初始化socket
            sendSocket = AsyncSocket(delegate: self)
            acceptSocket = AsyncSocket(delegate: self)
            
            //1.1/1.2服务器处于持续监听状态
            //port: 端口,是一个虚拟的通道,要实现数据的交换,必须通过port,它的范围为0~65535之间,使用的时候尽量选择大的端口号,小的一般被特殊的功能已经占用
            //需要通讯的双方必须保证端口号是一致的
            do {
             try acceptSocket.acceptOnPort(56789)
            
            
            }catch{
                
            }
        }
    

    2.之间搭建界面有连接button-先对每次连接进行判断,如果有连接线进行断开在重新连接,助于数据保护。

    //连接
    //1.2:客户端发起连接请求

        @IBAction func connectClick(sender: AnyObject) {
            
            if sendSocket.isConnected() {
                
                sendSocket.disconnect() //每次发送连接请求之间判断当前的连接状态,如果处于连接则断开连接,
            }
            
            //持续监听,进行重连
            //参数1:Host表示目标IP地址
            //参数2:端口
            //参数3:连接时间,负数表示持续连接
            do{
          try  sendSocket.connectToHost(self.addressTextField.text, onPort: 56789, withTimeout: -1)
            }catch{
                
            }
            
        }
    

    3.对服务端口进行连接数据请求-在进行追加socket-在向服务器进行持续的监听状态等待数据

    //1.3:服务端端收到连接请求
        func onSocket(sock: AsyncSocket!, didAcceptNewSocket newSocket: AsyncSocket!) {
            
            //向数组中追加新的socket
            self.dataArray.addObject(newSocket)
            
            //服务端持续进行监听
            newSocket.readDataWithTimeout(-1, tag: 0)
            
        }
    

    4.进行测试,先输入一个Print测试是否连接成功

    //1.4连接建立成功
        func onSocket(sock: AsyncSocket!, didConnectToHost host: String!, port: UInt16) {
            print("连接建立成功")
        }
    

    5.建立的界面有发送button,数据相互建立完成,第二步为发送数据-转化数据、写入数据、展示数据.-1为持续监听,tag值设为0足够。最后在发送完成之后,需要清空,以便下次发送!

    //1.2:客户端发送数据
        @IBAction func sendClick(sender: AnyObject) {
        
        
            //转化数据
            let data = self.contentTextField.text?.dataUsingEncoding(NSUTF8StringEncoding)
            //写入数据
            sendSocket.writeData(data, withTimeout: -1, tag: 0)
        
            //展示数据
            self.infoTextView.text = String(format: "%@我说: %@\n", self.infoTextView.text,self.contentTextField.text!)
            
            //清空
            self.contentTextField.text = ""
            
        }
    

    6.服务端接收到消息之后-在将数据格式进行转回为数组,在展示数据-在进行持续进行监听,等到数据

    //1.3服务端收到消息
        func  onSocket(sock: AsyncSocket!, didReadData data: NSData!, withTag tag: Int) {
            //将数据格式转回
            let str = NSString(data: data, encoding: NSUTF8StringEncoding)
            
            //展示数据 第一个%@IP地址 第二个谁的内容 第三个内容
            self.infoTextView.text = String(format: "%@%@说: %@\n", self.infoTextView.text,self.addressTextField.text!,str!)
            
            //持续监听
            sock.readDataWithTimeout(-1, tag: 0)
        }
    

    7.数据发送成功-对方接收成功之后-进行断开连接。在发送消息之时重新在连接

    //1.4数据发送成功
        func onSocket(sock: AsyncSocket!, didWriteDataWithTag tag: Int) {
            print("数据发送成功")
        }
        
        //MARK: 断开连接
        func onSocketDidSecure(sock: AsyncSocket!) {
            print("断开连接")
        }
    
    运行程序:
    屏幕快照 2016-11-04 11.48.04.png

    配套网站 环信及时通信云。

    进入环信开发者中心-网站:http://docs.easemob.com/im/300iosclientintegration/10prepareforsdkimport 注册登录-要求拿到苹果开发者证书-集成SDK(有OC和Swift视频讲解)-配置工程导入SDK- brisetting-关闭bitCode

    相关文章

      网友评论

          本文标题:SocketDemo,实时通讯

          本文链接:https://www.haomeiwen.com/subject/mqgiuttx.html