kivy-recv線插座不工作

Question

我做了一個應用程序與kivy的工作，發送「名稱」的服務器（與套接字），服務器插入「名稱」的數據庫，併發回「名稱「到客戶端（應用程序）和客戶端打印它。

我沒有得到任何錯誤，但該應用程序無法正常工作。它不開放。

我的客戶（應用程序）：

# kivy.require("1.8.0") 
from kivy.app import App 
from kivy.uix.label import Label 
from kivy.uix.gridlayout import GridLayout 
from kivy.lang import Builder 
from kivy.uix.screenmanager import ScreenManager, Screen 
from kivy.uix.widget import Widget 
from kivy.uix.textinput import TextInput 
from kivy.graphics import Line 
from kivy.uix.button import Button 
import socket 



Builder.load_string(""" 
#: import FadeTransition kivy.uix.screenmanager.FadeTransition 
<MenuScreen>: 
    BoxLayout: 
     Button: 
      text: 'Sign Up' 
      on_press: 
       root.manager.transition.direction = 'left' 
       root.manager.current = 'settings' 
     Button: 
      text: 'Login' 
      on_press: 
       root.manager.transition.direction = 'left' 
       root.manager.current = 'settings' 

<Searchi>: 
    BoxLayout: 
     Button: 
      text: 'send massage' 
      font_size: '20sp' 
      size_hint: (0.4,0.111) 
      pos_hint: {'y': 0,'x':0.6} 
      on_press: 
       root.manager.transition.direction = 'right' 
       root.manager.current = 'settings' 




<SettingsScreen>: 
    BoxLayout: 
     FloatLayout: 
      LoginScreen 
      Button: 
       font_size: '20sp' 
       size_hint: (0.4,0.111) 
       pos_hint: {'y': 0,'x':0.6} 
       text: 'Back to menu' 
       on_press: 
        root.manager.transition.direction = 'right' 
        root.manager.current = 'menu' 
""") 

class LoginScreen(GridLayout): 
    def __init__(self, **kwargs): 
     super(LoginScreen, self).__init__(**kwargs) 
     self.cols = 2 
     self.my_socket = socket.socket() 
     #host = socket.gethostname() 
     #port = 8585 
     self.my_socket.connect(('127.0.0.1', 8081)) 

     self.add_widget(Label(text='username')) 
     self.username = TextInput(multiline=False) 
     self.add_widget(self.username) 

     self.add_widget(Label(text='Password')) 
     self.password = TextInput(multiline=False, password=True) 
     self.add_widget(self.password) 

     self.submit_button = Button(text='sumbit',size_hint=(.5, 
.25),font_size=20) 
     self.submit_button.bind(on_press=self.submit_username) 
     self.add_widget(self.submit_button) 

    def submit_username(self, *args): 
     # Make sure to validate the input before submitting to the server 
     self.my_socket.send(self.username.text.encode('utf-8')) 
     sm.current = 'searchi' 
     sm.transition.direction = 'left' 

# Declare both screens 
class MenuScreen(Screen): 
    pass 

class SettingsScreen(Screen): 
    pass 

class Searchi(Screen): 
    def __init__(self, **kwargs): 
     super(Searchi, self).__init__(**kwargs) 
     self.my_socket = socket.socket() 
     self.my_socket.connect(('127.0.0.1', 8081)) 
     self.msg=self.my_socket.recv(1024) 
     self.name=self.msg.decode('utf-8') 


     self.add_widget(Label(text="hello"+self.name,size_hint=(1, 
1.7),font_size=20)) 


# Create the screen manager 
sm = ScreenManager() 
sm.add_widget(MenuScreen(name='menu')) 
sm.add_widget(Searchi(name='searchi')) 
sm.add_widget(SettingsScreen(name='settings')) 

class TestApp(App): 

    def build(self): 
     return sm 

if __name__ == '__main__': 
    TestApp().run() 

我的服務器：

import socket 
import db  # import my db 
import time 


server_socket = socket.socket() 
server_socket.bind(('127.0.0.1',8081)) 
server_socket.listen(5) 

(client_socket, client_address) = server_socket.accept() 
while(True): 
    client_username = client_socket.recv(1024) 
    msg=client_username.decode('utf-8') 
    db.data_entry_login(msg,"dsfsds","dsfsfsdd","2") #insert to my db 
    msg=msg+"\r\n" 
    client_socket.send(msg.text.encode('utf-8')) 

你能幫助我嗎？

Answer 1

問題出在你提到的recv方法。
該方法把整個主線程暫停，所以該應用程序不會運行。
只要有什麼東西在主線程中等待或循環，應​​用程序就會停止更新。並且recv正在等待消息。
所以你需要把recv放在一個線程中。

你可以這樣做：

import threading 

class Searchi(Screen): 
    def __init__(self, **kwargs): 
     super(Searchi, self).__init__(**kwargs) 
     self.hello_label = Label(text="Connecting...",size_hint=(1,1.7),font_size=20) 
     threading.Thread(target=self.recv_msg).start() 

    def recv_msg(self): 
     self.my_socket = socket.socket() 
     self.my_socket.connect(('127.0.0.1', 8081)) 
     self.msg=self.my_socket.recv(1024) 
     self.name=self.msg.decode('utf-8') 
     self.hello_label.text = "hello"+self.name