快捷導(dǎo)航

iOS開發(fā)項(xiàng)目- 基于WebSocket的聊天通訊（1）

更新時(shí)間：2016年11月11日 08:42:02 作者：小兵快跑

這篇文章主要介紹了iOS開發(fā)項(xiàng)目- 基于WebSocket的聊天通訊,WebSocket是web通信方式的一種,有需要的可以了解一下。

公司項(xiàng)目需要開發(fā)一個(gè)類似QQ、微信的即時(shí)IM聊天功能，做到實(shí)時(shí)監(jiān)控消息，需要用的技術(shù)是websocket。

概述WebSocket：

1.1 為什么我們需要WebSocket這樣的實(shí)時(shí)的通信協(xié)議？

WebSocket是web通信方式的一種，像我們熟知的HTTP協(xié)議也是web通信方式的一種。但是我們知道HTTP協(xié)議是一種無狀態(tài)的協(xié)議，其服務(wù)端本身不具備識(shí)別客戶端的能力，必須借助外部的一些信息比如說session和cookie，才能與特定的客戶端保持通信。也就是說我們所發(fā)送的每一個(gè)HTTP的請(qǐng)求都會(huì)帶上請(qǐng)求頭中一些相應(yīng)的信息還有cookie，這明顯會(huì)增加我們傳輸?shù)男畔⒌捏w量從而帶來一定的網(wǎng)絡(luò)延遲，對(duì)于一些對(duì)通信的實(shí)時(shí)性要求比較高的應(yīng)用來說就是不可忍受的了，比如說聊天程序或者是運(yùn)行在瀏覽器中的實(shí)時(shí)小游戲。最郁悶的卻還是這些頭信息和cookie往往對(duì)于服務(wù)器響應(yīng)客戶端的請(qǐng)求來說是多余的，也就是說雖然我每個(gè)請(qǐng)求都帶了這些信息，但是服務(wù)器與客戶端的交互過程中可能根本用不上這些信息。

為了改善HTTP請(qǐng)求的這種網(wǎng)絡(luò)延遲的情況，也出現(xiàn)了一些適應(yīng)不同需求的其他的[web通信]方式，比如說：輪詢，長(zhǎng)輪詢(long-polling)，數(shù)據(jù)流，EventSouce等等，WebSocket便是其中一種。

實(shí)際上大多數(shù)基于因特網(wǎng)（或者局域網(wǎng)）的網(wǎng)絡(luò)鏈接通常都包含長(zhǎng)連接和基于TCP套接字的雙向消息交換。但是TCP協(xié)議是屬于最底層的網(wǎng)絡(luò)通信協(xié)議了，讓一些不能信任的客戶端腳本去訪問底層的TCP套接字顯然是不太安全的，因此WebSocket實(shí)現(xiàn)了一種較為安全的方案，它允許客戶端腳本在客戶端和支持WebSocket協(xié)議的服務(wù)器之間創(chuàng)建雙向的套接字連接。從而使實(shí)時(shí)通信的某些網(wǎng)絡(luò)操作變得簡(jiǎn)單。

1.2 WebSocket是如何工作的？

我們知道了WebSocket的主要作用是，允許服務(wù)器端與客戶端進(jìn)行全雙工（full-duplex）的實(shí)時(shí)通信。這里有個(gè)例子特別好：HTTP協(xié)議像發(fā)電子郵件，發(fā)出后必須等待對(duì)方回信；WebSocket則是像打電話，服務(wù)器端和客戶端可以同時(shí)向?qū)Ψ桨l(fā)送數(shù)據(jù)，它們之間存著一條持續(xù)打開的數(shù)據(jù)通道。

1.Pod導(dǎo)入SocketRocket

platform :ios,'7.0'

target '白__Socket--Demo1' do

   pod 'SocketRocket', '~> 0.5.1'

end

2.導(dǎo)入對(duì)象SRWebSocket

#import "ViewController.h"
#import "SRWebSocket.h"
@interface ViewController ()<SRWebSocketDelegate>
@property(nonatomic,strong) SRWebSocket *webSocket;
@end

@implementation ViewController

- (void)viewDidLoad {
  [super viewDidLoad];


}

//初始化
- (void)Reconnect{

  NSLog(@"1221---open");

  self.webSocket.delegate = nil;
  [self.webSocket close];

  self.webSocket = [[SRWebSocket alloc] initWithURLRequest:[NSURLRequest requestWithURL:[NSURL URLWithString:@"ws://192.168.5.120:4141"]]];
  self.webSocket.delegate = self;
  self.title = @"Opening Connection...";

  [self.webSocket open];
}

- (void)viewWillAppear:(BOOL)animated{
  [self Reconnect];
}

- (void)viewDidDisappear:(BOOL)animated{
  // Close WebSocket
  self.webSocket.delegate = nil;
  [self.webSocket close];
  self.webSocket = nil;
 }

3.SRWebSocketDelegate

//連接成功
//代理方法實(shí)現(xiàn)
#pragma mark - SRWebSocketDelegate
- (void)webSocketDidOpen:(SRWebSocket *)webSocket{

  NSLog(@"Websocket Connected");
  self.title = @"Connected!";
 }
//連接失敗
- (void)webSocket:(SRWebSocket *)webSocket didFailWithError:(NSError *)error{
  NSLog(@":( Websocket Failed With Error %@", error);

  self.title = @"Connection Failed! (see logs)";
  self.webSocket = nil;
 }
//接收到新消息的處理
- (void)webSocket:(SRWebSocket *)webSocket didReceiveMessage:(id)message{
//  NSString *str1 = self.replyContent.text;
//  NSString *str2 = [str1 stringByAppendingFormat:@"%@\n",message];
//  self.replyContent.text = str2;

  NSLog(@"%@--askl",message);

 }
//連接關(guān)閉
- (void)webSocket:(SRWebSocket *)webSocket didCloseWithCode:(NSInteger)code reason:(NSString *)reason wasClean:(BOOL)wasClean{
  NSLog(@"Closed Reason:%@",reason);
  self.title = @"Connection Closed! (see logs)";
  self.webSocket = nil;
 }
//該函數(shù)是接收服務(wù)器發(fā)送的pong消息，其中最后一個(gè)是接受pong消息的，
在這里就要提一下心跳包，一般情況下建立長(zhǎng)連接都會(huì)建立一個(gè)心跳包，
用于每隔一段時(shí)間通知一次服務(wù)端，客戶端還是在線，這個(gè)心跳包其實(shí)就是一個(gè)ping消息，
我的理解就是建立一個(gè)定時(shí)器，每隔十秒或者十五秒向服務(wù)端發(fā)送一個(gè)ping消息，這個(gè)消息可是是空的
- (void)webSocket:(SRWebSocket *)webSocket didReceivePong:(NSData *)pongPayload{

  NSString *reply = [[NSString alloc] initWithData:pongPayload encoding:NSUTF8StringEncoding];
  NSLog(@"%@",reply);
 }

#pragma mark - SendButton Response
- (IBAction)sendAction:(id)sender {
  [self.view endEditing:YES];
  // WebSocket
  if (self.webSocket) {

    [self.webSocket send:@"您好 ！"];

  }
}

實(shí)現(xiàn)效果：