在局域网中发布共享文件

下面是脚本之家 jb51.cc 通过网络收集整理的代码片段。

脚本之家小编现在分享给大家，也给大家做个参考。

#!/usr/bin/env python
#coding:utf8
# Author          : tuxpy
# Email           : [emailprotected]
# Last modified   : 2014-10-03 19:22:22
# Filename        : client.py
# Description     : 
from xmlrpclib import ServerProxy,Fault
from cmd import Cmd
from random import choice
from string import lowercase
from core.server import Node,UNHANDLED
from core.data import get_port,get_host
from threading import Thread
from time import sleep

import sys

HEAD_START = 0.1
SECRET_LENGTH = 100


def randomString(length):
    chars = []
    for i in range(length):
        chars.append(choice(lowercase))

    return ''.join(chars)

class Client(Cmd):
    prompt = '> '
    def __init__(self,url,dirname):
        Cmd.__init__(self)
        self.url = url
        self.port = get_port(url)  # 这个要当信息广播出去
        self.secret = randomString(SECRET_LENGTH)
        node = Node(url,dirname,self.secret)
        t_node = Thread(target = node._start)
        t_node.setDaemon(True)
        t_node.start()

        sleep(HEAD_START)
        self.server = ServerProxy(url)
        t_update_known = Thread(target = self.update_known)
        t_update_known.setDaemon(True)
        t_update_known.start()
        
    def do_fetch(self,arg):
        try:
            self.server.fetch(arg,self.secret)
        except Fault,f:
            if f.faultCode != UNHANDLED:raise
            print "Couldn't find the file",arg

    def do_ls(self,path):
        for url,files in self.server.ls().items():
            print '%snt%s' % (get_host(url),'nt'.join(files))
        
    def update_known(self):
        from core.sock import sock
        sock = sock()
        sock.broadcast(str(self.port))  # 把自己的xml-rpc端口广播给别人
        while True:
            url = sock.recv_url()
            self.server.hello(url,self.secret) # 当收到节点信息时，更新节点

    def do_exit(self,arg):
        print
        sys.exit()

    do_EOR = do_exit

def main():
    import os
    cwd = os.path.dirname(os.path.abspath(sys.argv[0]))
    os.chdir(cwd) #  切换成程序所在目录

    from core.config import config
    cfg = config()
    directory = cfg.get('global','share_dir') 
    if not os.path.isdir(directory):
        sys.stderr.write("%s not is existn" % directory)
        sys.exit(1)
        
    url = 'http://localhost:' + cfg.get('global','data_port')

    client = Client(url,directory) 
    client.cmdloop()

if __name__ == "__main__":
    main()

以上是脚本之家(jb51.cc)为你收集整理的全部代码内容，希望文章能够帮你解决所遇到的程序开发问题。

如果觉得脚本之家网站内容还不错，欢迎将脚本之家网站推荐给程序员好友。

（编辑：安卓应用网）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!