如何更改这些模块以使通信是双向的(inout)？

# 模块A
def callback(data):
    print(f"Received data from Module B: {data}")

# 模块B
def send_data(callback):
    data = "Hello from Module B"
    callback(data)

# 使用
send_data(callback)

const EventEmitter = require('events');
const eventEmitter = new EventEmitter();

// 模块A
eventEmitter.on('data', (data) => {
    console.log(`Received data from Module B: ${data}`);
});

// 模块B
eventEmitter.emit('data', 'Hello from Module B');

# 模块A
import pika

connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
channel = connection.channel()

channel.queue_declare(queue='hello')

def callback(ch, method, properties, body):
    print(f"Received {body}")

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

print('Waiting for messages. To exit press CTRL+C')
channel.start_consuming()

# 模块B
import pika

connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
channel = connection.channel()

channel.queue_declare(queue='hello')

channel.basic_publish(exchange='', routing_key='hello', body='Hello World!')
print(" [x] Sent 'Hello World!'")

connection.close()

# 定义proto文件
syntax = "proto3";

service Greeter {
    rpc SayHello (HelloRequest) returns (HelloReply) {}
}

message HelloRequest {
    string name = 1;
}

message HelloReply {
    string message = 1;
}

# 模块A（客户端）
import grpc
import hello_pb2
import hello_pb2_grpc

channel = grpc.insecure_channel('localhost:50051')
stub = hello_pb2_grpc.GreeterStub(channel)

response = stub.SayHello(hello_pb2.HelloRequest(name='Module A'))
print("Greeter client received: " + response.message)

# 模块B（服务器）
import grpc
from concurrent import futures
import hello_pb2
import hello_pb2_grpc

class Greeter(hello_pb2_grpc.GreeterServicer):
    def SayHello(self, request, context):
        return hello_pb2.HelloReply(message='Hello, %s!' % request.name)

server = grpc.server(futures.ThreadPoolExecutor(max_workers=10))
hello_pb2_grpc.add_GreeterServicer_to_server(Greeter(), server)
server.add_insecure_port('[::]:50051')
server.start()
server.wait_for_termination()

// 模块A（服务器）
const WebSocket = require('ws');
const wss = new WebSocket.Server({ port: 8080 });

wss.on('connection', function connection(ws) {
    ws.on('message', function incoming(message) {
        console.log('received: %s', message);
        ws.send('Hello from Module A');
    });
});

// 模块B（客户端）
const WebSocket = require('ws');
const ws = new WebSocket('ws://localhost:8080');

ws.on('open', function open() {
    ws.send('Hello from Module B');
});

ws.on('message', function incoming(data) {
    console.log(data);
});