本文共 2175 字,大约阅读时间需要 7 分钟。
static PassRefPtr<ThreadableWebSocketChannel>
ThreadableWebSocketChannel::create(ScriptExecutionContext*, WebSocketChannelClient*); >>其中WebSocketChannelClient是指WebSocket对象 >>该类是一个抽象类(virtual void connect(const KURL&, const String& protocol) = 0;) >>实现调度 return WebSocketChannel::create(toDocument(context), client); 子类 >> class WebSocketChannel : public RefCounted<WebSocketChannel>, public SocketStreamHandleClient, public ThreadableWebSocketChannel { } 引用通用的枚举类型 virtual ThreadableWebSocketChannel::SendResult send(const Blob&) OVERRIDE; class ThreadableWebSocketChannel { public: enum SendResult{ EABC, EABB }; } WebSocket::connect() ThreadableWebSocketChannel::connect() WebSocketChannel::connect() { m_handshake = adoptPtr(new WebSocketHandshake(url, protocol, m_document)); InspectorInstrumentation::didCreateWebSocket(m_document, m_identifier, url, m_document->url(), protocol);//事件通知 m_handle = SocketStreamHandle::create(m_handshake->url(), this);//创建Socket数据流句柄 } WebSocket协议中握手是一个网络通信的一个环节,此情况确实化作一个对象来专职负责握手的流程。 #讲一个复杂的协议被分解为具体的Object进行表示 { m_secWebSocketKey = generateSecWebSocketKey(); m_expectedAccept = getExpectedWebSocketAccept(m_secWebSocketKey);//固定字符串 - 计算SHA1值 -> Base64编码 } 所谓的握手不再是简单的socket接受,然后读取,然后判断,而是直接创建一个对应的对象。 所谓的连接不再是简单的校验,而是直接创建一个SocketStreamHandler处理 class SocketStreamHandle : public RefCounted<SocketStreamHandle>, public SocketStreamHandleBase { }//定义的标准的接口类,交由具体的平台加以实现 SocketStreamHandleCurl.cpp platform/network/curl SocketStreamHandleWin.cpp platform/network/win SocketStreamHandleQt.cpp platform/network/cqt SocketStreamHandleBlackBerry.cpp platform/network/blackberry SocketStreamHandleSoup.cpp platform/network/soup SocketStreamHandleCFNet.cpp platform/network/cf m_handle = SocketStreamHandle::create(m_handshake->url(), this); >>其中this为WebSocketChannel >>参数2为(SocketStreamHandleClient* client) int SocketStreamHandle::platformSend(const char* data, int len) { return m_p->send(data, len); } # SocketStreamHandlePrivate* m_p; >> 本质是进一步委托QTcpSocket* m_socket;来实现send等动作 bool isSecure = url.protocolIs("wss"); if (isSecure) m_socket = new QSslSocket(this); else m_socket = new QTcpSocket(this); m_socket->connectToHost(host, port);