Socket就是对于传输层TCP/IP的封装
简述:
- 由于最近项目的需要,需要使用到Socket,所以就趁此整理了一下,网上对于Socket的理论知识有很多,这里就不必多说,此篇文章主要在Swift环境下使用CocoaAsyncSocket库,来实现一个非常简单的Socket连接的例子,帮助大家理解和使用.(大神勿喷呀,哈哈)
1.创建Swift工程,并使用Cocoapods导入CocoaAsyncSocket
1.创建工程
Cocoapods:
use_frameworks!
pod 'CocoaAsyncSocket'
2.搭建服务端和客户端UI
-
使用Tabbar分别创建服务端界面和客户端界面
服务端和客户端的界面搭建
-
分别创建服务端和客户端ViewController并关联相关Textfield 和 Button
4.服务端创建Socket绑定端口,设置监听,消息发送等方法
- ServerViewController
//
// ServerViewController.swift
// TestSocket
//
// Created by YYQ on 6/21/16.
// Copyright © 2016 YYQ. All rights reserved.
//
import UIKit
import CocoaAsyncSocket
class ServerViewController: UIViewController {
//端口
@IBOutlet weak var portTF: UITextField!
//消息
@IBOutlet weak var msgTF: UITextField!
//信息显示
@IBOutlet weak var infoTV: UITextView!
//服务端和客户端的socket引用
var serverSocket: GCDAsyncSocket?
var clientSocket: GCDAsyncSocket?
override func viewDidLoad() {
super.viewDidLoad()
}
//对InfoTextView添加提示内容
func addText(text: String) {
infoTV.text = infoTV.text.stringByAppendingFormat("%@\n", text)
}
///监听
@IBAction func listeningAct(sender: AnyObject) {
serverSocket = GCDAsyncSocket(delegate: self, delegateQueue: dispatch_get_main_queue())
do {
try serverSocket?.acceptOnPort(UInt16(portTF.text!)!)
addText("监听成功")
}catch _ {
addText("监听失败")
}
}
///发送
@IBAction func sendAct(sender: AnyObject) {
let data = msgTF.text?.dataUsingEncoding(NSUTF8StringEncoding)
//向客户端写入信息 Timeout设置为 -1 则不会超时, tag作为两边一样的标示
clientSocket?.writeData(data, withTimeout: -1, tag: 0)
}
}
extension ServerViewController: GCDAsyncSocketDelegate {
//当接收到新的Socket连接时执行
func socket(sock: GCDAsyncSocket!, didAcceptNewSocket newSocket: GCDAsyncSocket!) {
addText("连接成功")
addText("连接地址" + newSocket.connectedHost)
addText("端口号" + String(newSocket.connectedPort))
clientSocket = newSocket
//第一次开始读取Data
clientSocket!.readDataWithTimeout(-1, tag: 0)
}
func socket(sock: GCDAsyncSocket!, didReadData data: NSData!, withTag tag: Int) {
let message = String(data: data,encoding: NSUTF8StringEncoding)
addText(message!)
//再次准备读取Data,以此来循环读取Data
sock.readDataWithTimeout(-1, tag: 0)
}
}```
######5.客户端创建Socket,设置连接,消息发送,读取,断开连接等方法
- ClientViewController
``` Swift
//
// ClientViewController.swift
// TestSocket
//
// Created by YYQ on 6/21/16.
// Copyright 2016 YYQ. All rights reserved.
//
import UIKit
import CocoaAsyncSocket
class ClientViewController: UIViewController {
//IP地址
@IBOutlet weak var ipTF: UITextField!
//端口
@IBOutlet weak var portTF: UITextField!
//消息
@IBOutlet weak var msgTF: UITextField!
//信息显示
@IBOutlet weak var infoTV: UITextView!
var socket: GCDAsyncSocket?
override func viewDidLoad() {
super.viewDidLoad()
}
func addText(text: String) {
infoTV.text = infoTV.text.stringByAppendingFormat("%@\n", text)
}
//连接
@IBAction func connectionAct(sender: AnyObject) {
socket = GCDAsyncSocket(delegate: self, delegateQueue: dispatch_get_main_queue())
do {
try socket?.connectToHost(ipTF.text, onPort: UInt16(portTF.text!)!)
addText("连接成功")
}catch _ {
addText("连接失败")
}
}
//断开
@IBAction func disconnectAct(sender: AnyObject) {
socket?.disconnect()
addText("断开连接")
}
//发送
@IBAction func sendMsgAct(sender: AnyObject) {
socket?.writeData(msgTF.text?.dataUsingEncoding(NSUTF8StringEncoding), withTimeout: -1, tag: 0)
}
}
extension ClientViewController: GCDAsyncSocketDelegate {
func socket(sock: GCDAsyncSocket!, didConnectToHost host: String!, port: UInt16) {
addText("连接服务器" + host)
self.socket?.readDataWithTimeout(-1, tag: 0)
}
func socket(sock: GCDAsyncSocket!, didReadData data: NSData!, withTag tag: Int) {
let msg = String(data: data, encoding: NSUTF8StringEncoding)
addText(msg!)
socket?.readDataWithTimeout(-1, tag: 0)
}
}
|服务端| 客户端 |
|-----|:----:|----|
|
|
结语:
CocoaAsyncSocket的使用还是非常直观清晰的,这里只是简单的抛砖引玉,要更深入理解Socket,如果有时间的话,我觉得还是研究下底层的socket实现比较好,大家有什么问题欢迎提出来,一起共勉~
如果本文对你有用，非常感谢能给个赞噢~~
- 推荐 ：
iOS进阶技术群：1080059793，讨论技术， 大家一起交流学习成长
申请即送： 各类资料免费领取，包括 BAT大厂面试题、数据结构、底层进阶、图形视觉、音视频、架构设计、逆向安防、RxSwift、flutter
网友评论