有关python socket 多线程问题

我现在写的程序是模拟p2p DHT 就是peer1 知道peer2 和 peer3的port 依此类推 现在我写了一个程序 打开的每个xterm端口是一个peer 窗口里可以显示ping所返回的信息
代码如下
我测试了好久 有的显示返回信息 有的显示接收信息 有的豆显示 有的根本不显示
刚学编程半年 python很多东西不了解 socket 和多线程完全是先学先用的 所以请各位看一下
到底问题出在哪里

以下是代码

import sys
import time
import socket
import threading

class peer_server(threading.Thread):
def init(self):
threading.Thread.__init__(self)
self.ID = None
self.port = None
def run(self):
print(self.port)
server_port = self.port
serverSocket = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
serverSocket.bind(('', server_port))
while 1:
message, clientAddress = serverSocket.recvfrom(2048)
sendMessage = 'A ping response message was received from Peer {:}'.format(self.ID)
serverSocket.sendto(sendMessage.encode('ascii') , clientAddress)
print('server {:}'.format(self.ID))
print(message.decode('ascii'))
print(time.time())

class peer_client(threading.Thread):
def init(self):
threading.Thread.__init__(self)
self.ID = None
self.port1 = None
self.port2 = None

def run(self):
    while 1:
        server_port = self.port1
        clientSocket = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
        sendMessage = 'A ping request message was received from Peer {:}'.format(self.ID)
        clientSocket.sendto(sendMessage.encode('ascii'),('', server_port))
        receiveMessage, serverAddress = clientSocket.recvfrom(2048)
        print('client {:}'.format(self.ID))
        print(receiveMessage.decode('ascii'))
        print(time.time())
        clientSocket.close()
        server_port = self.port2
        clientSocket = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
        clientSocket.sendto(sendMessage.encode('ascii'),('', server_port))
        receiveMessage, serverAddress = clientSocket.recvfrom(2048)
        print('client {:}'.format(self.ID))
        print(receiveMessage.decode('ascii'))
        print(time.time())
        clientSocket.close()
        time.sleep(5)

class peer(threading.Thread):
ID = None
port = None
port1 = None
port2 = None
def init(self, ID, fID, sID):
self.ID = ID
self.port = 50000 + ID
self.port1 = 50000 + fID
self.port2 = 50000 + sID
def start_server(self):
server = peer_server()
server.ID = self.ID
server.port = self.port
server.start()
def ping(self):
client = peer_client()
client.ID = self.ID
client.port1 = self.port1
client.port2 = self.port2
client.start()

p0 = peer(int(sys.argv[1]), int(sys.argv[2]), int(sys.argv[3]))
p0.start_server()
p0.ping()

1个回答

xterm -hold -title "Peer 1" -e "python3 cdht.py 1 3 4" &
xterm -hold -title "Peer 3" -e "python3 cdht.py 3 4 5" &
xterm -hold -title "Peer 4" -e "python3 cdht.py 4 5 8" &
xterm -hold -title "Peer 5" -e "python3 cdht.py 5 8 10" &
xterm -hold -title "Peer 8" -e "python3 cdht.py 8 10 12" &
xterm -hold -title "Peer 10" -e "python3 cdht.py 10 12 15" &
xterm -hold -title "Peer 12" -e "python3 cdht.py 12 15 1" &
xterm -hold -title "Peer 15" -e "python3 cdht.py 15 1 3" &

测试的所需要的代码
在terminal输入

Csdn user default icon
上传中...
上传图片
插入图片
抄袭、复制答案,以达到刷声望分或其他目的的行为,在CSDN问答是严格禁止的,一经发现立刻封号。是时候展现真正的技术了!
其他相关推荐
python多线程tcp服务器并发测试问题

