生成python代码：1、生产者、缓存项目和消费者分别各自独立项目，以三个进程独立启动 2、选择一个消息队列服务使用（MSMQ、RocketMQ等等，备注：可自建消息队列服务器或使用阿里云、腾讯云等消息服务） 3、三个进程（消息队列服务可视为一个进程）它们之间通过接口（可以是socket、http协议、或消息队列SDK）连接并运行，协议自己设计 4、分别使用虚拟机运行以上不同进程

以下是一个简单的Python代码示例，实现了生产者、缓存项目和消费者分别作为独立进程运行，并通过消息队列服务进行通信。

# 生产者进程
import random
import time
import json
import pika

def generate_number():
    return random.randint(2000000000, 3000000000)

def send_number(number, channel):
    message = {"number": number}
    channel.basic_publish(
        exchange='',
        routing_key='numbers',
        body=json.dumps(message)
    )

if __name__ == '__main__':
    connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
    channel = connection.channel()
    channel.queue_declare(queue='numbers')
    while True:
        number = generate_number()
        print(f"Producer: {number}")
        send_number(number, channel)
        time.sleep(1)
    connection.close()


# 缓存项目进程
import pika

def cache_numbers():
    connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
    channel = connection.channel()
    channel.queue_declare(queue='numbers')

    def callback(ch, method, properties, body):
        number = json.loads(body.decode('utf-8'))['number']
        print(f"Caching: {number}")

    channel.basic_consume(
        queue='numbers', on_message_callback=callback, auto_ack=True)

    print('Waiting for messages...')
    channel.start_consuming()

if __name__ == '__main__':
    cache_numbers()


# 消费者进程
import pika

def is_prime(number):
    if number < 2:
        return False
    for i in range(2, int(number ** 0.5) + 1):
        if number % i == 0:
            return False
    return True

def consume_numbers():
    connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
    channel = connection.channel()
    channel.queue_declare(queue='numbers')

    def callback(ch, method, properties, body):
        number = json.loads(body.decode('utf-8'))['number']
        if is_prime(number):
            print(f"Consumer: {number} is prime")

    channel.basic_consume(
        queue='numbers', on_message_callback=callback, auto_ack=True)

    print('Waiting for messages...')
    channel.start_consuming()

if __name__ == '__main__':
    consume_numbers()

在这个示例中，我们使用了Python的pika库来连接RabbitMQ消息队列服务。生产者进程会生成一个大于20亿的随机数，然后将它发送到名为“numbers”的队列中。缓存项目进程会监听这个队列，并将收到的数字打印到控制台上。消费者进程也会监听这个队列，每当收到一个数字时，它会判断这个数字是否为素数，并将结果打印到控制台上。

这个示例可以在三个不同的虚拟机中分别运行。在每个虚拟机中，分别运行一个进程，可以使用命令行来启动这些进程。例如，在生产者进程所在的虚拟机中，可以使用以下命令启动生产者进程：

python producer.py

类似地，在缓存项目进程所在的虚拟机中，可以使用以下命令启动缓存项目进程：

python cache.py

在消费者进程所在的虚拟机中，可以使用以下命令启动消费者进程：

python consumer.py

这样，三个进程就可以通过消息队列服务进行通信，完成整个系统的功能。