TCP/IP

Author: heyxiaohao

.settings/org.eclipse.core.resources.prefs

@@ -1,5 +1,7 @@
 eclipse.preferences.version=1
+encoding/Collections\u96C6\u5408\u6A21\u5757.py=utf-8
 encoding/IO\u7F16\u7A0B.py=utf-8
+encoding/TCPIP.py=utf-8
 encoding/\u5206\u5E03\u5F0F\u8FDB\u7A0B.py=utf-8
 encoding/\u591A\u7EBF\u7A0B.py=utf-8
 encoding/\u591A\u8FDB\u7A0B.py=utf-8

Collections集合模块.py

@@ -0,0 +1,62 @@
+#!/usr/bin/env python
+# -*- coding: utf-8 -*-
+
+# namedtuple()函数创建自定义的tuple
+from collections import namedtuple
+Point = namedtuple('Point', ['x', 'y'])
+p = Point(101, 2)
+print p.x
+print p.y
+
+# deque双端队列
+from collections import deque
+q = deque(['a', 'b', 'c'])
+q.append('x')
+q.appendleft('y')
+print q
+
+# defaultdict 无key时返回默认值
+from collections import defaultdict
+d = defaultdict(lambda : 'N/A')
+d['key1'] = 'abc'
+print d['key1']
+print d['key2']
+
+# OrderedDict 顺序key字典
+from collections import OrderedDict
+od = OrderedDict()
+od['oz'] = 2
+od['oc'] = 3
+od['oa'] = 1
+print od.keys()
+
+# Counter 简单计数器
+from collections import Counter
+c = Counter()
+for ch in 'programming':
+    c[ch] += 1
+print c
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+

TCPIP.py

@@ -0,0 +1,87 @@
+#!/usr/bin/env python
+# -*- coding: utf-8 -*-
+
+import socket
+import threading, time
+
+type = 'client'
+if type == 'client':
+    # 创建socket AF_INET IPV4  AF_INET6 IPV6
+    s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
+    # 建立连接:
+    s.connect(('192.168.1.108', 9999))
+    # 接收欢迎消息:
+    print s.recv(1024)
+    for data in ['Michael', 'Tracy', 'Sarah']:
+        # 发送数据:
+        s.send(data)
+        print s.recv(1024)
+        s.send('exit')
+    s.close()
+   
+else:
+    def tcplink(sock, addr):
+        print 'Accept new connect from %s:%s...' % addr
+        sock.send('Welcome')
+        while True:
+            data = sock.recv(1024)
+            time.sleep(1)
+            if data == 'exit' or not data:
+                break
+            sock.send('Hello %s' % data)
+        sock.close()
+        print 'Connection from %s:%s closed' % addr
+    
+    s = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
+    # 监听端口
+    s.bind(('0.0.0.0', 9999))
+    s.listen(5)
+    print 'waiting for connect...'
+    while True:
+        # 接收一个新连接
+        sock, addr = s.accept()
+        # 创建新线程处理
+        t = threading.Thread(target = tcplink, args = (sock, addr))
+        
+        
+        
+        
+        
+        
+        
+        
+        
+        
+        
+        
+        
+        
+        
+        
+        
+        
+        
+        
+        
+        
+        
+        
+        
+        
+        
+        
+        
+        
+        
+        
+        
+        
+        
+        
+        
+        
+        
+        
+        
+        
+