def load_httpserver(self, sockets=None, **kwargs):
if not sockets:
from tornado.netutil import bind_sockets
if settings.IPV4_ONLY:
import socket
sockets = bind_sockets(options.port, options.address, family=socket.AF_INET)
else:
sockets = bind_sockets(options.port, options.address)
http_server = tornado.httpserver.HTTPServer(self.application, **kwargs)
http_server.add_sockets(sockets)
self.httpserver = http_server
return self.httpserver
python类address()的实例源码
def main():
tornado.options.parse_command_line()
print('BGmi HTTP Server listening on %s:%d' % (options.address, options.port))
http_server = tornado.httpserver.HTTPServer(make_app())
http_server.listen(options.port, address=options.address)
tornado.ioloop.IOLoop.current().start()
def main():
options.parse_command_line()
if os.path.exists(options.configFile):
try:
options.parse_config_file(options.configFile)
options.parse_command_line()
except Exception, E:
print("Invalid config file {0}".format(options.configFile))
print(E)
sys.exit(1)
# Set Log level
log.setLevel(getLogLevel(options.logLevel))
if not options.cookieSecret:
log.error("cookieSecret option required")
sys.exit(1)
detectProxy()
mailer.setup(options.smtpServer, options.smtpPort, options.emailSender, options.smtpUseTLS)
log.info("Server starting on {0}:{1}...".format(options.address, options.port))
http_server = Application()
http_server.listen(options.port, options.address, xheaders=True)
io_loop = tornado.ioloop.IOLoop.instance()
if options.autoReload:
log.debug("Starting autoreloader")
tornado.autoreload.watch(CONFIG_FILE)
for f in os.listdir(http_server.settings["template_path"]):
fn = os.path.join(http_server.settings["template_path"], f)
if os.path.isfile(fn):
tornado.autoreload.watch(fn)
tornado.autoreload.start(io_loop)
log.info("Server started. Listening on {0}:{1}".format(options.address, options.port))
io_loop.start()
def main():
tornado.options.parse_command_line()
application = tornado.web.Application([
(r"/", MainHandler),
])
http_server = tornado.httpserver.HTTPServer(application)
http_server.listen(options.port, address=options.address)
tornado.ioloop.IOLoop.current().start()
def test_address(self):
with self.mock_option('address', '127.0.0.1'):
command = WsCeleryCommand()
command.apply_options('wscelery', argv=['--address=foobar'])
self.assertEqual(options.address, 'foobar')
def run(self):
while True:
app = Application()
app.listen(options.port, options.address)
IOLoop.instance().start()
def print_settings_info(self):
if settings.DEBUG:
print('tornado version: %s' % tornado.version)
print('locale support: %s' % settings.TRANSLATIONS)
print('load apps:')
for app in settings.INSTALLED_APPS:
print(' - %s' % str(app))
print('template engine: %s' % (settings.TEMPLATE_CONFIG.template_engine or 'default'))
print('server started. development server at http://%s:%s/' % (options.address, options.port))
def define(self, options=options):
"""
???????,?????????????????????????????
:return:
"""
try:
# ??timerotating????
options.define("log_rotate_when", type=str, default='midnight',
help=("specify the type of TimedRotatingFileHandler interval "
"other options:('S', 'M', 'H', 'D', 'W0'-'W6')"))
options.define("log_rotate_interval", type=int, default=1,
help="The interval value of timed rotating")
options.define("log_rotate_mode", type=str, default='size',
help="The mode of rotating files(time or size)")
except:
pass
options.define("port", default=8000, help="run server on it", type=int)
options.define("settings", default='', help="setting module name", type=str)
options.define("address", default='0.0.0.0', help='listen host,default:0.0.0.0', type=str)
options.define("log_patch", default=True,
help='Use ProcessTimedRotatingFileHandler instead of the default TimedRotatingFileHandler.',
type=bool)
options.define("log_port_prefix", default=None, help='add port to log file prefix.', type=bool)
options.define("logging_dir", default='', help='custom log dir.')
options.define("disable_log", default=True, help='disable tornado log function.')
def main():
options.parse_command_line()
if os.path.exists(options.configFile):
try:
options.parse_config_file(options.configFile)
options.parse_command_line()
except Exception, E:
print("Invalid config file {0}".format(options.configFile))
print(E)
sys.exit(1)
# Set Log level
log.setLevel(getLogLevel(options.logLevel))
detectProxy()
# Load the credentials from file
log.info("Loading credentials")
try:
credentialsFile = options.credentialsFile
Keys.loadFromFile(credentialsFile)
except Exception as E:
log.error("Error opening the credentials file: {0}".format(credentialsFile))
log.error(E)
sys.exit(1)
# TMP fix for 'ValueError: I/O operation on closed epoll fd'
# Fixed in Tornado 4.2
tornado.ioloop.IOLoop.instance()
# Sync time to CertiVox time server
if options.syncTime:
Time.getTime(wait=True)
Keys.getAPISettings(wait=True)
log.info("Server starting on {0}:{1}...".format(options.address, options.port))
http_server = Application()
http_server.listen(options.port, options.address, xheaders=True)
main_loop = tornado.ioloop.IOLoop.instance()
http_server.io_loop = main_loop
if options.autoReload:
log.debug("Starting autoreloader")
tornado.autoreload.watch(CONFIG_FILE)
tornado.autoreload.start(main_loop)
process_dynamic_options(
DYNAMIC_OPTION_MAPPING,
DYNAMIC_OPTION_HANDLERS,
application=http_server,
initial=True)
log.info("Server started. Listening on {0}:{1}".format(options.address, options.port))
main_loop.start()
def main():
options.parse_command_line()
if os.path.exists(options.configFile):
try:
options.parse_config_file(options.configFile)
options.parse_command_line()
except Exception, E:
print("Invalid config file {0}".format(options.configFile))
print(E)
sys.exit(1)
# Set Log level
log.setLevel(getLogLevel(options.logLevel))
detectProxy()
# Load the credentials from file
log.info("Loading credentials")
try:
credentialsFile = options.credentialsFile
Keys.loadFromFile(credentialsFile)
except Exception as E:
log.error("Error opening the credentials file: {0}".format(credentialsFile))
log.error(E)
sys.exit(1)
# TMP fix for 'ValueError: I/O operation on closed epoll fd'
# Fixed in Tornado 4.2
tornado.ioloop.IOLoop.instance()
# Sync time to CertiVox time server
if options.syncTime:
Time.getTime(wait=True)
if options.backup and options.encrypt_master_secret and not options.passphrase:
options.passphrase = getpass.getpass("Please enter passphrase:")
http_server = Application()
http_server.listen(options.port, options.address, xheaders=True)
io_loop = tornado.ioloop.IOLoop.instance()
if options.autoReload:
log.debug("Starting autoreloader")
tornado.autoreload.watch(CONFIG_FILE)
tornado.autoreload.start(io_loop)
if options.syncTime and (options.timePeriod > 0):
scheduler = tornado.ioloop.PeriodicCallback(Time.getTime, options.timePeriod, io_loop=io_loop)
scheduler.start()
log.info("Server started. Listening on {0}:{1}".format(options.address, options.port))
io_loop.start()
