MSSQL消息发布：分享、沟通、连接

撸码网

2024-07-05 11:21:40

0次

1. 消息发布的作用

在MSSQL数据库中，消息发布是一种用于实现消息通信的机制。它具有分享、沟通、连接的作用。

1.1 分享

消息发布是一种多对多通信机制，它可以使多个客户端同时订阅同一个主题，从而实现信息共享。

例如：多个用户关注同一个任务的执行情况，可以订阅这个任务相关的主题，任务执行状态发生变化时，消息发布就会向所有订阅该主题的用户发送消息，从而实现任务执行过程的信息共享。

1.2 沟通

消息发布还可以用于实现多个应用程序之间的沟通。

例如：如果一个应用程序需要向另一个应用程序发送消息，则可以将消息发布到指定的主题，另一个应用程序再订阅该主题，就可以收到消息。

1.3 连接

消息发布可以用于建立应用程序之间的实时连接，从而实现实时数据传输。

例如：如果一个应用程序需要监控另一个应用程序的状态变化，可以使用消息发布将状态变化的信息实时传输给监控程序。

2. 消息发布的实现

在MSSQL数据库中，消息发布是通过创建一个消息发布器来实现的。一个消息发布器是一个数据库对象，用于发布消息到一个或多个主题。

在创建一个消息发布器之前，需要先创建一个消息类型，消息类型定义了消息的格式和内容。消息类型包括消息名称、消息格式和可选参数，如下所示：



CREATE MESSAGE TYPE message_type_name


[


    VALIDATION = { NONE | EMPTY | WELL_FORMED_XML }


]

其中：message_type_name是消息类型的名称，可以是nvarchar(256)类型的任意名称。

创建消息类型后，就可以创建一个消息合同。消息合同定义消息的目标主题，以及消息类型和传输协议，如下所示：



CREATE CONTRACT contract_name


(


    message_type_name SENT BY { INITIATOR | TARGET | ANY }


)

其中：contract_name是消息合同的名称，可以是nvarchar(256)类型的任意名称；message_type_name是消息类型的名称，需要与之前创建的消息类型名称相同；SENT BY { INITIATOR | TARGET | ANY }定义了消息是由发起方、接收方还是任意一方发送。

创建好消息类型和消息合同后，就可以创建一个消息发布器了。创建消息发布器需要指定发布器的名称、目标主题、消息合同和传输协议，如下所示：



CREATE TRIGGER trigger_name


ON table_name


FOR INSERT


AS


DECLARE @msg_body varbinary(max)


SET @msg_body = (SELECT * FROM inserted FOR XML AUTO)


;BEGIN TRANSACTION MessageTrigger


