您好, 欢迎来到 !    登录 | 注册 | | 设为首页 | 收藏本站

如何将数据从数据库推送到应用程序?

如何将数据从数据库推送到应用程序?

当然,有几种可能性可以做到这一点:

就个人而言,与其他方法相比,我更喜欢查询通知,因为它已经支持多种情况(例如,同步/异步通信),并且您不必重新发明轮子。并且在您的情况下由Microsoft建议。

轮询是您提到的另一种方法。它更像是传统方法,并且可能会有一些性能损失,但是如果您足够小心,就不必担心它们。例如,如果您已经在应用程序中内置了身份验证,则可以在您的应用程序中创建另一列Users如果该用户有任何更改,则设置该表。然后,您的应用程序中可能只有一个线程,它将每秒对该表执行一次查询(即使使用NOLOCK进行脏读也不是问题),并维护一些内存结构(例如线程安全的字典)那说明应该推动哪个客户。另一个线程轮询您的字典,当它找到适合客户端的内容时,执行db查询提取数据并将其发送给客户端。这看起来像很多不必要的工作,但是最后您得到了两个独立的工作人员,这在一定程度上有助于分离问题。第一个只是执行“轻量级”数据库轮询的通知程序;第二个提取真实数据并执行服务器推送。您甚至可以按其运行时的方式来优化推手,它检查多个客户端是否需要一些数据,然后对所有需要这些数据的人执行选择。您可能希望第二个工作人员的运行频率低于第一个工作人员。

如果希望使用非.NET技术来实现相同的功能,则必须更多地使用sql Server Service Broker。查询通知sql ServerServiceBroker上.NET中内置的简化层,您必须自己至少构建该层的一部分。这包括使用另一端的SEND和RECEIVE创建队列,消息类型,服务和存储过程。您将必须自己处理对话/对话。SB实际上是经过调整的异步消息世界,可以在RDBMS环境中工作,因此您将看到一些新的Tsql表达式。但是,MSDN可以为您提供帮助:

有关如何编写内容的示例:

-- First you have to enable SB for your database
USE master
ALTER DATABASE Playground
SET ENABLE_BROKER
GO

USE Playground
GO

-- Then create a message type; usually it will be XML
-- because it's very easy to serialize/deserialize it
CREATE MESSAGE TYPE [//Playground/YourMessageType]
VALIDATION = WELL_FORMED_XML
GO

-- Then create a contract to have a rule for communication
-- Specifies who sends which message type
CREATE CONTRACT [//Playground/YourContract] (
    [//Playground/YourMessageType] SENT BY ANY)
GO

--Creates queues, one for initiator (1) and one for target (2)
CREATE QUEUE MyQueue1
GO
CREATE QUEUE MyQueue2
GO

-- Finally, configure services that 'consume' queues
CREATE SERVICE [//Playground/YourService1]
ON QUEUE MyQueue1 ([//Playground/YourContract])
GO

CREATE SERVICE [//Playground/YourService2] 
ON QUEUE MyQueue2 ([//Playground/YourContract])
GO

-- Now you can send a message from service to service using contract
DECLARE 
    @dHandle uniqueidentifier,
    @Msg nvarchar(max)

BEGIN DIALOG @dHandle
    FROM SERVICE [//Playground/YourService1]
    TO SERVICE '//Playground/YourService2'
    ON CONTRACT [//Playground/YourContract]
WITH ENCRYPTION = OFF

SELECT @Msg = (
    SELECT TOP 3 *
    FROM Table1
    FOR XML PATH('row'), ROOT('Table1'))

;SEND ON CONVERSATION @dHandle 
MESSAGE TYPE [//Playground/YourMessageType] (@Msg)

PRINT @Msg
GO

-- To get the message on the other end, use RECEIVE
-- Execute this in another query window
DECLARE @dHandle uniqueidentifier
DECLARE @MsgType nvarchar(128)
DECLARE @Msg nvarchar(max)

;RECEIVE TOP(1)
    @dHandle = conversation_handle,
    @Msg = message_body,
    @MsgType = message_type_name
FROM MyQueue2

SELECT @MsgType 
SELECT @Msg

END CONVERSATION @dHandle 
GO
其他 2022/1/1 18:16:39 有511人围观

撰写回答


你尚未登录,登录后可以

和开发者交流问题的细节

关注并接收问题和回答的更新提醒

参与内容的编辑和改进,让解决方法与时俱进

请先登录

推荐问题


联系我
置顶