使用SQL Server Service Broker计划在特定时间段之后调用存储过程
SQL Server Service Broker是SQL Server数据库引擎中的一种消息传递机制，它允许在数据库内部或跨数据库之间进行异步通信。通过使用Service Broker，可以在特定时间段之后调用存储过程，实现定时任务的自动触发。
SQL Server Service Broker的主要特点和优势包括：
- 可靠性：Service Broker使用可靠的消息传递机制，确保消息的可靠传递和处理，即使在网络故障或数据库故障的情况下也能保证消息的完整性。
- 异步处理：Service Broker允许发送方发送消息后立即继续处理，而不需要等待接收方的响应。这种异步处理方式可以提高系统的响应速度和并发性能。
- 可扩展性：Service Broker支持多个会话和多个队列，可以处理大量的并发消息，适用于高负载的应用场景。
- 安全性：Service Broker提供了基于证书和对话的安全机制，确保消息的机密性和完整性。
- 可编程性：Service Broker提供了一套完整的T-SQL语句和存储过程，可以方便地进行开发和管理。
使用SQL Server Service Broker调用存储过程的步骤如下：
- 创建消息类型：使用CREATE MESSAGE TYPE语句创建消息类型，定义消息的结构和格式。
- 创建合同：使用CREATE CONTRACT语句创建合同，定义消息的发送方和接收方之间的通信规则。
- 创建队列：使用CREATE QUEUE语句创建发送方和接收方的队列，用于存储消息。
- 创建服务：使用CREATE SERVICE语句创建发送方和接收方的服务，将队列和合同关联起来。
- 创建存储过程：使用CREATE PROCEDURE语句创建需要在特定时间段之后调用的存储过程。
- 创建触发器：使用CREATE TRIGGER语句创建触发器，当消息到达接收方队列时触发存储过程的调用。
- 发送消息：使用SEND语句将消息发送到接收方队列。
- 接收消息并调用存储过程：当消息到达接收方队列时，触发触发器，调用存储过程进行处理。
腾讯云提供的相关产品和服务包括：
- 云数据库SQL Server：https://cloud.tencent.com/product/cdb_sqlserver
- 云函数SCF（Serverless Cloud Function）：https://cloud.tencent.com/product/scf
- 消息队列CMQ（Cloud Message Queue）：https://cloud.tencent.com/product/cmq
- 云服务器CVM（Cloud Virtual Machine）：https://cloud.tencent.com/product/cvm
请注意，以上链接仅供参考，具体产品选择应根据实际需求和情况进行评估和决策。
相关·内容
目前，我正在使用存储过程执行此操作，该存储过程通过计划的SQL Server代理作业每分钟运行一次。
它工作得很好，但在非高峰时段，每分钟运行一次是不必要的。有没有一种方法可以让存储过程每分钟只在数据插入到表中时运行一次？触发器可能无法工作，因为我不希望存储过程在insert之后立即运行，而是在指定的时间间隔之后运行，这样我就可以一次更新多个冲压。
浏览 9提问于2016-06-28得票数 0
2回答
我的.Net applicationFramework 4.5使用的是SQL server 2016。我在SQL中使用CLR调用，根据CRUD操作将一些数据传递给客户端/浏览器。例如: SignalR通知/调用，使用程序集的web服务调用
我们是否有任何替代的w.r.to.，SQL server CLR来进行直接的web服务调用。如有任何建议/帮助，我
浏览 0提问于2018-09-18得票数 0
我们使用SQL Server 2008R2中的Service Broker作为简单的作业调度程序。我们向代理发送一条消息，代理将其设置为在请求的日期/时间进行处理。此存储过程创建2个表，如果它们不存在，则截断它们，然后调用其他2个存储过程(连续)填充每个表。
几周前，当SB启动主进程“作业”时，两个存储过程中的第二个开始失败。如果我进入SSMS，我可以执行"jo
浏览 0提问于2014-07-29得票数 0
当向特定表中插入一行时，我必须从SQL Server发送Google Client Messaging (GCM)通知。我创建了一个Service Broker来管理队列等，在我的表中，我使用insert操作上的触发器将“工作”添加到我的队列中。我希望Service Broker调用CLR过程来发送GCM通知，并且我在Visual Studio中创建了它。我的问题是，当我尝试在SQL Ser
浏览 0提问于2015-11-06得票数 1
如何在特定时间安排存储过程的一次性执行？基本上，我的需求是处理(Process，TimeToRunIt)的传入请求。
我希望避免使用10秒的SQL Server代理作业来不断检查是否到了执行的时间。根据我的理解，Service Broker是为了让队列执行尽可能快地运行。我可以想象的一种解决方法是对调度的执行请求使用高度并行的Service Broker队列(高最大线程限制)，并使用</em
浏览 7提问于2018-02-20得票数 0
我有一个场景，在这个场景中，我需要处理(在SQL Server中)作为文件夹中的.xml文件实时传递的消息。
我开始研究SQL Service Broker以满足我的排队需求。基本上，我希望Service Broker拾取我的.xml文件，并在它们到达文件夹时将它们放入队列中。但是，SQL Service Broker不支持“独白”对话，至少在当前版本中不支持。我可以使用MSMQ，但是我需要维护两个
浏览 2提问于2010-05-12得票数 1
2回答
我想这样做的方式是一个windows服务，它将连接到我的sql后端，看看是否有SMS消息要发送出去，比如每10-20秒左右。如果是，则获取列表中的所有消息，从表中删除它们，然后继续发送它们。关于如何最好地提供此服务，而不会在asp.net网页中造成阻塞(例如，添加到sql server的消息)，您有什么想法吗？平台为windows server 2003 R2，SQL2008标准，asp.net 3.5 SP1。
谢谢你的建议。
浏览 2提问于2009-08-14得票数 0
回答已采纳
2回答
与我一起工作的一个应用程序开发团队设计了一个通用日志记录应用程序，该应用程序捕获单个存储库(msql2008r2)的异常以供以后审查。该团队希望将任何数据库异常路由到相同的存储库。如上所述，web应用程序使用WCF服务将消息写出到存储库。在某些情况下，由于插入尝试不存在/不正确的外键而导致失败的应用程序实际上会包含在应用程序的消息中，但是，在某些情况下，SQL代理作业执行与这些应用程序相关的存储过程，而这些存储过程不会记录到
浏览 0提问于2012-11-30得票数 0
回答已采纳
2回答
我使用SQL Server，我有3个应用程序服务器。当我的数据库中的表发生变化时，我需要这些应用服务器刷新本地缓存的数据。我对已知的更改使用触发器，并通过Service broker队列发送消息。然后我创建了一个存储过程，并将其分配给我的队列中的存储过程，在这个存储过程中我收到了消息，但我不知道应该如何在我的应用程序中调用刷新方法。
浏览 50提问于2014-08-17得票数 19
回答已采纳
在我的应用程序中，我需要异步调用一个存储的Proc。为此，我使用Sql Service Broker。这些是创建异步调用所涉及的步骤。1)创建Message、Contract、Queue、Service。并发送消息。我可以在'ReceiveQueue1‘中看到我的消息。但是，当我向'ReceiveQueue1‘添加一些新消息时，我的存储过程不会自动将这些记录添加到表中。为了添加新消息，我必须重新执
浏览 1提问于2011-11-24得票数 1
回答已采纳
我想像运行一台服务器一样运行我的两个SQL Server2008 R2企业版。如果一台服务器太忙，系统应该将请求定向到另一台服务器。我该怎么做呢？谢谢..
浏览 1提问于2012-05-30得票数 0
2回答
我希望将工作分散到多个进程中，而不必每分钟轮询SQL Server以查找更多工作。客户端将使用C#编写。
任何已知的模式、想法或方向都将非常感谢。
浏览 0提问于2012-07-18得票数 1
回答已采纳
在SQL Server中，是否可以调用长时间运行的存储过程，关闭连接并让其完成？我不关心结果。本质上，我想说：“嘿，SQL，在你自己的服务器上做这项工作吧。”
浏览 0提问于2011-11-18得票数 4
回答已采纳
我有一个外部程序，它将调用一个存储过程来等待队列中的消息，然后处理它。问题是有时从队列读取的消息可能无法正确处理，当发生这种情况时，我希望将消息留在队列中，直到可以处理它。但是正如您所看到的，在存储过程将消息返回给调用者(即java程序)之前，我无法知道消息是否有效。我想知道是否可以将"begin transaction“和" commit”或" rollback“分成两个存储过程:调用开始事务的
浏览 0提问于2012-03-19得票数 0
有没有使用SQL语言与套接字通信的方法？(为什么？)假设我手动打开SQL Server Management Studio，打开一个表，然后手动插入一条记录(我想强调的是，手动插入中间没有任何中间件)。我考虑的解决方案是将插入的记录写入一个文件，然后使用另一个应用程序监视该文件的更改(再次强调，我根本不想通过中间件来做这件事)，但这种方法不是实现此要求的标准方法，它更像是一种变通方法。是否有使用纯SQL Server语法/功能发出更改信号的标
浏览 2提问于2018-01-13得票数 0
回答已采纳
5回答
我们有一个存储过程，其中有两个部分。在第1部分中，需要将失败返回给应用程序，并且在存储过程返回之前必须完全执行该部分。第2部分是一个很长的过程，每次调用过程时都需要执行，但是所有的失败都可以忽略(或者在其他地方处理)，但是我们希望应用程序在完成之前返回。因此，我们需要一个完成此操作的过程：return
exec PART2 -- still gets executed, but after sql se
浏览 1提问于2009-12-17得票数 1
回答已采纳
在执行对外部数据和我们自己的数据执行分析的存储过程之前，需要提取这些数据。我的想法是创建一个CLR存储过程，它将被执行分析的存储过程调用，该分析将运行HTTP请求，反序列化JSON，然后将数据填充到我们的数据库中。谢谢
浏览 2提问于2015-05-07得票数 0
1回答
因此，我在Server上运行，并看到SQLQueryNotificationService每秒钟运行一次，持续时间很长。我检查了Service，创建了许多SQLQueryNotificationService队列。我不认为我们创建了任何这样的队列，还有像这些SqlQueryNotificationStoredProcedure-15c5b84b-42b0-4cfb-9707-9b1697f44127.这样的存储过程你能告诉我怎么扔掉它们吗
浏览 1提问于2013-03-05得票数 2
我们使用SQL Service Broker来调用存储的进程。当我们调用从一个数据库执行的存储的proc时，这个服务代理工作得很好。但当它调用另一个从多个数据库检索数据的存储过程时，它抛出的错误是“在当前安全上下文下，服务器原理无法访问"databseB”“。这两个数据库使用相同的登录名和用户名。但是这个存储的Proc在正常执行时，它执行时没有任何问题。
浏览 2提问于2011-12-02得票数 0
回答已采纳
6回答
我想知道有什么方法可以让我一次执行所有的存储过程。目前，我正在使用exec "Stored Procedure name"命令执行每个存储过程。我有200多个存储过程要在我的数据库上执行。有没有什么简单的方法可以一次执行所有这些存储过程，因为我很难跟踪它们？
浏览 2提问于2012-10-07得票数 3
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频活动推荐
腾讯云开发者