BEGIN TRY


    DECLARE @dialog_handle UNIQUEIDENTIFIER;


    BEGIN DIALOG @dialog_handle 


    FROM SERVICE


    [//mynamespace.com/myservice] 


    TO SERVICE 


    '//mynamespace.com/myservice/myqueue'


    ON CONTRACT [//mynamespace.com/myservice/mycontract]


    WITH ENCRYPTION = OFF;


    SEND ON CONVERSATION @dialog_handle


    MESSAGE TYPE mymessage


    (@msg_body);


    COMMIT TRANSACTION MessageTrigger;


END TRY


BEGIN CATCH


    ROLLBACK TRANSACTION MessageTrigger;


    PRINT ERROR_MESSAGE();


END CATCH


GO

其中：trigger_name是触发器的名称；table_name是触发器要监视的表名；消息的内容是通过FOR XML AUTO选项获取的；mynamespace.com是服务名称，myservice是服务中的一部分，myqueue是目标服务中的队列名称；mymessage是消息的名称。

3. 消息发布的应用实例

消息发布在企业级应用程序中有广泛的应用，特别是在分布式应用程序和较大规模的数据交换场景中更为常见。下面是一个示例：

3.1 场景描述

假设有一个企业级订单处理系统，订单处理过程需要跨越多个部门和系统。订单创建后，需要及时通知到各个部门和系统，以便他们做相应处理，同时需要将订单信息同步到不同的数据库中，以便实现数据共享和数据分析。

3.2 解决方案

为了解决上述问题，可以使用MSSQL数据库的消息发布机制。具体实现步骤如下：

3.2.1 创建消息类型和消息合同

创建订单消息的消息类型和消息合同，以便在订单创建时发布到目标主题，如下所示：



-- 创建消息类型  


CREATE MESSAGE TYPE OrderCreatedMessage  


    VALIDATION = NONE;  


GO  


-- 创建消息合同  


CREATE CONTRACT OrderCreatedContract  


    (OrderCreatedMessage SENT BY INITIATOR);  


GO

3.2.2 创建目标主题和队列

将消息发布到目标主题和队列中，以便订阅该主题的各个部门和系统能够收到消息，如下所示：



-- 创建目标主题  


CREATE TOPIC OrderCreatedTopic  


    (OrderCreatedMessage  


        WITH  


            (  


              STATUS = ON,  


              RETENTION = OFF,  


              DEFAULT_CONTRACT = OrderCreatedContract  


            )  


    );  


GO  


-- 创建目标队列  


CREATE QUEUE OrderCreatedQueue  


    WITH  


        STATUS = ON  


    ;  


GO  


-- 将目标队列绑定到目标主题  


CREATE SERVICE OrderCreatedService  


    ON QUEUE OrderCreatedQueue  


    ([http://schemas.microsoft.com/SQL/Notifications/PostEventNotification]);  


GO  


ALTER QUEUE OrderCreatedQueue  


    WITH  


        ACTIVATION (  


            STATUS = ON,  


            PROCEDURE_NAME = notification_procedure,  


            MAX_QUEUE_READERS = 1,  


            EXECUTE AS SELF  


        );  


GO

3.2.3 创建触发器

创建一个触发器用于在订单创建时发布消息到目标主题和队列，如下所示：



-- 创建触发器  


CREATE TRIGGER OrderCreatedTrigger  


ON Orders  


AFTER INSERT  


AS  


BEGIN  


  DECLARE @message_body varbinary(max);  


  SELECT @message_body = CONVERT(varbinary(max), (  


    SELECT *  


    FROM INSERTED  


    FOR XML AUTO  


  ));  


  


  DECLARE @conversation_handle UNIQUEIDENTIFIER;  


  BEGIN DIALOG @conversation_handle   


   FROM SERVICE OrderCreatedService  


   TO SERVICE 'http://schemas.microsoft.com/SQL/Notifications/PostEventNotification'  


   ON CONTRACT OrderCreatedContract  


   WITH ENCRYPTION = OFF;  


  SEND ON CONVERSATION @conversation_handle  


    MESSAGE TYPE OrderCreatedMessage  


    (@message_body);  


  END CONVERSATION @conversation_handle;  


END  


GO

3.2.4 订阅目标主题

在各个部门和系统的数据库中订阅目标主题，以便能够收到订单创建的消息，如下所示：



-- 在各个部门和系统的数据库中订阅目标主题  


CREATE SERVICE OrderCreatedService  


    ON QUEUE OrderCreatedQueue  


    ([http://schemas.microsoft.com/SQL/Notifications/PostEventNotification]);  


GO  


CREATE ROUTE OrderCreatedRoute  


    WITH  


        SERVICE_NAME = 'OrderCreatedService',  


        ADDRESS = 'LOCAL';  


GO  


CREATE EVENT NOTIFICATION OrderCreatedEventNotification  


    ON SERVER  


    FOR TOPIC OrderCreatedTopic  


    TO SERVICE 'OrderCreatedService'  


GO

3.2.5 处理订单创建的消息

订阅了目标主题的各个部门和系统的数据库，会收到订单创建的消息，需要编写相应的处理程序，来处理订单数据并将其同步到其他数据库中，以实现数据共享和数据分析，如下所示：



-- 订单处理程序处理函数  


CREATE PROCEDURE ProcessOrderCreatedMessage  


(  


    @message_body varbinary(max)  


)  


AS  


BEGIN  


    DECLARE @order_id int;  


    DECLARE @order_date datetime;  


    DECLARE @customer_id int;  


    DECLARE @order_total money;  


    -- 解析消息  


    SELECT  


        @order_id = x.OrderID,  


        @order_date = x.OrderDate,  


        @customer_id = x.CustomerID,  


        @order_total = x.OrderTotal  


    FROM  


        (  


            SELECT  


                OrderID = T.c.value('(OrderID)[1]', 'int'),  


                OrderDate = T.c.value('(OrderDate)[1]', 'datetime'),  


                CustomerID = T.c.value('(CustomerID)[1]', 'int'),  


                OrderTotal = T.c.value('(OrderTotal)[1]', 'money')  


            FROM  


                (  


                    SELECT CAST(@message_body AS XML) AS x  


                ) AS x  


                CROSS APPLY x.nodes('/Orders/Order') AS T(c)  


        ) AS x;  


    -- 处理订单数据  


    -- ...


    -- 将订单数据同步到其他数据库  


    -- ...  


END;  


GO  


-- 订阅消息处理函数  


CREATE QUEUE ProcessOrderCreatedMessageQueue  


GO  


CREATE SERVICE ProcessOrderCreatedMessageService   


    ON QUEUE ProcessOrderCreatedMessageQueue   


        ([http://schemas.microsoft.com/SQL/Notifications/PostEventNotification]);  


GO  


CREATE ROUTE ProcessOrderCreatedMessageRoute  


    WITH  


        SERVICE_NAME = 'ProcessOrderCreatedMessageService',  


        ADDRESS = 'LOCAL';  


GO  


CREATE EVENT NOTIFICATION ProcessOrderCreatedMessageEventNotification  


    ON SERVER  


    FOR QUEUE ProcessOrderCreatedMessageQueue   


    TO SERVICE 'ProcessOrderCreatedMessageService', 'CURRENT DATABASE'  


    WITH FAN_IN  


GO  


-- 订阅消息处理函数  


ALTER QUEUE ProcessOrderCreatedMessageQueue   


        WITH ACTIVATION   


        (  


            STATUS = ON   


            ,PROCEDURE_NAME=ProcessOrderCreatedMessage   


            ,MAX_QUEUE_READERS = 1  


            ,EXECUTE AS SELF  


        );  


GO

4. 总结

消息发布是一种实现消息通信的机制，在MSSQL数据库中有广泛的应用。消息发布的作用主要体现在分享、沟通和连接方面。为了实现消息发布，需要创建消息类型、消息合同、目标主题和队列，并编写触发器和处理程序来发布和处理消息。

免责声明：本文来自互联网，本站所有信息（包括但不限于文字、视频、音频、数据及图表），不保证该信息的准确性、真实性、完整性、有效性、及时性、原创性等，版权归属于原作者，如无意侵犯媒体或个人知识产权，请来电或致函告之，本站将在第一时间处理。猿码集站发布此文目的在于促进信息交流，此文观点与本站立场无关，不承担任何责任。

上一篇：MSSQL消耗的时光：最耗时的挑战

下一篇：MSSQL测试管理之旅：有效利用测试管理工具

相关阅读

数据库标签

SQL热门

SQL更新

免责申明：本站所有文章、数据仅供参考，广告商的言论与行为均与猿码集无关！谨防受骗！ 侵权及不实信息举报邮箱至：amarlboro@yeah.net 渝ICP备2023009929号-1