#  注釋的標(biāo)注格式為：每行開(kāi)頭則直接輸入#并空一格開(kāi)始注釋
#  若在每行代碼后面加注釋，則空兩格輸入#再空一格開(kāi)始注釋
import socket
#  使用udp收發(fā)數(shù)據(jù)
def main():
	#  1.創(chuàng)建socket套接字
	udp_socket = socket.socket(socket.AF_INET, sock.SOCK_DGRAM)  # AF_INET表示使用ipv4,默認(rèn)不變，SOCK_DGRAM表示使用UDP通信協(xié)議
	
	#  2.綁定端口port
	local_addr = ("", 7878)  # 默認(rèn)本機(jī)任何ip ，指定端口號(hào)7878
	udp_socket.bind(local_addr)  # 綁定端口
	
	#  3.收發(fā)數(shù)據(jù)
	send_data = input("請(qǐng)輸入您想要發(fā)送的數(shù)據(jù)：" )
	udp_socket.sendto(send_data.encode("utf-8"), ("10.80.34.68", 8080))  # 編碼成全球統(tǒng)一數(shù)據(jù)格式，用元組表示接收方ip和port
	recv_data = udp_socket.recvfrom(1024)  # 定義單次最大接收字節(jié)數(shù)
	
	#  4.打印數(shù)據(jù)
	recv_msg = recv_data[0]  # 接收的元組形式的數(shù)據(jù)有兩個(gè)元素，第一個(gè)為發(fā)送信息
	send_addr = recv_data[1]  # 元組第二個(gè)元素為發(fā)信息方的ip以及port
	print ("收到的信息為：", recv_msg.decode("gbk"))  # 默認(rèn)從windows發(fā)出的數(shù)據(jù)解碼要用”gbk”，保證中文不亂碼
	print ("發(fā)送方地址為：", str(send_addr))  # 強(qiáng)轉(zhuǎn)為字符串輸出地址，保證不亂碼
	
	#  5.關(guān)閉套接字
	udp_socket.close()
if __name__ == "__main__":
main()

socket.socket(AddressFamily,Type)

#import socket
# udp:sock_dgram:數(shù)據(jù)報(bào)套接字
# udpSocket = socket(socket.AF_INET, socket.SOCK_DGRAM)
#
#
# tcp：sock_stream:流式套接字
# tcpSocket = socket(AF_INET, SOCK_STREAM)

#!/usr/bin/env python
# -*- coding: utf-8 -*-
# @Author  : xiaoke
import socket
# 服務(wù)端
def main():
    # 1,創(chuàng)建數(shù)據(jù)報(bào)套接字
    udpSocket = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
    # 2，綁定本地地址，核心是為綁定并公布端口
    # ''表示指定任意ip：0.0.0.0，系統(tǒng)中任意ip的數(shù)據(jù)都可以接收
    myAddr = ('', 8080)
    udpSocket.bind(myAddr)
    # 3，接收客戶端數(shù)據(jù)，獲得客戶端的地址（ip和端口號(hào)）
    recData, clientAddr = udpSocket.recvfrom(1024)
    print(clientAddr)
    print(recData.decode())
    # 4，回復(fù)客戶端消息
    udpSocket.sendto(recData, clientAddr)
    # 5，關(guān)閉socket
    udpSocket.close()
if __name__ == '__main__':
    main()

#!/usr/bin/env python
# -*- coding: utf-8 -*-
# @Author  : xiaoke
import socket
# echo服務(wù)端,回射服務(wù)器，發(fā)過(guò)來(lái)，彈回去
# 單進(jìn)程單線程，無(wú)連接
def main():
    # 1,創(chuàng)建數(shù)據(jù)報(bào)套接字
    udpSocket = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
    # 2，服務(wù)端需要綁定：目的是把端口號(hào)和ip地址暴露給別人，讓別人調(diào)用
    # 表示指定任意ip：0.0.0.0，系統(tǒng)中任意ip的數(shù)據(jù)都可以接收
    myAddr = ('', 8080)
    udpSocket.bind(myAddr)
    while True:
        # 3，接收客戶端數(shù)據(jù)，獲得客戶端的地址（ip和端口號(hào)）
        recData, clientAddr = udpSocket.recvfrom(1024)
        # print(clientAddr)
        print(recData.decode())
        # 4，回復(fù)客戶端消息
        # udpSocket.sendto(recData, clientAddr)
        sendData = input("服務(wù)器！請(qǐng)輸入提供的數(shù)據(jù)：")
        udpSocket.sendto(sendData.encode(), clientAddr)
    # 5，關(guān)閉socket
    udpSocket.close()
