本文整理汇总了Python中zmq.utils.strtypes.asbytes函数的典型用法代码示例。如果您正苦于以下问题:Python asbytes函数的具体用法?Python asbytes怎么用?Python asbytes使用的例子?那么恭喜您, 这里精选的函数代码示例或许可以为您提供帮助。
在下文中一共展示了asbytes函数的20个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Python代码示例。
示例1: test_router_router
def test_router_router(self):
"""test router-router MQ devices"""
if zmq.zmq_version() >= "4.0.0":
raise SkipTest("Only for libzmq < 4")
dev = devices.ThreadMonitoredQueue(zmq.ROUTER, zmq.ROUTER, zmq.PUB, "in", "out")
dev.setsockopt_in(zmq.LINGER, 0)
dev.setsockopt_out(zmq.LINGER, 0)
dev.setsockopt_mon(zmq.LINGER, 0)
binder = self.context.socket(zmq.DEALER)
porta = binder.bind_to_random_port("tcp://127.0.0.1")
portb = binder.bind_to_random_port("tcp://127.0.0.1")
binder.close()
time.sleep(0.1)
a = self.context.socket(zmq.DEALER)
a.identity = asbytes("a")
b = self.context.socket(zmq.DEALER)
b.identity = asbytes("b")
a.connect("tcp://127.0.0.1:%i" % porta)
dev.bind_in("tcp://127.0.0.1:%i" % porta)
b.connect("tcp://127.0.0.1:%i" % portb)
dev.bind_out("tcp://127.0.0.1:%i" % portb)
dev.start()
time.sleep(0.2)
msg = [asbytes(m) for m in ("hello", "there")]
a.send_multipart(["b"] + msg)
bmsg = self.recv_multipart(b)
self.assertEquals(bmsg, ["a"] + msg)
b.send_multipart(bmsg)
amsg = self.recv_multipart(a)
self.assertEquals(amsg, ["b"] + msg)
开发者ID:thurday,项目名称:pyzmq,代码行数:32,代码来源:test_monqueue.py
示例2: test_pubsub
def test_pubsub(self):
s1, s2 = self.create_bound_pair(zmq.PUB, zmq.SUB)
s2.setsockopt(zmq.SUBSCRIBE, asbytes(''))
# Sleep to allow sockets to connect.
wait()
poller = zmq.Poller()
poller.register(s1, zmq.POLLIN|zmq.POLLOUT)
poller.register(s2, zmq.POLLIN)
# Now make sure that both are send ready.
socks = dict(poller.poll())
self.assertEquals(socks[s1], zmq.POLLOUT)
self.assertEquals(s2 in socks, 0)
# Make sure that s1 stays in POLLOUT after a send.
s1.send(asbytes('msg1'))
socks = dict(poller.poll())
self.assertEquals(socks[s1], zmq.POLLOUT)
# Make sure that s2 is POLLIN after waiting.
wait()
socks = dict(poller.poll())
self.assertEquals(socks[s2], zmq.POLLIN)
# Make sure that s2 goes into 0 after recv.
s2.recv()
socks = dict(poller.poll())
self.assertEquals(s2 in socks, 0)
poller.unregister(s1)
poller.unregister(s2)
# Wait for everything to finish.
wait()
开发者ID:HVF,项目名称:pyzmq,代码行数:35,代码来源:test_poll.py
示例3: test_single_socket_forwarder_bind
def test_single_socket_forwarder_bind(self):
dev = devices.ThreadDevice(zmq.FORWARDER, zmq.REP, -1)
req = self.context.socket(zmq.REQ)
port = 12345
req.connect('tcp://127.0.0.1:%i'%port)
dev.bind_in('tcp://127.0.0.1:%i'%port)
dev.start()
time.sleep(.25)
msg = asbytes('hello')
req.send(msg)
self.assertEquals(msg, req.recv())
del dev
del req
dev = devices.ThreadDevice(zmq.FORWARDER, zmq.REP, -1)
req = self.context.socket(zmq.REQ)
port = 12346
req.connect('tcp://127.0.0.1:%i'%port)
dev.bind_in('tcp://127.0.0.1:%i'%port)
dev.start()
time.sleep(.25)
msg = asbytes('hello again')
req.send(msg)
self.assertEquals(msg, req.recv())
del dev
del req
开发者ID:kyledj,项目名称:pyzmq,代码行数:25,代码来源:test_device.py
示例4: test_init_iface
def test_init_iface(self):
logger = self.logger
ctx = self.context
handler = handlers.PUBHandler(self.iface)
self.assertFalse(handler.ctx is ctx)
self.sockets.append(handler.socket)
# handler.ctx.term()
handler = handlers.PUBHandler(self.iface, self.context)
self.sockets.append(handler.socket)
self.assertTrue(handler.ctx is ctx)
handler.setLevel(logging.DEBUG)
handler.root_topic = self.topic
logger.addHandler(handler)
sub = ctx.socket(zmq.SUB)
self.sockets.append(sub)
sub.setsockopt(zmq.SUBSCRIBE, self.topic)
sub.connect(self.iface)
import time; time.sleep(0.25)
msg1 = 'message'
logger.info(msg1)
(topic, msg2) = sub.recv_multipart()
self.assertEquals(topic, asbytes('zmq.INFO'))
self.assertEquals(msg2, asbytes(msg1+'\n'))
logger.removeHandler(handler)
开发者ID:HVF,项目名称:pyzmq,代码行数:25,代码来源:test_log.py
示例5: test_prefix
def test_prefix(self):
if zmq.zmq_version() < '3.0.0':
raise SkipTest("Only applies to libzmq >= 3.0")
xrep, xreq = self.create_bound_pair(zmq.XREP, zmq.XREQ)
msg = [ asbytes(p) for p in 'hi there'.split() ]
xreq.send_multipart(msg)
recvd = xrep.recv_multipart()
self.assertTrue(isinstance(recvd, tuple))
self.assertEquals(len(recvd), 2)
prefix, real = recvd
self.assertTrue(isinstance(prefix, list))
self.assertEquals(len(prefix), 1)
self.assertEquals(real, msg)
xrep.send_multipart(real, prefix=prefix)
echo = xreq.recv_multipart()
self.assertTrue(isinstance(echo, list))
self.assertEquals(echo, real)
extra = [asbytes('pre')]
xrep.send_multipart(msg, prefix=prefix+extra)
recvd = xreq.recv_multipart()
self.assertTrue(isinstance(recvd, tuple))
self.assertEquals(len(recvd), 2)
prefix, real = recvd
self.assertTrue(isinstance(prefix, list))
self.assertEquals(len(prefix), 1)
self.assertEquals(prefix, extra)
self.assertEquals(real, msg)
开发者ID:thurday,项目名称:pyzmq,代码行数:27,代码来源:test_socket.py
示例6: test_single_socket_forwarder_bind
def test_single_socket_forwarder_bind(self):
dev = devices.ThreadDevice(zmq.QUEUE, zmq.REP, -1)
# select random port:
binder = self.context.socket(zmq.REQ)
port = binder.bind_to_random_port('tcp://127.0.0.1')
binder.close()
time.sleep(0.1)
req = self.context.socket(zmq.REQ)
req.connect('tcp://127.0.0.1:%i'%port)
dev.bind_in('tcp://127.0.0.1:%i'%port)
dev.start()
time.sleep(.25)
msg = asbytes('hello')
req.send(msg)
self.assertEquals(msg, self.recv(req))
del dev
req.close()
dev = devices.ThreadDevice(zmq.QUEUE, zmq.REP, -1)
# select random port:
binder = self.context.socket(zmq.REQ)
port = binder.bind_to_random_port('tcp://127.0.0.1')
binder.close()
time.sleep(0.1)
req = self.context.socket(zmq.REQ)
req.connect('tcp://127.0.0.1:%i'%port)
dev.bind_in('tcp://127.0.0.1:%i'%port)
dev.start()
time.sleep(.25)
msg = asbytes('hello again')
req.send(msg)
self.assertEquals(msg, self.recv(req))
del dev
req.close()
开发者ID:P2PTeam,项目名称:salt-windows-install,代码行数:33,代码来源:test_device.py
示例7: build_device
def build_device(self, mon_sub=asbytes(""), in_prefix=asbytes('in'), out_prefix=asbytes('out')):
self.device = devices.ThreadMonitoredQueue(zmq.PAIR, zmq.PAIR, zmq.PUB,
in_prefix, out_prefix)
alice = self.context.socket(zmq.PAIR)
bob = self.context.socket(zmq.PAIR)
mon = self.context.socket(zmq.SUB)
aport = alice.bind_to_random_port('tcp://127.0.0.1')
bport = bob.bind_to_random_port('tcp://127.0.0.1')
mport = mon.bind_to_random_port('tcp://127.0.0.1')
mon.setsockopt(zmq.SUBSCRIBE, mon_sub)
self.device.connect_in("tcp://127.0.0.1:%i"%aport)
self.device.connect_out("tcp://127.0.0.1:%i"%bport)
self.device.connect_mon("tcp://127.0.0.1:%i"%mport)
self.device.start()
time.sleep(.2)
try:
# this is currenlty necessary to ensure no dropped monitor messages
# see LIBZMQ-248 for more info
mon.recv_multipart(zmq.NOBLOCK)
except zmq.ZMQError:
pass
self.sockets.extend([alice, bob, mon])
return alice, bob, mon
开发者ID:P2PTeam,项目名称:salt-windows-install,代码行数:25,代码来源:test_monqueue.py
示例8: test_lifecycle2
def test_lifecycle2(self):
"""Run through a different ref counting cycle with a copy."""
for i in range(5, 16): # 32, 64,..., 65536
s = (2**i)*x
rc = 2
self.assertEquals(grc(s), rc)
m = zmq.Frame(s)
rc += 2
self.assertEquals(grc(s), rc)
m2 = copy.copy(m)
rc += 1
self.assertEquals(grc(s), rc)
b = m.buffer
rc += view_rc
self.assertEquals(grc(s), rc)
self.assertEquals(s, asbytes(str(m)))
self.assertEquals(s, asbytes(m2))
self.assertEquals(s, m2.bytes)
self.assertEquals(s, m.bytes)
# self.assert_(s is str(m))
# self.assert_(s is str(m2))
del b
self.assertEquals(grc(s), rc)
del m
# m.buffer is kept until m is del'd
rc -= view_rc
rc -= 1
self.assertEquals(grc(s), rc)
del m2
rc -= 2
self.assertEquals(grc(s), rc)
self.assertEquals(rc, 2)
del s
开发者ID:aelse,项目名称:pyzmq,代码行数:33,代码来源:test_message.py
示例9: test_lifecycle1
def test_lifecycle1(self):
"""Run through a ref counting cycle with a copy."""
for i in range(5, 16): # 32, 64,..., 65536
s = (2**i)*x
rc = 2
self.assertEquals(grc(s), rc)
m = zmq.Message(s)
rc += 2
self.assertEquals(grc(s), rc)
m2 = copy.copy(m)
rc += 1
self.assertEquals(grc(s), rc)
b = m2.buffer
rc += view_rc
self.assertEquals(grc(s), rc)
self.assertEquals(s, asbytes(str(m)))
self.assertEquals(s, asbytes(m2))
self.assertEquals(s, m.bytes)
# self.assert_(s is str(m))
# self.assert_(s is str(m2))
del m2
rc -= 1
self.assertEquals(grc(s), rc)
rc -= view_rc
del b
self.assertEquals(grc(s), rc)
del m
rc -= 2
self.assertEquals(grc(s), rc)
self.assertEquals(rc, 2)
del s
开发者ID:proger,项目名称:pyzmq,代码行数:33,代码来源:test_message.py
示例10: test_pair
def test_pair(self):
s1, s2 = self.create_bound_pair(zmq.PAIR, zmq.PAIR)
# Sleep to allow sockets to connect.
wait()
poller = zmq.Poller()
poller.register(s1, zmq.POLLIN|zmq.POLLOUT)
poller.register(s2, zmq.POLLIN|zmq.POLLOUT)
# Poll result should contain both sockets
socks = dict(poller.poll())
# Now make sure that both are send ready.
self.assertEquals(socks[s1], zmq.POLLOUT)
self.assertEquals(socks[s2], zmq.POLLOUT)
# Now do a send on both, wait and test for zmq.POLLOUT|zmq.POLLIN
s1.send(asbytes('msg1'))
s2.send(asbytes('msg2'))
wait()
socks = dict(poller.poll())
self.assertEquals(socks[s1], zmq.POLLOUT|zmq.POLLIN)
self.assertEquals(socks[s2], zmq.POLLOUT|zmq.POLLIN)
# Make sure that both are in POLLOUT after recv.
s1.recv()
s2.recv()
socks = dict(poller.poll())
self.assertEquals(socks[s1], zmq.POLLOUT)
self.assertEquals(socks[s2], zmq.POLLOUT)
poller.unregister(s1)
poller.unregister(s2)
# Wait for everything to finish.
wait()
开发者ID:HVF,项目名称:pyzmq,代码行数:33,代码来源:test_poll.py
示例11: test_basic
def test_basic(self):
s1, s2 = self.create_bound_pair(zmq.PUB, zmq.SUB)
s2.setsockopt(zmq.SUBSCRIBE,asbytes(''))
time.sleep(0.1)
msg1 = asbytes('message')
s1.send(msg1)
msg2 = s2.recv() # This is blocking!
self.assertEquals(msg1, msg2)
开发者ID:kyledj,项目名称:pyzmq,代码行数:8,代码来源:test_pubsub.py
示例12: _process_socks
def _process_socks(self, socks):
if self.result_collector in socks:
data = self.result_collector.recv_string()
if 'status' not in data:
self.stats_handler.write_result(ujson.loads(data))
self.external_publisher.send_multipart([asbytes(self.topic), asbytes(data)])
self.messages += 1
else:
self.turrets_manager.process_message(ujson.loads(data))
开发者ID:TheGhouls,项目名称:oct,代码行数:9,代码来源:hq.py
示例13: test_bad_send_recv
def test_bad_send_recv(self):
s1, s2 = self.create_bound_pair(zmq.REQ, zmq.REP)
for copy in (True,False):
self.assertRaisesErrno(zmq.EFSM, s1.recv, copy=copy)
self.assertRaisesErrno(zmq.EFSM, s2.send, asbytes('asdf'), copy=copy)
# I have to have this or we die on an Abort trap.
msg1 = asbytes('asdf')
msg2 = self.ping_pong(s1, s2, msg1)
self.assertEquals(msg1, msg2)
开发者ID:kyledj,项目名称:pyzmq,代码行数:10,代码来源:test_reqrep.py
示例14: test_close
def test_close(self):
ctx = zmq.Context()
s = ctx.socket(zmq.PUB)
s.close()
self.assertRaises(zmq.ZMQError, s.bind, asbytes(''))
self.assertRaises(zmq.ZMQError, s.connect, asbytes(''))
self.assertRaises(zmq.ZMQError, s.setsockopt, zmq.SUBSCRIBE, asbytes(''))
self.assertRaises(zmq.ZMQError, s.send, asbytes('asdf'))
self.assertRaises(zmq.ZMQError, s.recv)
del ctx
开发者ID:hoov,项目名称:pyzmq,代码行数:10,代码来源:test_socket.py
示例15: test_topic
def test_topic(self):
s1, s2 = self.create_bound_pair(zmq.PUB, zmq.SUB)
s2.setsockopt(zmq.SUBSCRIBE, asbytes('x'))
time.sleep(0.1)
msg1 = asbytes('message')
s1.send(msg1)
self.assertRaisesErrno(zmq.EAGAIN, s2.recv, zmq.NOBLOCK)
msg1 = asbytes('xmessage')
s1.send(msg1)
msg2 = s2.recv()
self.assertEquals(msg1, msg2)
开发者ID:kyledj,项目名称:pyzmq,代码行数:11,代码来源:test_pubsub.py
示例16: test_reply
def test_reply(self):
alice, bob, mon = self.build_device()
alices = asbytes("hello bob").split()
alice.send_multipart(alices)
bobs = self.recv_multipart(bob)
self.assertEquals(alices, bobs)
bobs = asbytes("hello alice").split()
bob.send_multipart(bobs)
alices = self.recv_multipart(alice)
self.assertEquals(alices, bobs)
self.teardown_device()
开发者ID:P2PTeam,项目名称:salt-windows-install,代码行数:11,代码来源:test_monqueue.py
示例17: test_bad_sockopts
def test_bad_sockopts(self):
"""Test that appropriate errors are raised on bad socket options"""
s = self.context.socket(zmq.PUB)
self.sockets.append(s)
s.setsockopt(zmq.LINGER, 0)
# unrecognized int sockopts pass through to libzmq, and should raise EINVAL
self.assertRaisesErrno(zmq.EINVAL, s.setsockopt, 9999, 5)
self.assertRaisesErrno(zmq.EINVAL, s.getsockopt, 9999)
# but only int sockopts are allowed through this way, otherwise raise a TypeError
self.assertRaises(TypeError, s.setsockopt, 9999, asbytes("5"))
# some sockopts are valid in general, but not on every socket:
self.assertRaisesErrno(zmq.EINVAL, s.setsockopt, zmq.SUBSCRIBE, asbytes('hi'))
开发者ID:aelse,项目名称:pyzmq,代码行数:12,代码来源:test_socket.py
示例18: monitordevice
def monitordevice():
in_prefix=asbytes('in')
out_prefix=asbytes('out')
monitoringdevice = MonitoredQueue(zmq.XREP, zmq.XREQ, zmq.PUB, in_prefix, out_prefix)
monitoringdevice.bind_in("tcp://127.0.0.1:%d" % frontend_port)
monitoringdevice.bind_out("tcp://127.0.0.1:%d" % backend_port)
monitoringdevice.bind_mon("tcp://127.0.0.1:%d" % monitor_port)
monitoringdevice.setsockopt_in(zmq.HWM, 1)
monitoringdevice.setsockopt_out(zmq.HWM, 1)
monitoringdevice.start()
print "Program: Monitoring device has started"
开发者ID:AndrejAleksic,项目名称:pyzmqnotes,代码行数:13,代码来源:monitoredqueue.py
示例19: test_tracker
def test_tracker(self):
"test the MessageTracker object for tracking when zmq is done with a buffer"
addr = 'tcp://127.0.0.1'
a = self.context.socket(zmq.XREQ)
port = a.bind_to_random_port(addr)
a.close()
del a
iface = "%s:%i"%(addr,port)
a = self.context.socket(zmq.XREQ)
a.setsockopt(zmq.IDENTITY, asbytes("a"))
b = self.context.socket(zmq.XREP)
self.sockets.extend([a,b])
a.connect(iface)
time.sleep(0.1)
p1 = a.send(asbytes('something'), copy=False, track=True)
self.assertTrue(isinstance(p1, zmq.MessageTracker))
self.assertFalse(p1.done)
p2 = a.send_multipart(list(map(asbytes, ['something', 'else'])), copy=False, track=True)
self.assert_(isinstance(p2, zmq.MessageTracker))
self.assertEquals(p2.done, False)
self.assertEquals(p1.done, False)
b.bind(iface)
msg = b.recv_multipart()
self.assertEquals(p1.done, True)
self.assertEquals(msg, (list(map(asbytes, ['a', 'something']))))
msg = b.recv_multipart()
self.assertEquals(p2.done, True)
self.assertEquals(msg, list(map(asbytes, ['a', 'something', 'else'])))
m = zmq.Message(asbytes("again"), track=True)
self.assertEquals(m.done, False)
p1 = a.send(m, copy=False)
p2 = a.send(m, copy=False)
self.assertEquals(m.done, False)
self.assertEquals(p1.done, False)
self.assertEquals(p2.done, False)
msg = b.recv_multipart()
self.assertEquals(m.done, False)
self.assertEquals(msg, list(map(asbytes, ['a', 'again'])))
msg = b.recv_multipart()
self.assertEquals(m.done, False)
self.assertEquals(msg, list(map(asbytes, ['a', 'again'])))
self.assertEquals(p1.done, False)
self.assertEquals(p2.done, False)
pm = m.tracker
del m
time.sleep(0.1)
self.assertEquals(p1.done, True)
self.assertEquals(p2.done, True)
m = zmq.Message(asbytes('something'), track=False)
self.assertRaises(ValueError, a.send, m, copy=False, track=True)
开发者ID:kyledj,项目名称:pyzmq,代码行数:51,代码来源:test_socket.py
示例20: test_multi_tracker
def test_multi_tracker(self):
m = zmq.Frame(asbytes('asdf'), track=True)
m2 = zmq.Frame(asbytes('whoda'), track=True)
mt = zmq.MessageTracker(m,m2)
self.assertFalse(m.tracker.done)
self.assertFalse(mt.done)
self.assertRaises(zmq.NotDone, mt.wait, 0.1)
del m
time.sleep(0.1)
self.assertRaises(zmq.NotDone, mt.wait, 0.1)
self.assertFalse(mt.done)
del m2
self.assertTrue(mt.wait() is None)
self.assertTrue(mt.done)
开发者ID:aelse,项目名称:pyzmq,代码行数:14,代码来源:test_message.py
注:本文中的zmq.utils.strtypes.asbytes函数示例由纯净天空整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论