玩蛇网提供最新Python编程技术信息以及Python资源下载!

PHP与Python间Socket通信代码片段

python 培训

PHP与Python间Socket通信代码片段,这不是完整的代码,而且代码还需要更多的改进。

服务器端Python代码

#coding:utf-8
'''
Socket 服务器端
    常见的协议及端口(这些端口是由操作系统管理的)
    ftp-Data:20,
    ftp-Control:21
    SSH:22,
    Telnet:23
    SMTP:25,
    HTTP:80
    POP3:110
    IMAP:143
    HTTPS:443
'''
import socket,threading
import time,Queue

'''
    任务线程
'''
class TaskThread(threading.Thread):

    '''
        初始化
    '''
    def __init__(self,queue):
        threading.Thread.__init__(self)
        self.queue = queue
    '''
     执行线程
    '''
    def run(self):
        task = self.queue.get() #取出一项任务
        self.doTask(task)
        self.queue.task_done() #完成任务信号
    '''
        做任务
    '''
    def doTask(self,task):
        path = './task/'+task+'.txt'
        fp = open(path,'w')
        fp.write(task)
        fp.close()

'''
www.iplaypython.com
'''
def main():

    #Socket
    s = socket.socket(socket.AF_INET,socket.SOCK_STREAM) #创建tcp socket
    s.bind(('localhost',9999))#绑定到9999
    s.listen(5) #监听,但只能挂起5以下链接

    #创建队列
    queue = Queue.Queue()
    
    while True:
        client,addr = s.accept()#连接
        addr = str(addr)
        print("从 %s 获取一个连接"%addr) #直接输出到控制台
        timestr = time.ctime(time.time())+"\r\n" #时间羽化输出
        strs = '现在是:'+timestr
        client.send(strs) #发送输数据
        task = str(client.recv(1024))
        cs = '%s 客户端返回的数据为:%s'%(addr,task) #接收客户端数据
        print(cs)
        client.close()

        #任务
        task = task.split('|')
        #将任务写入到队列中
        for i in task:
            queue.put(i)

        #开始线程   
        for i in task:
            t = TaskThread(queue)
            t.setDaemon(True) #子线程随主线程一起退出
            t.start() #启动线程
            t.join(10) #保证每个线程运行,但只等10s

        queue.join() #等所有任务都处理后,再退出
            
if __name__ =='__main__':
    main()

客户端PHP代码

<?php
/**
 * Socket PHP客户端
 * 
 */
header ( 'Content-type:text/html;charset=utf8' );
$host = 'tcp://localhost:9999';
$fp = stream_socket_client ( $host, $errno, $error, 20 );
if (! $fp)
{
	
	echo "$error ($errno)";
} else
{
	fwrite ( $fp, 'one|two|three' );
	while ( ! feof ( $fp ) )
	{
		echo fgets ( $fp ); #获取服务器返回的内容
	}
	fclose ( $fp );
}

玩蛇网原创,转载请注明文章出处和来源网址:http://www.iplaypython.com/code/other/o2368.html



微信公众号搜索"玩蛇网Python之家"加关注,每日最新的Python资讯、图文视频教程可以让你一手全掌握。强烈推荐关注!

微信扫描下图可直接关注

玩蛇网Python新手QQ群,欢迎加入: ① 240764603 玩蛇网Python新手群
文章发布日期:2016-04-13 21:21 玩蛇网 www.iplaypython.com

评论列表(网友评论仅供网友表达个人看法,并不表明本站同意其观点或证实其描述)
相关文章推荐
别人正在看
特别推荐
去顶部去底部