# -*- coding: utf-8 -*-

"""

Created on Thu Nov 12 15:02:53 2020

@author: Administrator

参考网址:https://www.pianshen.com/article/1060421464/

https://blog.csdn.net/qq_40483425/article/details/105475678

"""

import socket

import threading

import time

def recv_msg(udp_socket):

    """接收"""

    while True:

        recv_data = udp_socket.recvfrom(1024)

        print("%s 发送 %s" % (str(recv_data[1]), recv_data[0].decode("gbk")))

def send_msg(udp_socket, dest_ip, dest_port):

    """发送"""

    while True:

        send_data = "haha"

        udp_socket.sendto(send_data.encode("gbk"), (dest_ip, dest_port))

        time.sleep(1) 

def main():

    # 创建套接字

    udp_socket = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)

    # 绑定本地信息

    udp_socket.bind(("", 7890))

    # 获取对方信息

    dest_ip = "192.168.43.216"

    dest_port = 1234

    # 创建两个线程去执行函数

    t1 = threading.Thread(target=recv_msg, args=(udp_socket, ))

    t2 = threading.Thread(target=send_msg, args=(udp_socket, dest_ip, dest_port))

    t1.start()

    t2.start()

    #要有下面的join,否则会运行不完一个线程,就会跳到另一个线程.

    t1.join()

    t2.join()

if __name__ == '__main__':

    main()

'''

这里是关于udp的逻辑实现部分

也就是这里只是upd的各种动作,但是调用这些动作是在main中进行的.

udp是用户数据传输协议,位域TCP/IP协议的传输层.是一种无连接的协议.它发送的报文不能确定是否完整地到达另一端.

[需要做] 怎么实现的界面和逻辑分离, 逻辑如何和界面进行交互. 应该是在main函数里面了

[需要做] 关于Python中类的实现.需要好好弄明白语法.

[需要做] 关于try的用法.

[需要做] 关于socket的用法:https://www.cnblogs.com/nevermore29/p/9592080.html

[需要做] 这里接收数据,创建了一个线程,但是发送数据,并没有创造线程.

[需要做] 修饰器怎么从别的文档引入进来.???

[需要做] 要让udp的那个按钮选一个,开两个进程,就是能用udp发和收.

[心得] socket就是针对服务器,客户端进行  打开-->读写-->关闭  的一系列操作.

[心得] https://blog.csdn.net/qq_41262248/article/details/80791000

       ip:绑定了电脑; 一个电脑一个ip

       端口号:绑定了程序进程; 软件中不同的网口进程,有不同的端口号;  端口号范围0-65536 知名端口号0-1024和动态端口号   80端口网站:http

       局域网中不能有两个相同的ip地址.

'''

import time

from PyQt5 import QtWidgets

import net_stopThreading

import socket

import threading                              #这里是线程吗是的.

import sys

from write_txt import write_txt

from net_time_xh  import fn_timer                 #这个修饰器怎么从别的文档引入.确实是这样,可以这样进行引用了.

from ui_demo_6 import Ui_Form                #这里是界面

#下面这里就是一个网口的类

#里面包含了网口的各种操作

#这里是一个类,然后继承了界面的类

#没有槽函数,关于槽函数的逻辑,都是在主函数那里实现的

class UdpLogic(Ui_Form):

    def __init__(self):

        super(UdpLogic, self).__init__()

        pass

    #这里是选中udp标签之后,就会执行这里.

    #主函数里面会调用这个函数.

    def udp_start(self):

        """

        这个是打开服务器,然后服务器只是负责接收.

        开启UDP服务端方法

        单片机是客户端.

        :return:

        """

        #创建udp对象

        self.udp_socket = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)     #等号后面调用是固定的  创建socket对象,名字是udp_socket  创建udp

        #本地的ip和端口

        #返回里面的文字,返回本地端口号

        #self.local_port=self.net_box_local_portnumber.currentText()

        #self.local_port = int(self.local_port)

#        self.object_port=self.net_box_object_portnumber.currentText()

#        self.local_IP=self.net_box_local_IP.currentText()

#        self.object_IP=self.net_box_object_IP.currentText()

#        print('udp_start',"本地端口号:",self.local_port)

#        print("udp_start","对方端口号:",self.object_port)

#        print('udp_start',"本地IP:",self.local_IP)

