在这个例子中，我将使用Python语言来编写一个简单的消息代理。这个代理将包括发布者和订阅者的基本功能。

首先，我们需要定义一个简单的消息代理类，它包含发布消息和订阅消息的方法。

```python

import threading

class MessageBroker:

def __init__(self):

self.queue = [] # 用于存储消息的队列

self.lock = threading.Lock() # 用于同步的锁

def publish(self, message):

with self.lock:

self.queue.append(message)

print(f"Message published: {message}")

def subscribe(self):

# 模拟一个线程池或事件循环来处理订阅者

while True:

with self.lock:

if not self.queue: # 如果没有消息则暂停处理，直到有新消息进来

continue

message = self.queue[0] # 获取队列中的第一个消息

print(f"Message received: {message}") # 打印接收到的消息（在真实应用中，这里应该将消息发送给相应的订阅者）

self.queue.pop(0) # 从队列中移除已处理的消息

# 使用示例：

broker = MessageBroker()

# 启动一个订阅线程来处理接收到的消息

subscriber_thread = threading.Thread(target=broker.subscribe)

subscriber_thread.start() # 启动线程（这里只做演示，实际应用中可能会处理更多的逻辑）

# 发布消息到代理中（在另一个线程或进程中）

broker.publish("Hello, this is a test message!")

```

这个简单的消息代理使用Python的线程锁来确保在多线程环境中消息的同步处理。`publish`方法用于将消息添加到队列中，而`subscribe`方法则模拟了一个订阅者线程，它不断地从队列中取出并处理消息。请注意，这只是一个非常基础的示例，实际应用中可能需要更复杂的逻辑和更多的功能。例如，你可能需要处理多个订阅者、持久化存储、网络通信等。此外，对于生产环境的消息代理系统（如RabbitMQ、Kafka等），还需要考虑更多的性能和可靠性问题。