tcp连接代码python(tcp连接失败)

如何使用Python和Nose实现自动化测试？ 如何使用Python和Nose实现自动化测试？ 本文我将详细介绍使用Appium下的Python编写的测试的例子代码对一个iOS的样例应用进行测试所涉及的各个步骤，而对Android应用进行测试所需的步骤与此非常类似。

建议你下载我的java版本至尊聊天程序源码下去参考。在CSDN或百度上找吧。 协议完全自己来定制，数据以字节发送，以什么开始，什么结束，中间分几段，都可由你自己来定，接收时，就按你定的规则来解析并还原。比如：我要的协议格式为:>10:3:5:content:<:>表示一条消息的开始。10表示总消息长度（只是个代数，有可能不是10，需要你在发送前计算）:为分隔符3为头消息长度，也可能不是35表示后面的消息内容长度，甚至还可以定制，是否有图片，从多少位置开始是图片的数据。:<表示结束标志没有人限制你的协议。 关键一点：你在收取的时候，一定要注意数据可能会粘包，这个问题很头疼的。因为一般都是多线程模式。这需要你自己来处理它。一言难清。可以参考我的聊天程序。
java的socket就有tcp的封装吧，不需要写吧

socket(family,type[,protocal]) 使用给定的地址族、套接字类型、协议编号（默认为0）来创建套接字。有效的端口号： 0～ 65535但是小于1024的端口号基本上都预留给了操作系统POSIX兼容系统(如Linux、Mac OS X等)，在/etc/services文件中找到这些预留端口与的列表面向连接的通信提供序列化、可靠的和不重复的数据交付，而没有记录边界。意味着每条消息都可以拆分多个片段，并且每个消息片段都能到达目的地，然后将它们按顺序组合在一起,最后将完整的信息传递给等待的应用程序。实现方式(TCP)：传输控制协议（TCP）， 创建TCP必须使用SOCK_STREAM作为套接字类型因为这些套接字（AF_INET）的网络版本使用因特网协议(IP)来搜寻网络中的IP,所以整个系统通常结合这两种协议(TCP/IP)来进行网络间数据通信。数据报类型的套接字, 即在通信开始之前并不需要建议连接,当然也无法保证它的顺序性、可靠性或重复性实现方式(UDP)用户数据包协议（UDP), 创建UDP必须使用SOCK_DGRAM (datagram)作为套接字类型它也使用因特网来寻找网络中主机，所以是UDP和IP的组合名字UDP/IP注意点:1）TCP发送数据时，已建立好TCP连接，所以不需要指定地址。UDP是面向无连接的，每次发送要指定是发给谁。2）服务端与客户端不能直接发送列表，元组，字典。需要字符串化repr(data)。TCP的优点：可靠，稳定 TCP的可靠体现在TCP在传递数据之前，会有三次握手来建立连接，而且在数据传递时，有确认、窗口、重传、拥塞控制机制，在数据传完后，还会断开连接用来节约系统资源。TCP的缺点：慢，效率低，占用系统资源高，易被攻击 TCP在传递数据之前，要先建连接，这会消耗时间，而且在数据传递时，确认机制、重传机制、拥塞控制机制等都会消耗大量的时间，而且要在每台设备上维护所有的传输连接，事实上，每个连接都会占用系统的CPU、内存等硬件资源。 而且，因为TCP有确认机制、三次握手机制，这些也导致TCP容易被人利用，实现DOS、DDOS、CC等攻击。什么时候应该使用TCP :当对网络通讯质量有要求的时候，比如：整个数据要准确无误的传递给对方，这往往用于一些要求可靠的应用，比如HTTP、HTTPS、FTP等传输文件的协议，POP、SMTP等邮件传输的协议。 在日常生活中，常见使用TCP协议的应用如下： 浏览器，用的HTTP FlashFXP，用的FTP Outlook，用的POP、SMTP Putty，用的Telnet、SSH QQ文件传输.UDP的优点：快，比TCP稍安全 UDP没有TCP的握手、确认、窗口、重传、拥塞控制等机制，UDP是一个无状态的传输协议，所以它在传递数据时非常快。没有TCP的这些机制，UDP较TCP被攻击者利用的漏洞就要少一些。但UDP也是无法避免攻击的，比如：UDP Flood攻击……UDP的缺点：不可靠，不稳定 因为UDP没有TCP那些可靠的机制，在数据传递时，如果网络质量不好，就会很容易丢包。什么时候应该使用UDP：当对网络通讯质量要求不高的时候，要求网络通讯速度能尽量的快，这时就可以使用UDP。 比如，日常生活中，常见使用UDP协议的应用如下： QQ语音 QQ视频 TFTP ……

