socket udp bind

Author: windard

README.md

@@ -255,6 +255,10 @@ python的强大之处有很大的一方面在于它有各种各样非常强大
 
 ## [cProfile](content/cProfile.md)
 
+## [ping](content/ping.md)
+
+## [six](content/six.md)
+
 ## [tools](content/tools.md)
 
 ## [Other_thing](content/other_thing.md)

code/ipaddress_demo.py

@@ -0,0 +1,136 @@
+# -*- coding: utf-8 -*-
+
+import struct
+import socket
+import ipaddress
+
+
+def ip2hex(ip, encoding='utf-8'):
+    if type(ip) in [bytes, str]:
+        ip = ip.decode(encoding)
+    elif type(ip) not in [unicode]:
+        raise ValueError("IPAddress not valid")
+    ip_address = ipaddress.ip_address(ip)
+    return ip_address.packed.encode('hex')
+
+
+def hex2ip(ip):
+    return str(ipaddress.ip_address(int(ip, 16)))
+
+
+def int2ip(ip):
+    return str(ipaddress.ip_address(ip))
+
+
+def ip2int(ip, encoding='utf-8'):
+    if type(ip) in [bytes, str]:
+        ip = ip.decode(encoding)
+    elif type(ip) not in [unicode]:
+        raise ValueError("IPAddress not valid")
+    return int(ipaddress.ip_address(ip))
+
+
+def ip2long(ip):
+    packed_ip = socket.inet_aton(ip)
+    return struct.unpack("!L", packed_ip)[0]
+
+
+def hex2ip_old(ip):
+    return ".".join(map(str, map(lambda x: int(x, 16),
+                                 [ip[i:i + 2] for i in
+                                  xrange(0, len(ip), 2)])))
+
+
+def ip2hex_old(ip):
+    return "%02x%02x%02x%02x" % tuple(map(int, ip.split('.')))
+
+
+def ip2hex_struct(ip):
+    ip = map(int, ip.split('.'))
+    return struct.pack('BBBB', *ip).encode('hex')
+
+
+def hex2ip_struct(ip):
+    return '.'.join(map(str, struct.unpack('BBBB', ip.decode('hex'))))
+
+
+def ip2int_old(ip):
+    ip = map(int, ip.split('.'))
+    return (ip[0] << 24) + (ip[1] << 16) + (ip[2] << 8) + ip[3]
+
+
+def int2ip_old(ip):
+    ip = '{:032b}'.format(ip)
+    return '.'.join(map(str,
+                        [int(ip[:8], 2), int(ip[8:16], 2), int(ip[16:24], 2),
+                         int(ip[24:], 2)]))
+
+
+def ip2int_struct(ip):
+    ip = map(int, ip.split('.'))
+    return struct.unpack('>I', struct.pack('>BBBB', *ip))[0]
+
+
+def int2ip_struct(ip):
+    return '.'.join(
+        map(str, struct.unpack('BBBB', '{:x}'.format(ip).decode('hex'))))
+
+
+def ip_int2hex(ip):
+    return struct.pack('>I', ip).encode('hex')
+
+
+def ip_hex2int(ip):
+    return struct.unpack('>I', ip.decode('hex'))[0]
+
+
+def parse_peers(peers):
+    ip, port = peers[:8], peers[8:]
+    return '{}:{}'.format(hex2ip(ip), int(port, 16))
+
+
+def parse_peers_struct(peers):
+    ip_port = struct.unpack('>BBBBH', peers.decode('hex'))
+    return '{}.{}.{}.{}:{}'.format(*ip_port)
+
+
+def combine_peers(peers):
+    ip, port = peers.split(":")
+    return '%s%04x' % (ip2hex(ip), int(port))
+
+
+def combine_peers_struct(peers):
+    ip, port = peers.split(':')
+    ip = map(int, ip.split('.'))
+    port = int(port)
+    ip_port = ip + [port]
+    return struct.pack('>BBBBH', *ip_port).encode('hex')
+
+
+if __name__ == '__main__':
+    # print ip2hex('127.12.13.14')
+    # print ip2hex_struct('127.12.13.14')
+    # print hex2ip('7f0c0d0e')
+    # print hex2ip_struct('7f0c0d0e')
+    # print ip2int('127.12.13.14')
+    # print struct.unpack('BBBB', '7f0c0d0e'.decode('hex'))
+    # print repr(struct.pack('>I', 10240099))
+    # print struct.pack('BBBB', 127, 12, 13, 14).encode('hex')
+    # print combine_peers('127.12.13.14:1234')
+    # print struct.unpack('>BBBBH', '7f0c0d0e04d2'.decode('hex'))
+    # print parse_peers_struct('7f0c0d0e04d2')
+    # print struct.pack('>BBBBH', 127, 12, 13, 14, 1234).encode('hex')
+    # print combine_peers_struct('127.12.13.14:1234')
+
+    print ip2int('127.12.13.14')
+    print ip2int_old('127.12.13.14')
+    print int2ip_old(2131496206)
+    print int2ip_struct(2131496206)
+    print ip2int_struct('127.12.13.14')
+    # print struct.unpack('BBBB', '{:x}'.format(2131496206).decode('hex'))
+    # print struct.unpack('>I', '{:x}'.format(2131496206).decode('hex'))
+    # print repr(struct.pack('>I', 2131496206))
+    # print repr(struct.unpack('>I', '7f0c0d0e'.decode('hex')))
+    # print struct.unpack('>I', struct.pack('>BBBB', 127, 12, 13, 14))
+    print struct.pack('>I', 2131496206).encode('hex')
+    print struct.unpack('>I', '7f0c0d0e'.decode('hex'))[0]

