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

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

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

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

概述WebSocket：

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

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

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

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

1.2 WebSocket是如何工作的？

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

1.Pod導入SocketRocket

platform :ios,'7.0'

target '白__Socket--Demo1' do

   pod 'SocketRocket', '~> 0.5.1'

end

2.導入對象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

//連接成功
//代理方法實現(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ù)是接收服務器發(fā)送的pong消息，其中最后一個是接受pong消息的，
在這里就要提一下心跳包，一般情況下建立長連接都會建立一個心跳包，
用于每隔一段時間通知一次服務端，客戶端還是在線，這個心跳包其實就是一個ping消息，
我的理解就是建立一個定時器，每隔十秒或者十五秒向服務端發(fā)送一個ping消息，這個消息可是是空的
- (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:@"您好 ！"];

  }
}

實現(xiàn)效果：