我自己写了一个Python多线程tcp服务器,具体业务逻辑是 主线程创建socket套接字, 并处理消息盒子 创建线程变成监听套接字并等待连接, 每连接一个socket,会再起一个线程用于等待接收消息,并放入消息盒子。 另起线程等待从消息盒子取出消息,发送。 我目前在进行压力测试,测试中发现,连接数只能达到300左右,超过以后,服务器报错如下。 ![图片说明](https://img-ask.csdn.net/upload/202006/28/1593312844_706968.png) 有没有大佬看看啥情况

Python 使用多线程写入数据库,报错

#问题描述,定义了一个函数,用于数据库写入表,直接使用函数是可以运行,但我创建了一个 多线程,在多线程里面使用运行函数,然后后错 import mysql.connector from mysql.connector import errorcode import threading,time #数据库连接参数 def sqlconn(): dbconfig={'user': 'qrcodeadmin','password': 'careyes!@#','host': '119.23.8.62','port':3308,'database': 'qrcodes','raise_on_warnings': True} try: cnx = mysql.connector.connect(**dbconfig) print('数据库连接成功') except mysql.connector.Error as err: if err.errno == errorcode.ER_ACCESS_DENIED_ERROR: print("Something is wrong with your user name or password") elif err.errno == errorcode.ER_BAD_DB_ERROR: print("Database does not exist") else: print(err.encode) return cnx def handle(): while(True): global UID,ID for i in range(50): print(i) sqlinsert="INSERT INTO qrcode (URL,QrID) VALUES (%s,%s)",(UID,ID) cur.execute(sqlinsert[0],sqlinsert[1]) cur.execute(sqlinsert[0],sqlinsert[1]) dbcon.commit() if __name__=='__main__': global cur dbcon=sqlconn() cur=dbcon.cursor() UID=' MjAxNzEwMTExMjQyNDQ' ID='201710111242420111' #直接使用handle可以运行 handle() #------------- sql_thread=threading.Thread(target=handle) #如果使用线程就会报错 sql_thread.start() dbcon.close() print(dbcon) #报错内容 Exception in thread Thread-1: Traceback (most recent call last): File "C:\Python\lib\site-packages\mysql\connector\connection.py", line 280, in _send_cmd self._socket.send( AttributeError: 'NoneType' object has no attribute 'send' During handling of the above exception, another exception occurred: Traceback (most recent call last): File "C:\Python\lib\threading.py", line 914, in _bootstrap_inner self.run() File "C:\Python\lib\threading.py", line 862, in run self._target(*self._args, **self._kwargs) File "sqltestV0.2_Thread.py", line 34, in handle cur.execute(sqlinsert[0],sqlinsert[1]) File "C:\Python\lib\site-packages\mysql\connector\cursor.py", line 561, in exe cute self._handle_result(self._connection.cmd_query(stmt)) File "C:\Python\lib\site-packages\mysql\connector\connection.py", line 514, in cmd_query result = self._handle_result(self._send_cmd(ServerCmd.QUERY, query)) File "C:\Python\lib\site-packages\mysql\connector\connection.py", line 284, in _send_cmd raise errors.OperationalError("MySQL Connection not available.") mysql.connector.errors.OperationalError: MySQL Connection not available.

关于python3多线程的问题

代码如下: ![图片说明](https://img-ask.csdn.net/upload/201805/01/1525173395_783298.jpg) 我在每次循环后开启一个线程, 想问一下,程序线程的运行是每循环一次开启一个线程,然后执行相应的程序等这个等这些线程执行完毕后再 进入下个循环,还是这个线程开启后(相应的线程没有执行完毕)紧接着就会进入下个循环,开启下个线程? 像上边的代码,我运行后,电脑直接卡死了,我的初衷只是开启5个线程... 请高手指点一下,谢谢。

怎样实现python的多线程监听,当子线程运行时暂停主线程?

比如我的主线程是持续执行的,同时有一个thread1和thread2分别监听两个不同的信号 当thread1接受到信号时执行对应程序,但同时暂停主线程的执行 一旦thread1程序结束,主线程继续运行,两个子线程也继续监听?

python使用多线程下载网页 结果下载到的内容相同。。

``` import aiohttp import asyncio import time import multiprocessing as mp import requests from bs4 import BeautifulSoup import socket import re import pprint header = 'http://osu.ppy.sh/' middle = 'p/pp/?' mode = 'm=3' # 0=stanard 1=taiko 2=ctb 3=mania url = header + middle + mode + '&' page = [1, 3] # 开始页数-结束页数 badRequest = {} # pageNum:resCode htmls={} colls={} #way store in mongoDB : collection: {"_id":"1", "Rank":"1","Player Name":"Jakads","Accuracy":"97.59%","Play Count":"" #"Performance":"17288pp"} def getPages(pageNum): #每1秒获取一个页面当做缓存 global url #global badRequest #global htmls try: print('开始get网页,pageNum=',pageNum) res = requests.get(url=url + 'page=' +str(pageNum), timeout=10) print(url + 'page=' +str(pageNum)) time.sleep(.1) # 如果res不等于200 重试3次 count = 0 #print(res.status_code) while (res.status_code != 200 and count <= 3): res.status_code = requests.get(url=url + 'page=' +str(pageNum), timeout=10) print('restart get') count += 1 if (res.status_code == 200): return res.text else: return res.status_code if(res.status_code==200): writez(res.text) return res.text else: print( 'pageNum : ', pageNum, '返回码 : ', res.status_code) return res.status_code except Exception as e: print(e) return None def findTags(html,startNum): soup = BeautifulSoup(html, features='lxml') tables = soup.findAll('table') # print(len(tables)) for t in tables: sec = 0 #table顺序 for tr in t.tbody.findAll('tr'): # print('sec:',sec) td_sec = 0 #table内顺序 for td in tr.findAll('td'): text = td.get_text().strip() # print(len(text)) if (td_sec == 0): dict = {"rank": text} elif (td_sec == 1): dict.update({"Player Name": text}) elif (td_sec == 2): dict.update({"Accuracy": text}) elif (td_sec == 3): dict.update({"Play Count": text}) elif (td_sec == 4): dict.update({"Performance": text}) elif (td_sec == 5): dict.update({"SS": text}) elif (td_sec == 6): dict.update({"S": text}) elif (td_sec == 7): dict.update({"A": text}) td_sec += 1 #每一次遍历+1 colls[str(startNum+sec)] = dict sec += 1 #每一个用户+1 def writez(msg): with open('tmp.txt','w',encoding='utf-8') as f: f.write(msg) if __name__=='__main__': startTime = time.time() pool = mp.Pool() jobs=[pool.apply_async(getPages,args=(pageNum,))for pageNum in range(page[0],page[1]+1)] pool.close() pool.join() results=[f.get() for f in jobs] # for z in jobs: # writez(str(z.get())) #print(len(results)) startNum=1 #print(results[2]) for h in range(0,len(results)): findTags(results[h],startNum) startNum+=50 pprint.pprint(colls) #print(htmls) print('花费时间 : ', time.time() - startTime, 's') print('ok') ```

这是一个关于PYTHON多线程多进程的问题

这是我写的服务器代码 ``` import socket,os from multiprocessing import Process def haha(yong): while True: data=yong.recv(100) if data.decode()!='q': yong.send(data) else: yong.send('q'.encode()) yong.close() break if __name__ == '__main__': service = socket.socket(socket.AF_INET, socket.SOCK_STREAM) service.bind(('127.0.0.1', 6)) service.listen(4) print(os.getpid()) while True: yong,add=service.accept() jaiyou=Process(target=haha,args=(yong,)) jaiyou.start() service.close() ``` 这是我写的客户机代码 ``` import socket,os quest1=socket.socket(socket.AF_INET,socket.SOCK_STREAM) quest1.connect(('127.0.0.1',6)) while True: quest1.send(input().encode()) data=quest1.recv(100).decode() if data=='q': break; else: print(os.getpid()) continue quest1.close() ``` 当多个客户机 连接一个服务器的时候,每个进程ID号都是不同的,这我可以理解,多进程嘛 但是,当我把服务器代码中的进程process换成thread线程的时候。多个客户机的进程Id还不同,这就奇怪了,线程不应该都在一个进程Id里吗

pyqt5 使用多线程进行socket通信,界面未响应后程序退出

本来准备开好几个线程通信,写了两个正常运行,加了第三个后界面未响应,pycharm报错Process finished with exit code -1073740791 (0xC0000409) 现在一个线程也这样,不知是哪里出了问题。 这是UI类函数 class TabDemo(QTabWidget,QMainWindow): def __init__(self,parent=None): super(TabDemo,self).__init__(parent) self.resize(1200,900) self.tab1 = QWidget() self.tab2 = QWidget() self.tab3 = QWidget() self.tab4 = QWidget() self.tab5 = QWidget() self.addTab(self.tab1,'Voltage Curent') self.addTab(self.tab2,'Parameters') self.addTab(self.tab3,'Waveforms') self.addTab(self.tab4,'Charts') self.addTab(self.tab5,'Save Load') self.tab1UI() self.tab2UI() self.tab3UI() self.tab4UI() self.tab5UI() # self.Tcptrans = TcpThread() # self.Tcptrans1 = TcpThread1() # self.Tcptrans2 = TcpThread2() self.Tcptrans3 = TcpThread3() # self.Tcptrans.start() # self.Tcptrans1.start() # self.Tcptrans2.start() self.Tcptrans3.start() # self.Tcptrans.sinOut.connect(self.display) # self.Tcptrans1.sinOut1.connect(self.display1) # self.Tcptrans2.sinOut2.connect(self.display2) self.Tcptrans3.sinOut3.connect(self.display3) self.setWindowTitle('电能质量监测系统') 这是tab2UI def tab2UI(self): grid = QGridLayout() grid.setSpacing(10) l1=QLabel('Parameters') l2=QLabel('24V Supply') l3=QLabel('Volts') l4=QLabel('DSP Temp') l5=QLabel('Dg.c') self.t1=QTextBrowser() self.t2=QTextBrowser() self.table=QTableWidget(9,20) self.g1=QGraphicsView() self.table.setVerticalHeaderLabels(['ReactivePowerA', 'ReactivePowerC', 'ActivePowerA', 'ActivePowerC','CurrentA','CurrentC','THD IA', 'THD IC','Meter ID']) ''' self.l1.setGeometry(QtCore.QRect(190, 10, 101, 16)) self.l2.setGeometry(QtCore.QRect(50, 30, 91, 16)) self.l3.setGeometry(QtCore.QRect(170, 60, 72, 15)) self.l4.setGeometry(QtCore.QRect(50, 130, 72, 15)) self.l5.setGeometry(QtCore.QRect(170, 170, 72, 15)) self.t1.setGeometry(QtCore.QRect(30, 50, 111, 31)) self.t2.setGeometry(QtCore.QRect(30, 160, 111, 31)) self.table.setGeometry(QtCore.QRect(100, 20, 871, 291)) ''' grid.addWidget(l1,1,3) grid.addWidget(self.g1,2,0,5,16) grid.addWidget(l2,2,17) grid.addWidget(self.t1,3,17) grid.addWidget(l3,3,18) grid.addWidget(l4,4,17) grid.addWidget(self.t2,5,17) grid.addWidget(l5,5,18) grid.addWidget(self.table,6,0,20,21) self.tab2.setLayout(grid) 这是槽函数 def display3(self,Meterreading): for i in range(9): for j in range(20): self.Item=QTableWidgetItem('%s' % Meterreading[i,j]) self.table.setItem(i,j,self.Item) 这是定义的子线程类class TcpThread3(QThread): sinOut3 = pyqtSignal(np.ndarray) def __init__(self, parent=None): super(TcpThread3, self).__init__(parent) self.working = True def __del__(self): # 线程状态改变与线程终止 self.working = False self.wait() def run(self): if self.working == True: self.tcp_client_socket2 = socket(AF_INET, SOCK_STREAM) self.tcp_client_socket2.connect(("127.0.0.1", 6666)) while self.working == True: self.meg3 = b'\x01\x09\x00\x00\x01\x68\xDD\xB5' self.tcp_client_socket3.send(self.meg3) self.recv_data3 = self.tcp_client_socket3.recv(1024) l3 = list() l4 = list() CT = 1 PT = 1 for i in range(3, 723, 2): temp = self.recv_data3[i:i + 2] result = struct.unpack('!h', temp)[0] l3.append(result) list4 = l3[0:320] a = np.array(list4).reshape(20, 16) for i in range(10): l4.append(a[..., i]) ReactivePowerA = l4[0] * 0.0001 * CT * PT ReactivePowerC = l4[1] * 0.0001 * CT * PT ActivePowerA = l4[2] * 0.0001 * CT * PT ActivePowerC = l4[3] * 0.0001 * CT * PT CurrentA = l4[4] * 0.01 * CT CurrentC = l4[5] * 0.01 * CT THDIA = l4[6] * 0.1 THDIC = l4[7] * 0.1 lastone = (a[..., 8] * 65536 + a[..., 9]) * 0.01 Meterreading = np.vstack((ReactivePowerA, ReactivePowerC, ActivePowerA, ActivePowerC, CurrentA, CurrentC, THDIA, THDIC, lastone)) self.sinOut3.emit(Meterreading) QApplication.processEvents() self.sleep(1)

ssl.wrap_socket实现

<div class="post-text" itemprop="text"> <p>In python you can wrap a standard socket with ssl. Detailed doc can be found here, <a href="https://docs.python.org/2/library/ssl.html" rel="nofollow noreferrer">https://docs.python.org/2/library/ssl.html</a></p> <p>I want something similar in go. Here is my attempt.</p> <pre><code>func GetSSLWrappedConnection() (SSLWrappedConnection net.Conn, err error){ fmt.Println("Initialiazing proxy connection") rawConn, er_ := net.Dial("tcp", "127.0.0.1:8080") if er_ != nil { return nil, fmt.Errorf("Can't establish connection with remote server!") } else { // now we need to wrap the connection (SSL Wrap) var TLSconfig *tls.Config TLSconfig = &amp;tls.Config{ InsecureSkipVerify: true} ssl_wrapped_connection := tls.Client(rawConn, TLSconfig) err = ssl_wrapped_connection.Handshake() if err != nil { fmt.Println(err) rawConn.Close() return nil, err } return ssl_wrapped_connection, nil } </code></pre> <p>}</p> <p>Is this the correct implementation?</p> </div>

求助,python的数据库和多线程方面的问题

错误:ProgrammingError: Recursive use of cursors not allowed 代码大概结构如下: def socket_data(): cur=conn.cursor() while True: try: thread.start_new_thread(AcceptProc,(c,addr,cur)) print 'AcceptProc started' time.sleep(g_Timeparallel) except socket.timeout: iStream=updateallstream(cur,False) if int(iStream)!=int(g_stream): g_stream=iStream updatestatus(cur,1,False,g_stream) 这个代码不是完整的,只是部分的结构,多个函数里都有用到游标,不知道怎么解决,求帮忙

ZMQ套接字如何处理缺乏线程安全性的问题?

<div class="post-text" itemprop="text"> <p>I've been using ZMQ in some Python applications for a while, but only very recently I decided to reimplement one of them in Go and I realized that ZMQ sockets are not thread-safe.</p> <p>The original Python implementation uses an event loop that looks like this:</p> <pre class="lang-py prettyprint-override"><code>while running: socks = dict(poller.poll(TIMEOUT)) if socks.get(router) == zmq.POLLIN: client_id = router.recv() _ = router.recv() data = router.recv() requests.append((client_id, data)) for req in requests: rep = handle_request(req) if rep: replies.append(rep) requests.remove(req) for client_id, data in replies: router.send(client_id, zmq.SNDMORE) router.send(b'', zmq.SNDMORE) router.send(data) del replies[:] </code></pre> <p>The problem is that the reply might not be ready on the first pass, so whenever I have pending requests, I have to poll with a very short timeout or the clients will wait for more than they should, and the application ends up using a lot of CPU for polling.</p> <p>When I decided to reimplement it in Go, I thought it would be as simple as this, avoiding the problem by using infinite timeout on polling:</p> <pre class="lang-go prettyprint-override"><code>for { sockets, _ := poller.Poll(-1) for _, socket := range sockets { switch s := socket.Socket; s { case router: msg, _ := s.RecvMessage(0) client_id := msg[0] data := msg[2] go handleRequest(router, client_id, data) } } } </code></pre> <p>But that ideal implementation only works when I have a single client connected, or a light load. Under heavy load I get random assertion errors inside libzmq. I tried the following:</p> <ol> <li><p>Following the <a href="https://godoc.org/github.com/pebbe/zmq4#Context.NewSocket" rel="nofollow">zmq4 docs</a> I tried adding a sync.Mutex and lock/unlock on all socket operations. It fails. I assume it's because ZMQ uses its own threads for flushing.</p></li> <li><p>Creating one goroutine for polling/receiving and one for sending, and use channels in the same way I used the req/rep queues in the Python version. It fails, as I'm still sharing the socket.</p></li> <li><p>Same as 2, but setting <code>GOMAXPROCS=1</code>. It fails, and throughput was very limited because replies were being held back until the <code>Poll()</code> call returned.</p></li> <li><p>Use the req/rep channels as in 2, but use <code>runtime.LockOSThread</code> to keep all socket operations in the same thread as the socket. Has the same problem as above. It doesn't fail, but throughput was very limited.</p></li> <li><p>Same as 4, but using the poll timeout strategy from the Python version. It works, but has the same problem the Python version does. </p></li> <li><p>Share the context instead of the socket and create one socket for sending and one for receiving in separate goroutines, communicating with channels. It works, but I'll have to rewrite the client libs to use two sockets instead of one.</p></li> <li><p>Get rid of zmq and use raw TCP sockets, which are thread-safe. It works perfectly, but I'll also have to rewrite the client libs. </p></li> </ol> <p>So, it looks like 6 is how ZMQ was really intended to be used, as that's the only way I got it to work seamlessly with goroutines, but I wonder if there's any other way I haven't tried. Any ideas?</p> <hr> <p><strong>Update</strong></p> <p>With the answers here I realized I can just add an <code>inproc</code> PULL socket to the poller and have a goroutine connect and push a byte to break out of the infinite wait. It's not as versatile as the solutions suggested here, but it works and I can even backport it to the Python version.</p> </div>

用C++怎么改写这段socket多线程服务器端代码?

不太会用C++,这个程序前端是python写的,后端是C++,需要用socket通讯。client端我已经用python写好了,不知道server端怎么用C++实现。 代码如下: ```python from socket import * from threading import Thread IP = '127.0.0.1' PORT = 8888 BUFLEN = 512 def clientHandler(dataSocket, addr): while True: recved = dataSocket.recv(BUFLEN) # 当对方关闭连接的时候,返回空字符串 if not recved: print(f'客户端{addr} 关闭了连接') break # 读取的字节数据是bytes类型,需要解码为字符串 check = recved.decode() if check == '111111111111': linkItems = '01478' elif check == '211111111111': linkItems = '01258' else: linkItems = 'FFFFFF' info = list(check) print(info) # print(f'收到{addr}信息: {info}') # dataSocket.send(f'{linkItems}'.encode()) dataSocket.send(linkItems.encode()) dataSocket.close() listenSocket = socket(AF_INET, SOCK_STREAM) listenSocket.bind((IP, PORT)) listenSocket.listen(8) print(f'服务端启动成功,在{PORT}端口等待客户端连接...') while True: dataSocket, addr = listenSocket.accept() # Establish connection with client. addr = str(addr) print(f'一个客户端 {addr} 连接成功') # 创建新线程处理和这个客户端的消息收发 th = Thread(target=clientHandler, args=(dataSocket, addr)) th.start() listenSocket.close() ```

Python 在tkinter.mainloop中开线程,为什么又出现一个新窗口?

def make_app(): app=Tk() Listbox(name='listb').pack() Button(text="run",command=run_script).pack() Button(text="stop",command=stop_script).pack() return app def run_script(): p=multiprocessing.Process(name="print", target=run_func) p.start() def ui_make_list(): listb=app.children["listb"] for f in os.listdir(): listb.insert(END,f) def stop_script(): for p in multiprocessing.active_children(): if p.name == "print": p.terminate() def run_func(): list = app.children["listb"] path = list.get(ACTIVE) print(path) run_path(path) app = make_app() app.after(100, ui_make_list) app.mainloop() 运行时会先出现一个窗口,点击run按钮开启新线程后,又出现一个窗口。关掉第二个窗口后报错: KeyError: 'listb'

socket tcp通信客户端句柄设为全局变量

将初始化和发送分别放在两个函数中,句柄设为全局变量,发送结果显示错误:socket on non-socket,求教应该怎么改

socket中while(true)的使用

本人初学java编程,在书中看到这个语句,这个是服务端接受语句的代码 ``` package dddd; import java.io.BufferedReader; import java.io.IOException; import java.io.InputStreamReader; import java.net.ServerSocket; import java.net.Socket; public class MyTcp { private BufferedReader reader; private ServerSocket server1; private ServerSocket server2; private Socket socket1; private Socket socket2; void getserver1(){ try{ server1=new ServerSocket(7993); System.out.println("服务器套接字已经创建成功"); while(true){ System.out.println("等待客户机链接"); socket1=server1.accept(); reader=new BufferedReader(new InputStreamReader(socket1.getInputStream())); getClientMessage(socket1); } }catch(Exception e){ e.printStackTrace(); } } private void getClientMessage(Socket socket){ try{ while(true){ System.out.println("来自客户机的信息:"+reader.readLine()); } }catch(Exception e){ e.printStackTrace(); } try{ if(reader!=null){ reader.close(); System.out.println("readerclose"); } if(socket!=null){ socket.close(); System.out.println("socketclose"); } }catch(IOException e){ e.printStackTrace(); } } public static void main(String[] args){ MyTcp tcp=new MyTcp(); tcp.getserver1(); } } ``` 这里面有两个while(true)都不太明白什么意思。按照我的理解在第二个语句 ``` while(true){ System.out.println("来自客户机的信息:"+reader.readLine()); } ``` 里面,system应该不断输出这个消息啊,但是结果system只是输出了一段消息 ![图片说明](https://img-ask.csdn.net/upload/201509/24/1443070801_437920.jpg) 我从客户端输入一次服务端便响应一次,程序没问题,就是想知道为何while(true)没有出现死循环。

python模拟udp包的发送,怎样使客户端发送多个udp包到服务器

python模拟udp包的发送,怎样使客户端发送多个udp包到服务器,客户端不同的ip地址或者不同的端口发送都行

这是一个关于PYQT5多线程通信的绑定mywindow类成员函数问题

``` import sys,time import threading from PyQt5 import QtWidgets,QtCore,QtGui import zuoye2 import socket class Mywindow(QtWidgets.QMainWindow, zuoye2.Ui_MainWindow): def __init__(self): super(Mywindow,self).__init__() self.setupUi(self) #继承于Ui_MainWindow self.pushButton.clicked.connect(self.zuoxian) self.pushButton_2.clicked.connect(self.youxian) def zuoxian(self): a=threading.Thread(target='zuo') a.start() def zuo(self): for i in range(1,10,1): time.sleep(1) self.textEdit.append(str(i)) def you(self): for i in range(1, 10, 1): self.textEdit_2.append(str(i)) def youxian(self): a=threading.Thread(target='you') a.start() ``` 我写的pyqt代码 ,想让zuoxian开线程,绑定函数zuo,但是报错,如图所示: ![图片说明](https://img-ask.csdn.net/upload/201912/01/1575210661_223448.png) 我觉得是target=后面加了引号的问题,把引号去掉后,target=后面的那个参数又出现了下滑红曲线,好难过,求大佬们解答

python3爬取的内容可以print但是写入本地文件失败,但测试发现写入语句没有问题

# python3 # 源码如下 ``` python import os # 调用系统变量 import re # 正则表达式相关 import urllib import urllib.request import urllib.error import urllib.parse import json import socket import time class ImoocSpider: headers={'User-Agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/68.0.3440.106 Safari/537.36'} def getPythonInfo(self,keyWord): myKeyWord = urllib.parse.quote(keyWord) searchUrl='https://www.imooc.com/search/?words='+myKeyWord try: request = urllib.request.Request(url=searchUrl, headers=self.headers) page = urllib.request.urlopen(request) rsp = page.read().decode('unicode_escape') except UnicodeDecodeError as e: print(e) print('-----UnicodeDecodeErrorurl:', searchUrl) except urllib.error.URLError as e: print(e) print("-----urlErrorurl:", searchUrl) except socket.timeout as e: print(e) print("-----socket timout:", searchUrl) else: myres=rsp self.saveFile(myres,keyWord) finally: page.close() print("get_finally") def saveFile(self,res,keyWord): b="./" + keyWord +'.txt' if not os.path.exists(b): # 判断路径指定下是否存在文件/文件夹 try : fp=open(b,'w') print(res,file=fp) #print到文件 except : # print (e) print('文件写入有误') finally : fp.close() print('save_finally') def start (self, keyWord): self.getPythonInfo(keyWord) if __name__ == '__main__': imoocInfo = ImoocSpider() imoocInfo.start('python') ```

这是个PYHTON线程和进程的问题

PYHTON的多进程和多线程到底有什么区别呢? 我做socket程序,一个服务器,两个客户机,进行通信测试,感觉二者都是一样的。。。 两个客户机和服务器分别设置显示进程Ip,发现规律也差不多。。 求大佬帮我解答

这是一个关于PYTHON通信的相关问题

使用socket进行多线程通信,不会用信号, 使用socket+pyqt窗体进行多线程通信,要用信号,这是为什么呢? 感觉不到pyqt中信号的意义。求解

初级玩转Linux+Ubuntu(嵌入式开发基础课程)

课程主要面向嵌入式Linux初学者、工程师、学生 主要从一下几方面进行讲解: 1.linux学习路线、基本命令、高级命令 2.shell、vi及vim入门讲解 3.软件安装下载、NFS、Samba、FTP等服务器配置及使用

我以为我对Mysql事务很熟,直到我遇到了阿里面试官

太惨了,面试又被吊打

Python代码实现飞机大战

文章目录经典飞机大战一.游戏设定二.我方飞机三.敌方飞机四.发射子弹五.发放补给包六.主模块 经典飞机大战 源代码以及素材资料(图片,音频)可从下面的github中下载: 飞机大战源代码以及素材资料github项目地址链接 ————————————————————————————————————————————————————————— 不知道大家有没有打过飞机,喜不喜欢打飞机。当我第一次接触这个东西的时候,我的内心是被震撼到的。第一次接触打飞机的时候作者本人是身心愉悦的,因为周边的朋友都在打飞机, 每

Python数据分析与挖掘

92讲视频课+16大项目实战+源码+¥800元课程礼包+讲师社群1V1答疑+社群闭门分享会=99元 &nbsp; 为什么学习数据分析? &nbsp; &nbsp; &nbsp; 人工智能、大数据时代有什么技能是可以运用在各种行业的?数据分析就是。 &nbsp; &nbsp; &nbsp; 从海量数据中获得别人看不见的信息,创业者可以通过数据分析来优化产品,营销人员可以通过数据分析改进营销策略,产品经理可以通过数据分析洞察用户习惯,金融从业者可以通过数据分析规避投资风险,程序员可以通过数据分析进一步挖掘出数据价值,它和编程一样,本质上也是一个工具,通过数据来对现实事物进行分析和识别的能力。不管你从事什么行业,掌握了数据分析能力,往往在其岗位上更有竞争力。 &nbsp;&nbsp; 本课程共包含五大模块: 一、先导篇: 通过分析数据分析师的一天,让学员了解全面了解成为一个数据分析师的所有必修功法,对数据分析师不在迷惑。 &nbsp; 二、基础篇: 围绕Python基础语法介绍、数据预处理、数据可视化以及数据分析与挖掘......这些核心技能模块展开,帮助你快速而全面的掌握和了解成为一个数据分析师的所有必修功法。 &nbsp; 三、数据采集篇: 通过网络爬虫实战解决数据分析的必经之路:数据从何来的问题,讲解常见的爬虫套路并利用三大实战帮助学员扎实数据采集能力,避免没有数据可分析的尴尬。 &nbsp; 四、分析工具篇: 讲解数据分析避不开的科学计算库Numpy、数据分析工具Pandas及常见可视化工具Matplotlib。 &nbsp; 五、算法篇: 算法是数据分析的精华,课程精选10大算法,包括分类、聚类、预测3大类型,每个算法都从原理和案例两个角度学习,让你不仅能用起来,了解原理,还能知道为什么这么做。

如何在虚拟机VM上使用串口

在系统内核开发中,经常会用到串口调试,利用VMware的Virtual Machine更是为调试系统内核如虎添翼。那么怎么搭建串口调试环境呢?因为最近工作涉及到这方面,利用强大的google搜索和自己

程序员的兼职技能课

获取讲师答疑方式: 在付费视频第一节(触摸命令_ALL)片头有二维码及加群流程介绍 限时福利 原价99元,今日仅需39元!购课添加小助手(微信号:csdn590)按提示还可领取价值800元的编程大礼包! 讲师介绍: 苏奕嘉&nbsp;前阿里UC项目工程师 脚本开发平台官方认证满级(六级)开发者。 我将如何教会你通过【定制脚本】赚到你人生的第一桶金? 零基础程序定制脚本开发课程,是完全针对零脚本开发经验的小白而设计,课程内容共分为3大阶段: ①前期将带你掌握Q开发语言和界面交互开发能力; ②中期通过实战来制作有具体需求的定制脚本; ③后期将解锁脚本的更高阶玩法,打通任督二脉; ④应用定制脚本合法赚取额外收入的完整经验分享,带你通过程序定制脚本开发这项副业,赚取到你的第一桶金!

MFC一站式终极全套课程包

该套餐共包含从C小白到C++到MFC的全部课程,整套学下来绝对成为一名C++大牛!!!

C++语言基础视频教程

C++语言基础视频培训课程:本课与主讲者在大学开出的程序设计课程直接对接,准确把握知识点,注重教学视频与实践体系的结合,帮助初学者有效学习。本教程详细介绍C++语言中的封装、数据隐藏、继承、多态的实现等入门知识;主要包括类的声明、对象定义、构造函数和析构函数、运算符重载、继承和派生、多态性实现等。 课程需要有C语言程序设计的基础(可以利用本人开出的《C语言与程序设计》系列课学习)。学习者能够通过实践的方式,学会利用C++语言解决问题,具备进一步学习利用C++开发应用程序的基础。

北京师范大学信息科学与技术学院笔试10复试真题

北京师范大学信息科学与技术学院笔试,可以更好的让你了解北师大该学院的复试内容,获得更好的成绩。

深度学习原理+项目实战+算法详解+主流框架(套餐)

深度学习系列课程从深度学习基础知识点开始讲解一步步进入神经网络的世界再到卷积和递归神经网络,详解各大经典网络架构。实战部分选择当下最火爆深度学习框架PyTorch与Tensorflow/Keras,全程实战演示框架核心使用与建模方法。项目实战部分选择计算机视觉与自然语言处理领域经典项目,从零开始详解算法原理,debug模式逐行代码解读。适合准备就业和转行的同学们加入学习! 建议按照下列课程顺序来进行学习 (1)掌握深度学习必备经典网络架构 (2)深度框架实战方法 (3)计算机视觉与自然语言处理项目实战。(按照课程排列顺序即可)

网络工程师小白入门--【思科CCNA、华为HCNA等网络工程师认证】

本课程适合CCNA或HCNA网络小白同志,高手请绕道,可以直接学习进价课程。通过本预科课程的学习,为学习网络工程师、思科CCNA、华为HCNA这些认证打下坚实的基础! 重要!思科认证2020年2月24日起,已启用新版认证和考试,包括题库都会更新,由于疫情原因,请关注官网和本地考点信息。题库网络上很容易下载到。

Python界面版学生管理系统

前不久上传了一个控制台版本的学生管理系统,这个是Python界面版学生管理系统,这个是使用pycharm开发的一个有界面的学生管理系统,基本的增删改查,里面又演示视频和完整代码,有需要的伙伴可以自行下

软件测试2小时入门

本课程内容系统、全面、简洁、通俗易懂,通过2个多小时的介绍,让大家对软件测试有个系统的理解和认识,具备基本的软件测试理论基础。 主要内容分为5个部分: 1 软件测试概述,了解测试是什么、测试的对象、原则、流程、方法、模型;&nbsp; 2.常用的黑盒测试用例设计方法及示例演示;&nbsp; 3 常用白盒测试用例设计方法及示例演示;&nbsp; 4.自动化测试优缺点、使用范围及示例‘;&nbsp; 5.测试经验谈。

Tomcat服务器下载、安装、配置环境变量教程(超详细)

未经我的允许,请不要转载我的文章,在此郑重声明!!! 请先配置安装好Java的环境,若没有安装,请参照我博客上的步骤进行安装! 安装Java环境教程https://blog.csdn.net/qq_40881680/article/details/83585542 Tomcat部署Web项目(一)·内嵌https://blog.csdn.net/qq_40881680/article/d...

2019数学建模A题高压油管的压力控制 省一论文即代码

2019数学建模A题高压油管的压力控制省一完整论文即详细C++和Matlab代码,希望对同学们有所帮助

图书管理系统(Java + Mysql)我的第一个完全自己做的实训项目

图书管理系统 Java + MySQL 完整实训代码,MVC三层架构组织,包含所有用到的图片资源以及数据库文件,大三上学期实训,注释很详细,按照阿里巴巴Java编程规范编写

linux下利用/proc进行进程树的打印

在linux下利用c语言实现的进程树的打印,主要通过/proc下的目录中的进程文件,获取status中的进程信息内容,然后利用递归实现进程树的打印

微信小程序开发实战之番茄时钟开发

微信小程序番茄时钟视频教程,本课程将带着各位学员开发一个小程序初级实战类项目,针对只看过官方文档而又无从下手的开发者来说,可以作为一个较好的练手项目,对于有小程序开发经验的开发者而言,可以更好加深对小程序各类组件和API 的理解,为更深层次高难度的项目做铺垫。

[已解决]踩过的坑之mysql连接报“Communications link failure”错误

目录 前言 第一种方法: 第二种方法 第三种方法(适用于项目和数据库在同一台服务器) 第四种方法 第五种方法(项目和数据库不在同一台服务器) 总结 前言 先给大家简述一下我的坑吧,(我用的是mysql,至于oracle有没有这样的问题,有心的小伙伴们可以测试一下哈), 在自己做个javaweb测试项目的时候,因为买的是云服务器,所以数据库连接的是用ip地址,用IDE开发好...

人工智能-计算机视觉实战之路(必备算法+深度学习+项目实战)

系列课程主要分为3大阶段:(1)首先掌握计算机视觉必备算法原理,结合Opencv进行学习与练手,通过实际视项目进行案例应用展示。(2)进军当下最火的深度学习进行视觉任务实战,掌握深度学习中必备算法原理与网络模型架构。(3)结合经典深度学习框架与实战项目进行实战,基于真实数据集展开业务分析与建模实战。整体风格通俗易懂,项目驱动学习与就业面试。 建议同学们按照下列顺序来进行学习:1.Python入门视频课程 2.Opencv计算机视觉实战(Python版) 3.深度学习框架-PyTorch实战/人工智能框架实战精讲:Keras项目 4.Python-深度学习-物体检测实战 5.后续实战课程按照自己喜好选择就可以

2019 AI开发者大会

2019 AI开发者大会(AI ProCon 2019)是由中国IT社区CSDN主办的AI技术与产业年度盛会。多年经验淬炼,如今蓄势待发:2019年9月6-7日,大会将有近百位中美顶尖AI专家、知名企业代表以及千余名AI开发者齐聚北京,进行技术解读和产业论证。我们不空谈口号,只谈技术,诚挚邀请AI业内人士一起共铸人工智能新篇章!

机器学习初学者必会的案例精讲

通过六个实际的编码项目,带领同学入门人工智能。这些项目涉及机器学习(回归,分类,聚类),深度学习(神经网络),底层数学算法,Weka数据挖掘,利用Git开源项目实战等。

Python数据分析师-实战系列

系列课程主要包括Python数据分析必备工具包,数据分析案例实战,核心算法实战与企业级数据分析与建模解决方案实战,建议大家按照系列课程阶段顺序进行学习。所有数据集均为企业收集的真实数据集,整体风格以实战为导向,通俗讲解Python数据分析核心技巧与实战解决方案。

YOLOv3目标检测实战系列课程

《YOLOv3目标检测实战系列课程》旨在帮助大家掌握YOLOv3目标检测的训练、原理、源码与网络模型改进方法。 本课程的YOLOv3使用原作darknet(c语言编写),在Ubuntu系统上做项目演示。 本系列课程包括三门课: (1)《YOLOv3目标检测实战:训练自己的数据集》 包括:安装darknet、给自己的数据集打标签、整理自己的数据集、修改配置文件、训练自己的数据集、测试训练出的网络模型、性能统计(mAP计算和画出PR曲线)和先验框聚类。 (2)《YOLOv3目标检测:原理与源码解析》讲解YOLOv1、YOLOv2、YOLOv3的原理、程序流程并解析各层的源码。 (3)《YOLOv3目标检测:网络模型改进方法》讲解YOLOv3的改进方法,包括改进1:不显示指定类别目标的方法 (增加功能) ;改进2:合并BN层到卷积层 (加快推理速度) ; 改进3:使用GIoU指标和损失函数 (提高检测精度) ;改进4:tiny YOLOv3 (简化网络模型)并介绍 AlexeyAB/darknet项目。

2021考研数学张宇基础30讲.pdf

张宇:博士,全国著名考研数学辅导专家,教育部“国家精品课程建设骨干教师”,全国畅销书《张宇高等数学18讲》《张宇线性代数9讲》《张宇概率论与数理统计9讲》《张宇考研数学题源探析经典1000题》《张宇考

三个项目玩转深度学习(附1G源码)

从事大数据与人工智能开发与实践约十年,钱老师亲自见证了大数据行业的发展与人工智能的从冷到热。事实证明,计算机技术的发展,算力突破,海量数据,机器人技术等,开启了第四次工业革命的序章。深度学习图像分类一直是人工智能的经典任务,是智慧零售、安防、无人驾驶等机器视觉应用领域的核心技术之一,掌握图像分类技术是机器视觉学习的重中之重。针对现有线上学习的特点与实际需求,我们开发了人工智能案例实战系列课程。打造:以项目案例实践为驱动的课程学习方式,覆盖了智能零售,智慧交通等常见领域,通过基础学习、项目案例实践、社群答疑,三维立体的方式,打造最好的学习效果。

DirectX修复工具V4.0增强版

DirectX修复工具(DirectX Repair)是一款系统级工具软件,简便易用。本程序为绿色版,无需安装,可直接运行。 本程序的主要功能是检测当前系统的DirectX状态,如果发现异常则进行修复

期末考试评分标准的数学模型

大学期末考试与高中的考试存在很大的不同之处,大学的期末考试成绩是主要分为两个部分:平时成绩和期末考试成绩。平时成绩和期末考试成绩总分一般为一百分,然而平时成绩与期末考试成绩所占的比例不同会导致出现不同

Vue.js 2.0之全家桶系列视频课程

基于新的Vue.js 2.3版本, 目前新全的Vue.js教学视频,让你少走弯路,直达技术前沿! 1. 包含Vue.js全家桶(vue.js、vue-router、axios、vuex、vue-cli、webpack、ElementUI等) 2. 采用笔记+代码案例的形式讲解,通俗易懂

c语言项目开发实例

十个c语言案例 (1)贪吃蛇 (2)五子棋游戏 (3)电话薄管理系统 (4)计算器 (5)万年历 (6)电子表 (7)客户端和服务器通信 (8)潜艇大战游戏 (9)鼠标器程序 (10)手机通讯录系统

相关热词 c#框体中的退出函数 c# 按钮透明背景 c# idl 混编出错 c#在位置0处没有任何行 c# 循环给数组插入数据 c# 多线程死锁的例子 c# 钉钉读取员工排班 c# label 不显示 c#裁剪影像 c#工作进程更新ui
立即提问