websocket是一个浏览器和服务器通信的新的协议，一般而言，浏览器和服务器通信最常用的是http协议，但是http协议是无状态的，每次浏览器请求信息，服务器返回信息后这个浏览器和服务器通信的信道就被关闭了，这样使得服务器如果想主动给浏览器发送信息变得不可能了，服务器推技术在http时代的解决方案一个是客户端去轮询，或是使用comet技术，而websocket则和一般的socket一样，使得浏览器和服务器建立了一个双工的通道。 具体的websocket协议在rfc6455里面有，这里简要说明一下。websocket通信需要先有个握手的过程，使得协议由http转变为webscoket协议，然后浏览器和服务器就可以利用这个socket来通信了。首先浏览器发送握手信息，要求协议转变为websocketGET / HTTP/1.1Host: example.comUpgrade: websocketConnection: UpgradeSec-WebSocket-Key: dGhlIHNhbXBsZSBub25jZQ==Origin:服务器接收到信息后，取得其中的Sec-WebSocket-Key，将他和一个固定的字符串258EAFA5-E914-47DA-95CA-C5AB0DC85B11做拼接，得到的字符串先用sha1做一下转换，再用base64转换一下，就得到了回应的字符串，这样服务器端发送回的消息是这样的HTTP/1.1 101 Switching ProtocolsUpgrade: websocketConnection: UpgradeSec-WebSocket-Accept: s3pPLMBiTxaQ9kYGzzhZRbK+xOo=这样握手就完成了，用python来实现这段握手过程的话就是下面这样。def handshake(conn):key =Nonedata = conn.recv(8192)if not len(data):return Falsefor line in data.split('rnrn')[0].split('rn')[1:]:k, v = line.split(': ')if k =='Sec-WebSocket-Key':key =base64.b64encode(hashlib.sha1(v +'258EAFA5-E914-47DA-95CA-C5AB0DC85B11').digest())if not key:conn.close()return Falseresponse ='HTTP/1.1 101 Switching Protocolsrn''Upgrade: websocketrn''Connection: Upgradern''Sec-WebSocket-Accept:'+ key +'rnrn'conn.send(response)return True握手过程完成之后就是信息传输了，websocket的数据信息格式是这样的。+-+-+-+-+-------+-+-------------+-------------------------------+0 1 2 30 1 2 3 4 5 6 7 8 9 0 1 2 3 4 5 6 7 8 9 0 1 2 3 4 5 6 7 8 9 0 1+-+-+-+-+-------+-+-------------+-------------------------------+|F|R|R|R| opcode|M| Payload len |Extended payload length||I|S|S|S|(4)|A| (7) | (16/64) ||N|V|V|V| |S| | (if payload len==126/127) || |1|2|3| |K| | |+-+-+-+-+-------+-+-------------+ - - - - - - - - - - - - - - - +| Extended payload length continued, if payload len == 127|+ - - - - - - - - - - - - - - - +-------------------------------+| | Masking-key, if MASK set to 1 |+-------------------------------+-------------------------------+| Masking-key (continued) |Payload Data |+-------------------------------- - - - - - - - - - - - - - - - +: Payload Data continued ...:+ - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - +| Payload Data continued ...|+---------------------------------------------------------------+值得注意的是payload len这项，表示数据的长度有多少，如果小于126，那么payload len就是数据的长度，如果是126那么接下来2个字节是数据长度，如果是127表示接下来8个字节是数据长度，然后后面会有四个字节的mask，真实数据要由payload data和mask做异或才能得到，这样就可以得到数据了。发送数据的格式和接受的数据类似，具体细节可以去参考rfc6455，这里就不过多赘述了。Python的Websocket客户端：Websocket-ClientWebsocket-Client 是 Python 上的 Websocket 客户端。它只支持 hybi-13，且所有的 Websocket API 都支持同步。InstallationThis module is tested on Python 2.7 and Python 3.x.Type "python setup.py install" or "pip install websocket-client" to install.Caution!from v0.16.0, we can install by "pip install websocket-client" for python 3.This module depend onsixbackports.ssl_match_hostname for Python 2.xPython通过websocket与js客户端通信示例分析这里，介绍如何使用 Python 与前端 js 进行通信。websocket 使用 HTTP 协议完成握手之后，不通过 HTTP 直接进行 websocket 通信。于是，使用 websocket 大致两个步骤：使用 HTTP 握手，通信。js 处理 websocket 要使用 ws 模块； Python 处理则使用 socket 模块建立 TCP 连接即可，比一般的 socket ，只多一个握手以及数据处理的步骤。包格式js 客户端先向服务器端 python 发送握手包，格式如下：GET /chat HTTP/1.1Host: server.example.comUpgrade: websocketConnection: UpgradeSec-WebSocket-Key: dGhlIHNhbXBsZSBub25jZQ==Origin:Sec-WebSocket-Protocol: chat, superchatSec-WebSocket-Version: 13服务器回应包格式：HTTP/1.1 101 Switching ProtocolsUpgrade: websocketConnection: UpgradeSec-WebSocket-Accept: s3pPLMBiTxaQ9kYGzzhZRbK+xOo=Sec-WebSocket-Protocol: chat其中， Sec-WebSocket-Key 是随机的，服务器用这些数据构造一个 SHA-1 信息摘要。方法为： key+migic ， SHA-1加密， base-64 加密Python 中的处理代码:MAGIC_STRING = '258EAFA5-E914-47DA-95CA-C5AB0DC85B11'res_key = base64.b64encode(hashlib.sha1(sec_key + MAGIC_STRING).digest())握手完整代码js 端js 中有处理 websocket 的类，初始化后自动发送握手包，如下：var socket = new WebSocket('ws://localhost:3368');Python 端Python 用 socket 接受得到握手字符串，处理后发送HOST = 'localhost'PORT = 3368MAGIC_STRING = '258EAFA5-E914-47DA-95CA-C5AB0DC85B11'HANDSHAKE_STRING = "HTTP/1.1 101 Switching Protocolsrn" "Upgrade:websocketrn" "Connection: Upgradern" "Sec-WebSocket-Accept: {1}rn" "WebSocket-Location: ws://{2}/chatrn" "WebSocket-Protocol:chatrnrn"def handshake(con):#con为用socket，accept()得到的socketheaders = {}shake = con.recv(1024)if not len(shake):return Falseheader, data = shake.split('rnrn', 1)for line in header.split('rn')[1:]:key, val = line.split(': ', 1)headers[key] = valif 'Sec-WebSocket-Key' not in headers:print ('This socket is not websocket, client close.')con.close()return Falsesec_key = headers['Sec-WebSocket-Key']res_key = base64.b64encode(hashlib.sha1(sec_key + MAGIC_STRING).digest())str_handshake = HANDSHAKE_STRING.replace('{1}', res_key).replace('{2}', HOST + ':' + str(PORT))print str_handshakecon.send(str_handshake)return True通信不同版本的浏览器定义的数据帧格式不同， Python 发送和接收时都要处理得到符合格式的数据包，才能通信。Python 接收Python 接收到浏览器发来的数据，要解析后才能得到其中的有用数据。固定字节：（ 1000 0001 或是 1000 0002 ）这里没用，忽略包长度字节：第一位肯定是 1 ，忽略。剩下 7 个位可以得到一个整数 (0 ~ 127) ，其中（ 1-125 ）表此字节为长度字节，大小即为长度；（126）表接下来的两个字节才是长度；（127）表接下来的八个字节才是长度；用这种变长的方式表示数据长度，节省数据位。mark 掩码：mark 掩码为包长之后的 4 个字节，之后的兄弟数据要与 mark 掩码做运算才能得到真实的数据。兄弟数据：得到真实数据的方法：将兄弟数据的每一位 x ，和掩码的第 i%4 位做 xor 运算，其中 i 是 x 在兄弟数据中的索引。完整代码def recv_data(self, num):try:all_data = self.con.recv(num)if not len(all_data):return Falseexcept:return Falseelse:code_len = ord(all_data[1]) & 127if code_len == 126:masks = all_data[4:8]data = all_data[8:]elif code_len == 127:masks = all_data[10:14]data = all_data[14:]else:masks = all_data[2:6]data = all_data[6:]raw_str = ""i = 0for d in data:raw_str += chr(ord(d) ^ ord(masks[i % 4]))i += 1return raw_strjs 端的 ws 对象，通过 ws.send(str) 即可发送ws.send(str)Python 发送Python 要包数据发送，也需要处理固定字节：固定的 1000 0001( ‘ x81 ′ )包长：根据发送数据长度是否超过 125 ， 0xFFFF(65535) 来生成 1 个或 3 个或 9 个字节，来代表数据长度。def send_data(self, data):if data:data = str(data)else:return Falsetoken = "x81"length = len(data)if length < 126:token += struct.pack("B", length)elif length <= 0xFFFF:token += struct.pack("!BH", 126, length)else:token += struct.pack("!BQ", 127, length)#struct为Python中处理二进制数的模块，二进制流为C，或网络流的形式。data = '%s%s' % (token, data)self.con.send(data) return True

大多数连接都是可靠的TCP连接。创建TCP连接时，主动发起连接的叫客户端，被动响应连接的叫服务器。 举个例子，当我们在浏览器中访问新浪时，我们自己的计算机就是客户端，浏览器会主动向新浪的服务器发起连接。如果一切顺利，新浪的服务器接受了我们的连接，一个TCP连接就建立起来的，后面的通信就是发送网页内容了。所以，我们要创建一个基于TCP连接的Socket，可以这样做：# 导入socket库:import socket# 创建一个socket:s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)# 建立连接:s.connect(( , 80)) 创建Socket时，AF_INET指定使用IPv4协议，如果要用更先进的IPv6，就指定为AF_INET6。SOCK_STREAM指定使用面向流的TCP协议，这样，一个Socket对象就创建成功，但是还没有建立连