from  greenlet import greenlet

def test1():
    print(1)
    gr2.switch()
    print(3)
    gr2.switch()
def test2():
    print(2)
    gr1.switch()
    print(4)
    gr1.switch()

gr1 = greenlet(test1)
gr2 = greenlet(test2)
gr2.switch()

import gevent
def func1():
    print("1111")
    gevent.sleep(1)
    print("2222")
def func2():
    print("3333")
    gevent.sleep(1)
    print("444444")
def func3():
    print("55555")
    gevent.sleep(2)
    print("666666")

gevent.joinall([
    gevent.spawn(func1),
    gevent.spawn(func2),
    gevent.spawn(func3)
])

import gevent

def task(pid):
    gevent.sleep(0.5)
    print(‘Task %s done‘ % pid)

def synchronous():
    for i in range(1, 10):
        task(i)

def asynchronous():
    threads = [gevent.spawn(task, i) for i in range(10)]
    gevent.joinall(threads)

print(‘Synchronous:‘)
synchronous()

print(‘Asynchronous:‘)
asynchronous()

import time
# from gevent import monkey;
# monkey.patch_all()
import gevent
from  urllib.request import urlopen

def f(url):
    print(‘GET: %s‘ % url)
    resp = urlopen(url)
    data = http://www.mamicode.com/resp.read()
    print(‘%d bytes received from %s.‘ % (len(data), url))
t1 = time.time()
gevent.joinall([
    gevent.spawn(f, ‘https://www.python.org/‘),
    gevent.spawn(f, ‘https://www.yahoo.com/‘),
    gevent.spawn(f, ‘https://github.com/‘),
])
print(time.time()-t1)

import socket

HOST = ‘localhost‘  # The remote host
PORT = 9999  # The same port as used by the server
s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
s.connect((HOST, PORT))
while True:
    msg = bytes(input(">>:"), encoding="utf8")
    s.sendall(msg)
    data = s.recv(1024)
    # print(data)

    print(‘Received‘, repr(data))
s.close()

import pika

connection = pika.BlockingConnection(pika.ConnectionParameters(
    ‘192.168.56.15‘))
channel = connection.channel()

# 声明queue
channel.queue_declare(queue=‘liangkai‘)

# n RabbitMQ a message can never be sent directly to the queue, it always needs to go through an exchange.
channel.basic_publish(exchange=‘‘,
                      routing_key=‘liangkai‘,
                      body=‘liangkai & xiaoqing‘)
print(" [x] Sent ‘Hello World!‘")
connection.close()

import pika
connection = pika.BlockingConnection(pika.ConnectionParameters(‘192.168.56.15‘))
channel = connection.channel()

channel.queue_declare(queue=‘liangkai‘)

def callback(ch,method,properties,body):
    print(ch,method,property)
    print("[x] Recived %r"%body)
channel.basic_consume(callback,queue="liangkai",no_ack=True)

print("[*] Wating for message.TO exit press CTRL+C")
channel.start_consuming()

import pika

#connection = pika.BlockingConnection(pika.ConnectionParameters(
#     ‘192.168.56.15‘))
# 添加认证
username = ‘python‘   #指定远程rabbitmq的用户名密码
pwd = ‘python‘
user_pwd = pika.PlainCredentials(username, pwd)
connection = pika.BlockingConnection(pika.ConnectionParameters(‘192.168.56.15‘, credentials=user_pwd))#创建连接
channel = connection.channel()
# 声明queue
channel.queue_declare(queue=‘kaige‘,durable=True)  #队列的持久化

# n RabbitMQ a message can never be sent directly to the queue, it always needs to go through an exchange.
channel.basic_publish(exchange=‘‘,
                      routing_key=‘kaige‘,
                      body=‘liangkai & xiaoqing‘,
                      properties = pika.BasicProperties(
                          delivery_mode=2       #消息的持久化
                      ))
print(" [x] Sent ‘Hello World!‘")
connection.close()

import pika
username = ‘python‘   #指定远程rabbitmq的用户名密码
pwd = ‘python‘
user_pwd = pika.PlainCredentials(username, pwd)
connection = pika.BlockingConnection(pika.ConnectionParameters(‘192.168.56.15‘, credentials=user_pwd))#创建连接

channel = connection.channel()
#注意这里发送端要和接收端定义的连接相同
channel.queue_declare(queue=‘kaige‘,durable=True) 

def callback(ch,method,properties,body):
    print(ch,method,property)
    print("[x] Recived %r"%body)
channel.basic_consume(callback,queue="kaige",no_ack=True)

print("[*] Wating for message.TO exit press CTRL+C")
channel.start_consuming()