# udp_gb_server.py
'''服務(wù)端（UDP協(xié)議局域網(wǎng)廣播）'''
import socket,time,struct
s = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
s.setsockopt(socket.SOL_SOCKET, socket.SO_BROADCAST, 1)
PORT = 6454
network ='127.0.0.1'# '<broadcast>'
s.sendto('Client broadcast message!'.encode('utf-8'), (network, PORT))
def formatdata(dvcid,dat):
    sendBuf=[0x41, 0x72, 0x74, 0x2D, 0x4E, 0x65, 0x74, 0x00, 0x00, 0x50, 0x00, 0x0E, 0x77, 0x01]
    #sendBuf[14]設(shè)備節(jié)點(diǎn)
    #sendBuf[15] = 0x00;
    sendBuf.append(dvcid& 0xff)
    sendBuf.append(0x00)
    # 發(fā)送的字節(jié)數(shù) 512
    #sendBuf[16] = 0x02;
    #sendBuf[17] = 0x00;
    datlen = len(dat)
    sendBuf.append((datlen & 0xff00) >> 8)
    sendBuf.append(datlen & 0xff)
    # 發(fā)送的數(shù)據(jù)
    #sendBuf[17+n] = 0x00;
    print( datlen)
    for x in range(datlen):
        pass
        sendBuf.append((dat[x] & 0xff))#.to_bytes(1,'big')
    #data = [1, 2, 3]
    #buffer = struct.pack("!ihb", *data)
    packstyle=str(18+datlen)+'B'#B 0-255
    #req = struct.pack('14b',*sendBuf) 0-127
    req = struct.pack(packstyle, *sendBuf)
    return req
import struct
from ctypes import create_string_buffer
def pack():
    # 創(chuàng)建一個(gè)9字節(jié)大小的緩存區(qū)，初始化默認(rèn)全部為\x00 
    buf = create_string_buffer(9)# buf.raw: '\x00\x00\x00\x00\x00\x00\x00\x00\x00'
    # 沖緩存區(qū)buf的第0個(gè)字節(jié)開(kāi)始打包兩個(gè)4字節(jié)無(wú)符號(hào)整型數(shù)據(jù)1和2
    struct.pack_into(">II", buf, 0, 1, 2)#  buf.raw: '\x00\x00\x00\x01\x00\x00\x00\x02\x00'
    # 然后我們想再打包一個(gè)布爾型數(shù)據(jù)到buf中就可以改變以下偏移量
    struct.pack_into(">?", buf, 8, True)# buf.raw: '\x00\x00\x00\x01\x00\x00\x00\x02\x01'
    return buf
c=0
while True:
    c=c+1
    d=[200,1,2,3,4,5,6,7]
    #d = [0 for i in range(512)]
    a= []
    for i in range(512):
        a.append(i)#'''
    print(a)
    print(c)
    #senddata(2,d)
    req = struct.pack('8B', int('3F', 16), int('20', 16), int('63', 16), int('31', 16), int('0D', 16), int('0A', 16), int('0D', 16), int('0A', 16))
    #s.sendto((b"\x78\x78\x11\x01\x07\x52\x53\x36\x78\x90\x02\x42\x70\x00\x32\x01\x00\x05\x12\x79\x0D\x0A"),(network, PORT))
    #s.sendto(req, (network, PORT))
    s.sendto(formatdata(128,a), (network, PORT))
    #s.sendto(pack(), (network, PORT))
    time.sleep(1)
