使用Python编写可与IConsumer()接口配合的数据转发程序

以下是一个使用Python编写的数据转发程序，可以与IConsumer()接口配合使用。该程序将接收到的数据转发给消费者。

import time

class DataForwarder:
    def __init__(self, consumer):
        self.consumer = consumer

    def forward_data(self, data):
        try:
            self.consumer.consume_data(data)
        except Exception as e:
            print(f"Error forwarding data: {str(e)}")

class IConsumer:
    def consume_data(self, data):
        pass

class ExampleConsumer(IConsumer):
    def consume_data(self, data):
        print(f"Consuming data: {data}")

# 使用例子
if __name__ == "__main__":
    # 创建一个消费者示例
    consumer = ExampleConsumer()

    # 创建一个数据转发器实例，并将消费者传递给它
    forwarder = DataForwarder(consumer)

    # 模拟接收到的数据
    data = "Hello, World!"

    # 将数据转发给消费者
    forwarder.forward_data(data)

    # 等待一段时间，以便查看输出
    time.sleep(1)

在上述示例中，我们首先定义了一个接口IConsumer，用于消费数据的类必须实现该接口。然后，我们创建了一个名为ExampleConsumer的类，并实现了IConsumer接口的consume_data方法。在这个例子中，consume_data方法只是简单地打印出接收到的数据。

接下来，我们定义了一个名为DataForwarder的类，它拥有一个forward_data方法，该方法负责将接收到的数据转发给消费者。在forward_data方法中，我们尝试调用消费者的consume_data方法，如果出现任何异常，将打印出相应的错误消息。

在使用示例的代码部分，我们首先创建了一个消费者实例consumer，然后创建了一个数据转发器实例forwarder，并将消费者传递给它。接着，我们模拟了接收到的数据，并使用forward_data方法将数据转发给消费者。最后，我们等待一段时间，以便在屏幕上查看输出。

将上述代码保存为一个Python脚本并运行，您将看到类似以下的输出：

Consuming data: Hello, World!

这表明数据转发成功地将数据传递给了消费者，并且消费者正确地消费了数据。

您可以根据实际需求扩展这个示例程序，以更好地适应您的应用场景。