我正在使用服务总线队列在Web角色和工作角色之间进行通信。我的服务总线中有两个队列。我从Web角色将消息放入队列,然后工作角色处理该消息并将另一条消息放回另一个队列,Web角色检索该队列并将其发送给客户端。Web角色和工作角色的线程都在持续运行。
当执行控制位于QueueClient.Receive时,我想知道它是否会等待接收到消息,如果队列上没有消息,则会移动到下一行吗?因为在没有消息的情况下,我已经在QueueClient.Receive处设置了断点以检查下一步会发生什么,但控制不会转移到下一行,它只消失了,所以我认为它可能只是在等待。
但在我的Web角色中,我通过服务总线队列向工作角色发送消息,并期望立即从工作角色获得响应,但是有时候工作角色需要一些处理时间,而Web角色无法获取到响应,导致Web角色线程进入休眠状态。
我是Windows Azure的初学者,对这整个问题感到有些困惑。有人可以帮帮我吗?
我的工作角色:
当执行控制位于QueueClient.Receive时,我想知道它是否会等待接收到消息,如果队列上没有消息,则会移动到下一行吗?因为在没有消息的情况下,我已经在QueueClient.Receive处设置了断点以检查下一步会发生什么,但控制不会转移到下一行,它只消失了,所以我认为它可能只是在等待。
但在我的Web角色中,我通过服务总线队列向工作角色发送消息,并期望立即从工作角色获得响应,但是有时候工作角色需要一些处理时间,而Web角色无法获取到响应,导致Web角色线程进入休眠状态。
我是Windows Azure的初学者,对这整个问题感到有些困惑。有人可以帮帮我吗?
我的工作角色:
// Receive the message from Web Role
BrokeredMessage receivedBroadcastMessage = null;
receivedBroadcastMessage = WebRoleClient.Receive();
if (receivedBroadcastMessage != null)
{
// Process the message
receivedBroadcastMessage.Complete();
}
BrokeredMessage webRoleMessage = new BrokeredMessage(processedMessage);
WorkerRoleClient.Send(webRoleMessage);
我的网络角色:
// send the request to worker role
BrokeredMessage webRoleMessage = new BrokeredMessage(details);
WebRoleClient.Send(webRoleMessage);
// receive the queue from worker role
BrokeredMessage workerRoleMessage = null;
workerRoleMessage = WorkerRoleClient.Receive();
if (workerRoleMessage != null)
{
//process message
workerRoleMessage.Complete();
}
else
{
// sleep thread
}