#        print("udp_start","对方IP:",self.object_IP) 

        #测试

        self.object_IP= "192.168.43.216"

        self.local_IP = "192.168.43.216"

        self.object_port =2345

        self.local_port=1234

        #gxt先固定端口号

        address = ('', self.local_port)

        self.udp_socket.bind(address)                                          #[注意这里,进行了绑定,那么端口号就是固定的了]绑定地址,address取决于地址族.  这里的address是元组比如:('127.0.0.1',8080)  

        print("开始创建线程了")                                                      #try中没有出现异常情况.

        self.sever_th = threading.Thread(target=self.udp_receive)        #这里是创造一个线程.  注意这里的括号里面,里面是udp_server_concurrency这是一个函数.

        self.send_th = threading.Thread(target=self.udp_send)                       #这里是创造一个线程.  注意这里的括号里面,里面是udp_server_concurrency这是一个函数.

        self.sever_th.start()                                                       #开启线程.   为什么没有加入那个东西.

        self.send_th.start()

        self.sever_th.join()

        self.send_th.join()

        #奇怪,下面这句话输出不了???

        print("线程创建完毕")        

    ################################################################################################################################################################################

    ###############################  接收数据 ###################################

    #读网口会写这个缓存,写txt也会用到这个缓存,这里是不是两个进程都会用到一个内存,所以就是需要用到信号量??

    def udp_receive(self):

        """

        这里是udp的接收.

        用于创建一个线程持续监听UDP通信

        有个疑问?? 开启了这里的线程,那么这个while就会一直执行下去吗???

        """

        while True:

            print("udp_receive","网口正在接收...")

            #time.sleep(1)  #这里是停止1秒

            #有个疑问?这里定义的变量,应该是属于全局变量的,

            #然后怎么在其他文档中用到这个变量.

            self.recv_msg, self.recv_addr = self.udp_socket.recvfrom(1024)                    #这里的参数是从缓冲区度1024字节的数据 接收udp套接字的数据. 返回的是data,address. 其中data是包含接收数据的字符串,address是发送数据的套接字的地址.

            print("%s 接收 %s" % (str(self.recv_addr), self.recv_msg.decode("gbk")))          #这里要注意,window用的是gbk

            #gxt

            #有待完善???

            #write_txt(msg)                                                          #这里还是可以优化的.

            #返回里面的文字,返回本地端口号

    #            self.local_port=self.net_box_local_portnumber.currentText()

    #            self.object_port=self.net_box_object_portnumber.currentText()

    #

    #            self.local_IP=self.net_box_local_IP.currentText()

    #            self.object_IP=self.net_box_object_IP.currentText()            

            #把接收的msg,显示到窗口处

            #有待完善:

            #self.s2__receive_text.emit(msg)                                         #这个是信号   用于显示在接收界面中的.  这里是通过这个刷新ui界面显示的.

    #########################################网口发送数据#############################################

    #################################################################################################

    #这里发送有个问题,端口号总是在改变

    #主函数会调用这个.

    def udp_send(self):

        """

        这里是udp的发送

        功能函数，用于UDP客户端发送消息

        :return: None

        """

        while(1):

            #print("切换到网口发送...")

            time.sleep(1)

            # 获取对方信息

    #        #返回里面的文字,返回本地端口号

    #        self.local_port=self.net_box_local_portnumber.currentText()

    #        self.object_port=self.net_box_object_portnumber.currentText()

    #        #注意!!!从窗口读出来的端口号是字符,必须要转换成数字

    #        self.object_port=int(self.object_port)

    #        self.local_IP=self.net_box_local_IP.currentText()

    #        self.object_IP=self.net_box_object_IP.currentText()

    #        send_msg = (str(self.s3__send_text.toPlainText())).encode("gbk") 

            send_msg="haha"

            self.udp_socket.sendto(send_msg.encode("gbk"), (self.object_IP, self.object_port))

            #有待完善

            #self.s2__receive_text.emit(msg)        

    #下面是关闭udp的.

    def udp_close(self):

        """

        功能函数，关闭网络连接的方法.

        分别代表了关闭服务器和客户端.

        :return:

        """

        try:

            self.udp_socket.close()

            if self.link is True:

                print("已断开网络")

                #有待完善emit

                #self.s2__receive_text.emit(msg)

        except Exception as ret:

            ret=ret #防止报警

            pass

        try:

            net_stopThreading.stop_thread(self.sever_th)

        except Exception:

            pass

        try:

            net_stopThreading.stop_thread(self.client_th)

        except Exception:

            pass

if __name__ == '__main__':

    ui=UdpLogic()

    ui.udp_start()

    print("udp")

    pass