python_TCP_IP_realtime_graph - 8BitsCoding/RobotMentor GitHub Wiki

프로젝트 정보

• 제작시작일 : 19.09.22
• 제작종료일 : 19.09.22
• 언어 : Python3.7
• IDE : Pycharm2019.01.01(Community)
• 라이브러리 : PyQt5, matplotlib, drawnow, numpy, random
• GitHub 주소 : https://github.com/GoodayTH/python_tcp_udp_realtime_graph

---

프로젝트 계획

Send Btn 버튼을 누르면 Server쪽에서 랜덤 데이터를 보내고 Client쪽에서 랜덤 데이터를 받아서 실시간으로 그려준다.

프로젝트는 Python TCP/UDP/WEB tools프로젝트를 기반으로 만든다.

---

핵심코드

client 수신측에서 그래프 그리기

def tcp_client_concurrency(self, address):
    while True:
        recv_msg = self.tcp_socket.recv(1024)
        if recv_msg:
            msg = recv_msg.decode('utf-8')

            msg_recv = 'Target IP:{}Port:{}:\n{}\n'.format(address[0], address[1], msg)

            self.graph_cnt = self.graph_cnt+1
            self.x.append(self.graph_cnt)
            # self.y.append(np.random.random())
            self.y.append(int(msg))

            plt.bar(self.x, self.y)
            drawnow(self.makt_fig)

            self.signal_write_msg.emit(msg_recv)

랜덤 데이터 주기적 송신

def tcp_send_RD(self):

    self.send_RD_th = threading.Thread(target=self.tcp_send_RD_concurrency)
    self.send_RD_th.start()


def tcp_send_RD_concurrency(self):
    if self.link is False:
        # msg = '请选择服务，并点击连接网络\n'
        msg = 'Check Service and click connect button\n'
        self.signal_write_msg.emit(msg)
    else:
        try:
            while True:
                send_msg = (str(randint(0, 100))).encode('utf-8')
                if self.comboBox_tcp.currentIndex() == 0:
                    # 向所有连接的客户端发送消息
                    for client, address in self.client_socket_list:
                        client.send(send_msg)
                    # msg = 'TCP服务端已发送\n'
                    msg = 'TCP Server Send\n'
                else:
                    msg = 'this service only enable for tcp server'
                self.signal_write_msg.emit(msg)
                sleep(1)
        except Exception as ret:
            # msg = '发送失败\n'
            msg = 'Send Error\n'
            self.signal_write_msg.emit(msg)