实时通讯简化相互通讯,俗称QQ,先输入IP地址进行相互连接,在进行内容相互传递。
步骤
Socket实现通讯的步骤
1.建立连接:服务端持续监听---客户端发起连接请求--服务端收到连接请求--连接成功
2.发送数据:服务端持续监听---客户端发送数据--服务端接收到数据--数据发送成功
3.断开连接:
1.用storyBoard创建简化的界面。
,并且对界面进行关联
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("断开连接")
}
运行程序:
配套网站 环信及时通信云。
进入环信开发者中心-网站:http://docs.easemob.com/im/300iosclientintegration/10prepareforsdkimport 注册登录-要求拿到苹果开发者证书-集成SDK(有OC和Swift视频讲解)-配置工程导入SDK- brisetting-关闭bitCode