code/selenium_screenshot.py

@@ -0,0 +1,17 @@
+from selenium import webdriver
+
+driver = webdriver.Chrome()     # 打开 Chrome 浏览器
+
+# 将刚刚复制的帖在这
+driver.get("https://morvanzhou.github.io/")
+driver.find_element_by_xpath(u"//img[@alt='强化学习 (Reinforcement Learning)']").click()
+driver.find_element_by_link_text("About").click()
+driver.find_element_by_link_text(u"赞助").click()
+driver.find_element_by_link_text(u"教程 ▾").click()
+driver.find_element_by_link_text(u"数据处理 ▾").click()
+driver.find_element_by_link_text(u"网页爬虫").click()
+
+# 得到网页 html, 还能截图
+html = driver.page_source       # get html
+driver.get_screenshot_as_file("./img/sreenshot1.png")
+driver.close()

code/six_demo.py

@@ -0,0 +1,8 @@
+# coding=utf-8
+
+import six
+
+six.print_(six.PY2)
+six.print_(six.PY3)
+
+six.print_(six.string_types)

code/socket_udp_bind.py

@@ -0,0 +1,45 @@
+# -*- coding: utf-8 -*-
+
+import sys
+import socket
+import threading
+
+host = '127.0.0.1'
+port = 1234
+bufsize = 1024
+
+
+def server(udpsock):
+    print "Waiting for message ... "
+    while 1:
+        data, addr = udpsock.recvfrom(bufsize)
+        print '[%s:%s]: %s' % (addr[0], addr[1], data)
+
+
+def main(host, port):
+
+    udpsock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
+    udpsock.bind((host, port))
+    threading.Thread(target=server, args=(udpsock,)).start()
+
+    import pdb
+    pdb.set_trace()
+
+    # while 1:
+    #     data = raw_input(">")
+    #     if not data:
+    #         break
+    #     udpsock.sendto(data, (host, port))
+    #     data, addr = udpsock.recvfrom(bufsize)
+    #     if not data:
+    #         break
+    #     print data
+
+    udpsock.close()
+
+
+if __name__ == '__main__':
+    if len(sys.argv) > 2:
+        host = sys.argv[1]
+        port = int(sys.argv[2])
+    main(host, port)

content/contextlib.md

@@ -182,6 +182,20 @@ with reckon_time():
     print countsum(100000)
 ```
 
+或者是用来忽略异常
+
+```
+@contextlib.contextmanager
+def ignore_errors(*errors):
+    if not errors:
+        errors = Exception
+    try:
+        yield
+    except errors:
+        pass
+
+```
+
 如果有多个上下文嵌套的话，可以使用双重 with 语句，或者 with 语句并列。如果 Python 版本小于 2.7 则需要使用 `contextlib.nested` 来减少 with 的嵌套
 
 ```

content/datetime.md

