WebSocket是一种在Web应用程序中实现双向通信的协议。它允许客户端和服务器之间建立一个持久性的连接，以便可以在任何时间点进行双向通信。传统的HTTP请求-响应模式只支持客户端发起请求，服务器做出响应。也就是说，当一个页面被加载时，它通常会发起一个HTTP请求获取某些资源，例如HTML、CSS和JavaScript文件等。一旦这些资源被发送到浏览器，连接就被关闭了，除非有其他请求发送。对于某些Web应用程序，需要更加实时的交互。这就是WebSocket所提供的优势：它们允许客户端和服务器之间保持开放的连接，使得双方可以随时发送消息。WebSocket使用HTTP协议进行握手，然后升级到WebSocket协议。一旦这个升级完成，客户端和服务器将使用WebSocket协议进行通信。WebSocket通过使用标准的TCP/IP套接字来实现，在网络上发送和接收数据。WebSocket在很多场景下都非常实用，比如在线游戏、实时聊天、股票行情推送等，可以大大提高应用程序的交互效果和用户体验。
1. 建立在 TCP 协议之上，服务器端的实现比较容易。
2. 与 HTTP 协议有着良好的兼容性。默认端口也是80和443，并且握手阶段采用 HTTP 协议，因此握手时不容易屏蔽，能通过各种 HTTP 代理服务器。
3. 数据格式比较轻量，性能开销小，通信高效。
4. 可以发送文本，也可以发送二进制数据。
5. 没有同源限制，客户端可以与任意服务器通信。
6. 协议标识符是ws（如果加密，则为wss），服务器网址就是URL。`ws://example.com:80/some/path`
7. 全双工通信。
使用方法和之前的第三方库一样，利用cocoapods导库，具体操作就不详写了，在之前的博客里也写到过。
导入头文件设置代理
在需要用的地方导入#import
SRWebSocket的初始化和建立连接
self.socket = [[SRWebSocket alloc] initWithURLRequest:[NSURLRequest requestWithURL:[NSURL URLWithString:[NSString stringWithFormat:@"ws://101.43.193.62:9090/ws?id=%d", self.senderSubscriberNumber]]]];
self.socket.delegate = self;
NSLog(@"Opening Connection...");
dispatch_queue_t queue = dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_LOW, 0);
dispatch_async(queue, ^{
[self.socket open];
});
在这里看到，我为什么把[self.socketopen];这句代码放在了一个异步并发队列里，在之前我直接在主线程调用open方法，编译器给我报了一堆奇怪的东西，查找之后告诉我是线程优先级倒置导致的：在iOS中，每个线程都有一个与之关联的QualityofService级别，用于指定它的相对优先级。QOS_CLASS_USER_INTERACTIVE表示线程需要立即响应并具有最高优先级，而QOS_CLASS_DEFAULT表示线程具有默认优先级。
这个问题的原因应该是这个第三方库底层的原因，我看了一些源码，发现调用了很多GCD的东西，暂时还没发现原因。
SRWebSocketDelegate代理方法实现
//socket 连接成功
- (void)webSocketDidOpen:(SRWebSocket *)webSocket {
NSLog(@"Websocket Connected");
}
//socket 连接失败
- (void)webSocket:(SRWebSocket *)webSocket didFailWithError:(NSError *)error {
NSLog(@":( Websocket Failed With Error %@", error);
self.socket = nil;
// 断开连接后每过1s重新建立一次连接
dispatch_after(dispatch_time(DISPATCH_TIME_NOW, (int64_t)(1 * NSEC_PER_SEC)), dispatch_get_main_queue(), ^{
[self setSocket];
});
}
//socket连接断开
- (void)webSocket:(SRWebSocket *)webSocket didCloseWithCode:(NSInteger)code reason:(NSString *)reason wasClean:(BOOL)wasClean {
NSLog(@"WebSocket closed");
self.socket = nil;
}
//收到消息
- (void)webSocket:(SRWebSocket *)webSocket didReceiveMessage:(id)message {
NSLog(@"Received "%@"", message);
}
四个最常用方法分别表示，连接成功，连接失败，连接断开，和收到消息，我们在每个协议函数中做自己该做的事即可。
后端发给我的信息是这样的：在接收到消息时本想用字典存储，转化的时候刚开始一直有问题，试了好多次才转化成功。
NSString *messageString = (NSString *)message;
NSData *messageData = [messageString dataUsingEncoding:NSUTF8StringEncoding];
NSDictionary *messageDictionary = [NSJSONSerialization JSONObjectWithData:messageData options:kNilOptions error:nil];
加上简单UI实现两个用户之间简单通信
浅看了一点点源码
基本初始化方法-initWithURLRequest:requestprotocols:protocolsallowsUntrustedSSLCertificates:allowsUntrustedSSLCertificates
底层调用了_SR_commonInit方法
//初始化
- (void)_SR_commonInit;
{
//得到url schem小写
NSString *scheme = _url.scheme.lowercaseString;
//如果不是这几种，则断言错误
assert([scheme isEqualToString:@"ws"] || [scheme isEqualToString:@"http"] || [scheme isEqualToString:@"wss"] || [scheme isEqualToString:@"https"]);
_readyState = SR_CONNECTING;
_webSocketVersion = 13;
//初始化工作的队列，串行
_workQueue = dispatch_queue_create(NULL, DISPATCH_QUEUE_SERIAL);
//给队列设置一个标识,标识为指向自己的，上下文对象为这个队列
dispatch_queue_set_specific(_workQueue, (__bridge void *)self, maybe_bridge(_workQueue), NULL);
//设置代理queue为主队列
_delegateDispatchQueue = dispatch_get_main_queue();
//retain主队列？
sr_dispatch_retain(_delegateDispatchQueue);
//读Buffer
_readBuffer = [[NSMutableData alloc] init];
//输出Buffer
_outputBuffer = [[NSMutableData alloc] init];
//当前数据帧
_currentFrameData = [[NSMutableData alloc] init];
//消费者数据帧的对象
_consumers = [[NSMutableArray alloc] init];
_consumerPool = [[SRIOConsumerPool alloc] init];
//注册的runloop
_scheduledRunloops = [[NSMutableSet alloc] init];
....省略了一部分代码
}
整个过程：
判断协议类型初始化了_workQueue，这个GCD队列用来处理主要的业务逻辑，包括处理错误、发送内容、关闭连接等。初始化_delegateDispatchQueue，这个队列是用来向外发送通知的。我们可以通过-setDelegateOperationQueue:queue或-setDelegateDispatchQueue:queue来自定义这个队列。
创建输入输出流
//初始化流
- (void)_initializeStreams;
{
//断言 port值小于UINT32_MAX
assert(_url.port.unsignedIntValue <= UINT32_MAX);
//拿到端口
uint32_t port = _url.port.unsignedIntValue;
//如果端口号为0，给个默认值，http 80 https 443;
if (port == 0) {
if (!_secure) {
port = 80;
} else {
port = 443;
}
}
NSString *host = _url.host;
CFReadStreamRef readStream = NULL;
CFWriteStreamRef writeStream = NULL;
//用host创建读写stream,Host和port就绑定在一起了
CFStreamCreatePairWithSocketToHost(NULL, (__bridge CFStringRef)host, port, &readStream, &writeStream);
//绑定生命周期给ARC _outputStream = __bridge transfer
_outputStream = CFBridgingRelease(writeStream);
_inputStream = CFBridgingRelease(readStream);
//代理设为自己
_inputStream.delegate = self;
_outputStream.delegate = self;
}
open方法
//开始连接
- (void)open;
{
assert(_url);
//如果状态是正在连接，直接断言出错
NSAssert(_readyState == SR_CONNECTING, @"Cannot call -(void)open on SRWebSocket more than once");
//自己持有自己
_selfRetain = self;
//判断超时时长
if (_urlRequest.timeoutInterval > 0)
{
dispatch_time_t popTime = dispatch_time(DISPATCH_TIME_NOW, _urlRequest.timeoutInterval * NSEC_PER_SEC);
//在超时时间执行
dispatch_after(popTime, dispatch_get_main_queue(), ^(void){
//如果还在连接，报错
if (self.readyState == SR_CONNECTING)
[self _failWithError:[NSError errorWithDomain:@"com.squareup.SocketRocket" code:504 userInfo:@{NSLocalizedDescriptionKey: @"Timeout Connecting to Server"}]];
});
}
//开始建立连接
[self openConnection];
}
//开始连接
- (void)openConnection;
{
//更新安全、流配置
[self _updateSecureStreamOptions];
//判断有没有runloop
if (!_scheduledRunloops.count) {
//SR_networkRunLoop会创建一个带runloop的常驻线程，模式为NSDefaultRunLoopMode。
[self scheduleInRunLoop:[NSRunLoop SR_networkRunLoop] forMode:NSDefaultRunLoopMode];
}
//开启输入输出流
[_outputStream open];
[_inputStream open];
}
- (void)scheduleInRunLoop:(NSRunLoop *)aRunLoop forMode:(NSString *)mode;
{
[_outputStream scheduleInRunLoop:aRunLoop forMode:mode];
[_inputStream scheduleInRunLoop:aRunLoop forMode:mode];
//添加到集合里，数组
[_scheduledRunloops addObject:@[aRunLoop, mode]];
}
再往后就没看了，浅看了这两三个方法，后面还会调的方法：
didConnect构建HTTPHeader发送HTTPHeader注册一个接收服务器返回Header信息的监听，并在回调内进行相应处理-safeHandleEvent:eventCodestream:aStream这是NSStream的回调方法，输入和输出流的共同回调NSStreamEventOpenCompleted连接打开；NSStreamEventHasBytesAvailable可读取；NSStreamEventHasSpaceAvailable可写入数据在NSStreamEventOpenCompleted里面的[self_pumpScanner];用来触发第5条中的来处理服务器返回的握手Header信息
文章为作者独立观点，不代表 股票程序化软件自动交易接口观点
相关文章
股民评论