'''
byte[] sendBuf = new byte[530];//設(shè)置發(fā)送緩存區(qū)
            //41 72 74 2D 4E 65 74 00 00 50 00 0E 77 01
            //按照協(xié)議報(bào)文填充數(shù)據(jù)
            //固定格式
            sendBuf[0] = 0x41;
            sendBuf[1] = 0x72;
            sendBuf[2] = 0x74;
            sendBuf[3] = 0x2D;
            sendBuf[4] = 0x4E;
            sendBuf[5] = 0x65;
            sendBuf[6] = 0x74;
            sendBuf[7] = 0x00;
            sendBuf[8] = 0x00;
            sendBuf[9] = 0x50;
            sendBuf[10] = 0x00;
            sendBuf[11] = 0x0E;
            sendBuf[12] = 0x77;
            sendBuf[13] = 0x01;
            //設(shè)備節(jié)點(diǎn)
            if (Convert.ToInt16(textBox7.Text) > 0 && Convert.ToInt16(textBox7.Text) < 5)
            {
                sendBuf[14] = Convert.ToByte(Convert.ToInt16(textBox7.Text)-1);
            }
            else
            {
                MessageBox.Show("設(shè)備節(jié)點(diǎn)輸入有誤");
            }
            sendBuf[15] = 0x00;
            //發(fā)送的字節(jié)數(shù)
            sendBuf[16] = 0x02;
            sendBuf[17] = 0x00;
            //后面的字節(jié)就是DMX512對(duì)應(yīng)的512個(gè)通道的數(shù)據(jù)了
            if (Convert.ToInt16(textBox1.Text) >= 1 && Convert.ToInt16(textBox1.Text) <= 512 && Convert.ToInt16(textBox2.Text) >= 0 && Convert.ToInt16(textBox2.Text) <= 255)
            {
                sendBuf[17 + Convert.ToInt16(textBox1.Text)] = Convert.ToByte(textBox2.Text);
            }
            else
                MessageBox.Show("通道或數(shù)值參數(shù)輸入有誤");
'''

# udp_gb_client.py
'''客戶端（UDP協(xié)議局域網(wǎng)廣播）'''
import socket
s = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
s.setsockopt(socket.SOL_SOCKET, socket.SO_BROADCAST, 1)
PORT = 6454
s.bind(('127.0.0.1', PORT))
print('Listening for broadcast at ', s.getsockname())
while True:
    data, address = s.recvfrom(65535)
    print('Server received from {}:{}'.format(address, data))

import socket
# 設(shè)置服務(wù)器默認(rèn)端口號(hào)
PORT = 9002
# 創(chuàng)建一個(gè)套接字socket對(duì)象，用于進(jìn)行通訊
# socket.AF_INET 指明使用INET地址集，進(jìn)行網(wǎng)間通訊
# socket.SOCK_DGRAM 指明使用數(shù)據(jù)協(xié)議，即使用傳輸層的udp協(xié)議
server_socket = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
address = ("", PORT)
# 為服務(wù)器綁定一個(gè)固定的地址，ip和端口
server_socket.bind(address)
# 接收客戶端傳來(lái)的數(shù)據(jù) recvfrom接收客戶端的數(shù)據(jù)，默認(rèn)是阻塞的，直到有客戶端傳來(lái)數(shù)據(jù)
# recvfrom 參數(shù)的意義，表示最大能接收多少數(shù)據(jù)，單位是字節(jié)
# recvfrom返回值說(shuō)明
# receive_data表示接受到的傳來(lái)的數(shù)據(jù),是bytes類型, receive_data.decode()解碼，將bytes類型轉(zhuǎn)換為字符串類型
# client_address 表示傳來(lái)數(shù)據(jù)的客戶端的身份信息，客戶端的ip和端口，元組
receive_data, client = server_socket.recvfrom(1024)
print("來(lái)自客戶端%s,發(fā)送的%s" % (client, receive_data.decode()))
# 不再接收數(shù)據(jù)的時(shí)候，將套接字socket關(guān)閉
server_socket.close()

import socket
PORT = 9002
server_socket = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
address = ("192.168.219.129", PORT)
server_socket.bind(address)
while True:
    receive_data, client_address = server_socket.recvfrom(1024)
    print("接收到了客戶端 %s 傳來(lái)的數(shù)據(jù): %s" % (client_address, receive_data.decode()))

import socket
client_socket = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
msg = input("請(qǐng)輸入要發(fā)送的內(nèi)容：")  # 字符串類型， 通過(guò)msg.encode() 編碼 轉(zhuǎn)換為bytes類型
server_address = ("127.0.0.1", 8000)  # 接收方 服務(wù)器的ip地址和端口號(hào)
client_socket.sendto(msg.encode(), server_address)
client_socket.close()

import socket
client_socket = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
while True:
    msg = input("請(qǐng)輸入要發(fā)送的內(nèi)容：")   
    server_address = ("192.168.79.127", 8000)  
    client_socket.sendto(msg.encode(), server_address)