if __name__ == '__main__':
    main()

#!/usr/bin/env python
# -*- coding: utf-8 -*-
# @Author  : xiaoke
import socket
# 客戶端
def main():
    # 1,創(chuàng)建udp類型的socket
    udpSocket = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
    # 2，指定目的地址（ip和端口號(hào)
    serverAddr = ('192.168.105.125', 8080)
    while True:
        # 3，發(fā)送數(shù)據(jù)
        sendData = input("客戶端！請(qǐng)輸入請(qǐng)求數(shù)據(jù)：")
        udpSocket.sendto(sendData.encode(), serverAddr)
        # 4，接收數(shù)據(jù)是一個(gè)元組,本次接收數(shù)據(jù)的最大長(zhǎng)度，建議是2^xxx次方
        receData, peerAddr = udpSocket.recvfrom(1024)
        print(receData.decode())
        # print(peerAddr)
    # 5,關(guān)閉socket
    udpSocket.close()
if __name__ == '__main__':
    main()

#!/usr/bin/env python
# -*- coding: utf-8 -*-
# @Author  : xiaoke
import socket
from threading import Thread
def task_recv(s):
    while True:
        recvData, peerAddr = s.recvfrom(1024)
        print('子線程接收：ip地址 %s :  消息 %s' % (str(peerAddr), recvData.decode()))
def task_send(s, addr):
    while True:
        sendData = input('親！請(qǐng)?zhí)峁┓祷氐臄?shù)據(jù)：')
        s.sendto(sendData.encode(), addr)
def main():
    # 1.創(chuàng)建udp數(shù)據(jù)報(bào)套接字
    serverSocket = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
    # 2.綁定本地地址，核心是為綁定并公布端口
    myAddr = ('', 8080)  # ''表示指定任意ip 0.0.0.0 系統(tǒng)中任意ip的數(shù)據(jù)都可以接收
    serverSocket.bind(myAddr)
    # 3.主線程收到消息，獲得對(duì)方的ip,port
    recvData, peerAddr = serverSocket.recvfrom(1024)
    print('主線程接收：ip地址 %s :  消息 %s' % (str(peerAddr), recvData.decode()))
    # 4.啟動(dòng)接收消息線程
    thread_recv = Thread(target=task_recv, args=(serverSocket,))
    thread_recv.start()
    # 5.再啟動(dòng)發(fā)送消息的線程，傳遞對(duì)方的ip port
    thread_send = Thread(target=task_send, args=(serverSocket, peerAddr))
    thread_send.start()
    # 6,等待子線程結(jié)束
    thread_recv.join()
    thread_send.join()
if __name__ == "__main__":
    main()

#!/usr/bin/env python
# -*- coding: utf-8 -*-
# @Author  : xiaoke
from socket import *
def main():
    # 1，創(chuàng)建socket，數(shù)據(jù)報(bào)套接字
    udp_socket = socket(AF_INET, SOCK_DGRAM)
    # 2，設(shè)置允許廣播
    # 設(shè)置socket屬性，是否允許廣播，1就是允許
    udp_socket.setsockopt(SOL_SOCKET, SO_BROADCAST, 1)
    # 3，指定廣播地址（“broadcast”,2425）
    broadcast_addr = ('<broadcast>', 8080)
    # 4,發(fā)送消息,以下以飛秋軟件演示
    send_data = b'1:100:will:will-pc:32:will broadcast'
    udp_socket.sendto(send_data, broadcast_addr)
    udp_socket.close()
if __name__ == '__main__':
    main()