如何修改Azure Service Bus代码实现单次接收一条消息？

嘿，针对你的需求，我来一步步说明怎么让Azure Service Bus一次只收一条消息，同时把你的代码调整到位：

首先，核心逻辑很简单：别用批量接收的API，直接用Service Bus客户端的**Receive()同步方法**（或者异步的ReceiveAsync()），这两个方法每次只会拉取一条可用的消息，完美符合你的需求。另外还要注意消息的确认机制——处理完消息要调用Complete()把它从队列删掉，要是处理失败就用Abandon()让消息回到队列，避免丢消息。

下面是修改后的完整代码，我把发送和接收部分都优化了，尤其是接收逻辑补全并做了规范处理：

修改后的完整代码 #

Imports Microsoft.ServiceBus.Messaging

Private Sub Button_SEND_Click(sender As Object, e As EventArgs) Handles Button_SEND.Click
    ' 用Using语句自动管理客户端资源，比手动设Nothing更安全
    Using client As QueueClient = QueueClient.CreateFromConnectionString(My.Settings.connString, My.Settings.queueName)
        Dim message As New BrokeredMessage(TextBox_M2SEND.Text.Trim)
        client.Send(message)
        MessageBox.Show("消息发送成功！")
    End Using
End Sub

' 读取单条消息的按钮点击事件
Private Sub Button_READ_Click(sender As Object, e As EventArgs) Handles Button_READ.Click
    Using client As QueueClient = QueueClient.CreateFromConnectionString(My.Settings.connString, My.Settings.queueName)
        ' 接收一条消息，设置5秒超时——没消息时就直接返回，不会卡死UI
        Dim receivedMessage As BrokeredMessage = client.Receive(TimeSpan.FromSeconds(5))
        
        If receivedMessage IsNot Nothing Then
            Try
                ' 读取消息里的文本内容，显示到文本框
                Dim messageContent As String = receivedMessage.GetBody(Of String)()
                TextBox_M2READ.Text = messageContent
                
                ' 确认消息处理完成，从队列移除
                receivedMessage.Complete()
                MessageBox.Show("消息接收并处理完成！")
            Catch ex As Exception
                ' 处理出错了，把消息放回队列，避免丢失
                receivedMessage.Abandon()
                MessageBox.Show($"处理消息失败，消息已放回队列：{ex.Message}")
            Finally
                ' 手动释放消息资源
                receivedMessage.Dispose()
            End Try
        Else
            MessageBox.Show("队列里暂时没有可用消息哦！")
        End If
    End Using
End Sub

关键改动点说明 #

• 把原来手动赋值client = Nothing改成了Using语句，自动释放资源，避免内存泄漏。
• 接收消息时加了5秒超时，防止UI线程被无限阻塞。
• 增加了异常处理逻辑，保证消息在处理失败时能回到队列，不会丢。
• 完善了消息内容的读取和显示逻辑，让接收功能真正可用。

如果你的项目用的是新版Azure.Messaging.ServiceBus SDK（不是旧的Microsoft.ServiceBus.Messaging），代码会有点不一样，但从你提供的代码来看，应该是用的旧版SDK，所以上面的代码完全适配你的场景。

内容的提问来源于stack exchange，提问作者alex.s