Как получить объект JSON из подписок на тему служебной шины Azure

Question

У меня есть сомнения по поводу реализации Azure Service Bus получать сообщения от подписки на темы. Мы используем несколько приложений в нашей организации, и нам нужно обмениваться данными между одной подсистемой, чтобы мы использовали служебную шину Azure. Здесь одно из моих приложений часто отправляло сообщение для подписки на тему служебной шины. Всякий раз, когда в нашем приложении создается новая учетная запись пользователя, каждый раз данные профиля пользователя будут отправлять данные в соответствующие подписки на темы служебной шины. Я упомянул ниже снимок, который я должен получить объект JSON. Сообщение хранится в виде объекта JSON.

введите описание изображения здесь

JSON-объект:

{ "ID":"N322333","Имя": "adsdddd", "LastName":"asddd", "электронная почта":"[e-mail]123ZXc","emailVerified" ложь "DateOfBirth":"2016-08-03","Вход":"qqqqqqqqqq","пароль":"Pass@1234","HomePhone":"233322","MobilePhone":"1111111122asdf","workPhone":"22222","Гендер":1,"centerId":"I23642","UserType":"студент","staffRole": нулевой,"staffActive": ложные}

Теперь я собираюсь получить объект JSON, который я уже отправил в очередь подписок на темы служебной шины Azure, прежде чем перейти в тупик. В объектах JSON может храниться список объектов JSON по подписке. Я искал много примеров, которые я не смог найти подходящего решения. Пожалуйста, позвольте мне поделиться вашим предложением. Как я могу получить список объектов JSON? Я буду ждать вашего ответа.

С Уважением,

Parthiban.

Answer 1

Полезная нагрузка BrokeredMessage это единственный бизнес приложения. Вы контролируете, что вы отправляете в своем сообщении. Если вы можете, вы можете отправить свой объект JSON в виде одной полезной нагрузки в одном сообщении с брокером и обработать список.

Если вы спрашиваете, как получить несколько сообщений и объединить их в один список, это теперь имеет два аспекта

1. Технические: как получить несколько сообщений
2. Логический + технический: как объединять несколько сообщений и логически знать, когда список является полным списком для обработки.

Первый пункт не так сложен, вы можете получать сообщения партиями, используя .ReceiveBatchAsync()

Второй пункт действительно зависит от вашей реализации. Если вам нужно объединить эти отдельные сообщения и обработать список, вы должны ответить на такие вопросы, как, сколько сообщений составляют список, есть ли у вас период времени, когда это происходит, как и где вы храните эти элементы по мере их поступления. Возможно, вы просто сохраняете эти сообщения, и отдельный процесс выполняет обработку, формируя список за определенный период времени и т. Д.

Одно замечание - по изображению все ваши сообщения имеют одинаковый идентификатор. Трудно увидеть, как это отрубается. Это хорошая практика