@@ -308,3 +308,24 @@ def datetime_next_day(datetime_obj):
     return datetime_obj + timedelta(days=1)
 
 ```
+
+### 获得当天剩余时间
+
+```
+# -*- coding: utf-8 -*-
+import datetime
+
+
+def get_today_seconds_left():
+    now = datetime.datetime.now()
+    end = now.date() + datetime.timedelta(days=1)
+    return int(time.mktime(end.timetuple()) - time.mktime(now.timetuple()))
+
+
+def get_daily_left_seconds():
+    now = datetime.datetime.now()
+    last_second = datetime.datetime.combine(datetime.date.today(),
+                                            datetime.time.max)
+    return int((last_second - now).total_seconds())
+
+```

content/ipaddress.md

@@ -6,6 +6,7 @@ IP Address 解析库
 # -*- coding: utf-8 -*-
 
 import struct
+import socket
 import ipaddress
 
 
@@ -34,6 +35,11 @@ def ip2int(ip, encoding='utf-8'):
     return int(ipaddress.ip_address(ip))
 
 
+def ip2long(ip):
+    packed_ip = socket.inet_aton(ip)
+    return struct.unpack("!L", packed_ip)[0]
+
+
 def hex2ip_old(ip):
     return ".".join(map(str, map(lambda x: int(x, 16),
                                  [ip[i:i + 2] for i in

content/itertools.md

@@ -1,6 +1,6 @@
 ## itertools
 
-### 迭代器 
+### 迭代器
 
 迭代器 (iterator) 是可迭代对象的一种。
 
@@ -163,4 +163,6 @@ StopIteration
 - product(p, q, ... [,repeat=1]) 取循环集合的笛卡尔积 如 product([1,2,3,4],['a','b','c']) 得到 (1,'a'),(1,'b'),(1,'c'),(2,'a'),(2,'b'),(2,'c')...(4,'b'),(4,'c')
 - permutations(q[,r=1]) q 做 r 位的全排列 如 permutations('abcde',3) 得到 ('a', 'b', 'c'),('a', 'b', 'd')...('c','d','e') |共 60 组
 - combinations(q,r=1) q 做 r 位的全组合 如 combinations('abcde',3) 得到 ('a', 'b', 'c'),('a', 'b', 'd')...('c','d','e') |共 10 组
-- combinations_with_replacement(p,r) 与 combinations 类似 ，但是允许元素重复出现，如 combinations_with_replacement('abcde',3) 得到 ('a', 'a', 'a'),('a', 'a', 'b'),...('e','e','e') | 共 125 组
+- combinations_with_replacement(p,r) 与 combinations 类似 ，但是允许元素重复出现，如 combinations_with_replacement('abcde',3) 得到 ('a', 'a', 'a'),('a', 'a', 'b'),...('e','e','e') | 共 125 组
+
+

content/other_thing.md

@@ -76,6 +76,10 @@ npm install http-server -g
 - urllib.quote <-> urllib.unquote
 - urlparse.urlparse <-> urlparse.urlunparse
 
+7. 转义
+
+- re.escape 转义非法字符串
+
 ```
 # -*- coding: utf-8 -*-
 

content/pdb.md

@@ -10,3 +10,9 @@ pdb.set_trace()
 ```
 
 然后就可以了。
+
+2018-09-15
+
+需注意两点
+1. 在 pdb 中不能创建新的变量
+2. 在 pdb 中不能给已有的变量赋值

content/ping.md

@@ -0,0 +1,58 @@
+## ping
+
+服务器上最常见的网络命令，测试网络是否通畅，能否抵达目标。
+
+一般用来根据能否 ping 通来判断自身的网络连接或者目标的网络连接，根据 ping 的时长来检测网络连接状况。
+
+ping 使用 ICMP(internet control message protocol) 协议，不在 TCP/IP 协议层中，所以没有特定的端口号，如果强行使用 socket 连接，可以设置端口号为 1.
+
+在七层网络模型中，icmp 是第三层协议，TCP/UDP 是第四层协议。
+
+[An ICMP Reference](https://danielmiessler.com/study/icmp/)
+
+如果使用 ping 命令来判断是否网络通畅
+
+```
+import os
+
+status = os.system("ping -c 1 www.baidu.com");
+
+if status == 0:
+    print '连接成功!';
+else:
+    print '连接失败';
+
+```
+
+或者使用 ping 这个 python 库
+
+```
+# -*- coding: utf-8 -*-
+
+import sys
+import ping
+import socket
+
+
+def ping_test(host):
+    try:
+        ping.quiet_ping(host, count=1)
+    except socket.error:
+        return False
+    else:
+        return True
+
+
+if __name__ == '__main__':
+
+    if len(sys.argv) < 2:
+        print """
+        Uasge: python ping_test.py baidu.com
+
+        """
+        sys.exit(0)
+    print ping_test(sys.argv[1])
+
+```
+
+使用时需注意使用 root 权限运行。