我需要设置一个将 sqs 发送到服务器的客户端:
客户端:
...
sqs = AWS::SQS.new
q = sqs.queues.create("q_name")
m = q.send_message("meta")
...
但是服务器如何读取客户端的消息?
先感谢您。
我需要设置一个将 sqs 发送到服务器的客户端:
客户端:
...
sqs = AWS::SQS.new
q = sqs.queues.create("q_name")
m = q.send_message("meta")
...
但是服务器如何读取客户端的消息?
先感谢您。
首先你需要让你的服务器连接到 SQS 然后你可以得到你的队列。在您的队列上执行 get_messages。转到boto 文档以获取有关属性的更多信息。这将根据您的参数为您提供 1 到 10 个消息对象。然后在每个对象上执行 get_body() 然后您将获得消息的字符串。
这是python中的一个简单示例。抱歉不知道红宝石。
sqsConn = connect_to_region("us-west-1", # this is the region you created the queue in
aws_access_key_id=AWS_ACCESS_KEY_ID,
aws_secret_access_key=AWS_SECRET_ACCESS_KEY)
QUEUE = sqsConn.get_queue("my-queue") # the name of your queue
msgs = QUEUE.get_messages(num_messages=10, # try and get 10 messages
wait_time_seconds=1, # wait 1 second for these messages
visibility_timeout=10) # keep them visible for 10 seconds
body = msgs[0].get_body() # get the string from the first object
希望这可以帮助。