SSB(SQLservice Service Broker) 入门实例介绍

step 1:perpar database & data


代码如下:

use master
go
Create database Inventory
go
use Inventory
go
Create table inventory
(
    TitleId nvarchar(6) not null,
    Quantity int not null,
    primary key (TitleId,Quantity)
);
go

insert inventory values ('pc1001',100);
insert inventory values ('pc1002',200);
insert inventory values ('pc1003',300);
insert inventory values ('pc1004',400);

step 2: 创建整个SSB的基础框架.

首先创建信息类型


代码如下:

Create Message Type [//mark/v10/types/inventory]
Create Message Type [//mark/v10/types/inventoryresponse]

创建合约


代码如下:

Create contracts [//mark/v10/contracts/inventorycontract]
(
    [//mark/v10/types/inventory] send by initiator,
    [//mark/v10/types/inventoryresponse] send by target 
);

创建队列与服务

代码如下:

create queue [inventory client queue];
create service [//mark/v10/services/inventory client]
    on queue [inventory client queue]

go
    --create inventory service
    create queue [inventory queue];
    create service [//mark/v10/services/inventory]
    on queue [inventory queue]
    (
        [//mark/v10/contracts/inventorycontract]
    );

step 3:发送消息到消息队列中



代码如下:

use Inventory
go
--send message
begin transaction
    declare @dialog_id uniqueidentifier
    begin dialog conversation @dialog_id
        from service [//mark/v10/services/inventory client]
        to service '//mark/v10/services/inventory'
        on contract [//mark/v10/contracts/inventorycontract]
        with encryption = off;
        send on conversation @dialog_id message type [//mark/v10/types/inventory]
        (
        '<InventoryUpdate>
        <TitleId>pc1001</TitleId>
        <Quantity>102</Quantity>
        </InventoryUpdate>'   
        );
        commit transaction;

发送成功后,可以查询 inventory_queue


代码如下:

select conversation_handle, cast(message_body as xml) as conversation_body from [Inventory queue]

这里只是查询了两列。
 
其中conversation_body 就是 我们发出的信息了。

setp 4: 从 inventory queue 中获取信息并更新数据

代码如下:

use inventory
go
begin transaction
    declare @dialog_id uniqueidentifier
    declare @message_body xml
    declare @amount int;
    declare @title nvarchar(128);

receive
        @dialog_id = conversation_handle,
        @message_body = message_body
    from [dbo].[Inventory queue]

print 'handle is' + cast(@dialog_id as nvarchar(90))
    print 'message body is' + cast(@message_body as  nvarchar(max) )
    if(@dialog_id is not null)
    begin
        set @amount = @message_body.value('(/InventoryUpdate/Quantity)[1]','int');
        set @title = @message_body.value('(/InventoryUpdate/TitleId)[1]','nvarchar(100)');
        print 'a:'+cast(@amount as nvarchar(100))
        print 'b:'+@title;

Update inventory set Quantity = @amount where TitleId = @title;
        end
        end conversation @dialog_id;
    commit transaction;

操作成功后再去查询inventory queue的表 犹豫里面的数据已经被receive 出来 就为空了。

数据同时被更新了

step 5: 接下来做个自动监听功能,只要有信息发送到队列,相关队列,就可以自动执行功能.

首先建立个存储过程,(把receive 中的那段代码拿过来就可以了)


代码如下:

use Inventory
go
--create procedure to receive message and update table
create proc InventoryProc as

begin transaction
    declare @dialog_id uniqueidentifier
    declare @message_body xml
    declare @amount int;
    declare @title nvarchar(128);

waitfor(
    receive
        @dialog_id = conversation_handle,
        @message_body = message_body
    from [dbo].[Inventory queue]),timeout 5000;

print 'handle is' + cast(@dialog_id as nvarchar(90))
    print 'message body is' + cast(@message_body as  nvarchar(max) )
    if(@dialog_id is not null)
    begin
        set @amount = @message_body.value('(/InventoryUpdate/Quantity)[1]','int');
        set @title = @message_body.value('(/InventoryUpdate/TitleId)[1]','nvarchar(100)');
        print 'a:'+cast(@amount as nvarchar(100))
        print 'b:'+@title;

Update inventory set Quantity = @amount where TitleId = @title;
        end
        end conversation @dialog_id;
    commit transaction;
    go

队列监听


代码如下:

alter queue [inventory queue]
        with activation(
            status = on,
            procedure_name=    InventoryProc,
            max_queue_readers=2,
            execute as self
        );

go

完成后,只要发送队列信息后,就可以了

PS: 我们定义了 两个队列 还有个 inventory client queue

这个队列保存的是成功或者error 提示。用receive 方法也可以提取出来。


代码如下:

select message_type_name from [Inventory client queue]

以上的 message type  service 等信息   如图所示,都在这里.

以上是SSB的入门实例,以后会再写一篇实际应用上的(以上的sql code 都是纯手工输入,可能还存在错误(虽然校验了两遍),如果发生错误,对不起大家了。)

(0)

相关推荐

  • SSB(SQLservice Service Broker) 入门实例介绍

    step 1:perpar database & data 复制代码 代码如下: use mastergoCreate database Inventorygouse InventorygoCreate table inventory(    TitleId nvarchar(6) not null,    Quantity int not null,    primary key (TitleId,Quantity));go insert inventory values ('pc1001',

  • Docker Swarm入门实例详解

    Swarm 在 Docker 1.12 版本之前属于一个独立的项目,在 Docker 1.12 版本发布之后,该项目合并到了 Docker 中,成为 Docker 的一个子命令.目前,Swarm 是 Docker 社区提供的唯一一个原生支持 Docker 集群管理的工具.它可以把多个 Docker 主机组成的系统转换为单一的虚拟 Docker 主机,使得容器可以组成跨主机的子网网络. 1. Swarm 认识 Swarm 是目前 Docker 官方唯一指定(绑定)的集群管理工具.Docker 1.

  • hibernate4快速入门实例详解

    Hibernate是什么 Hibernate是一个轻量级的ORMapping框架 ORMapping原理(Object RelationalMapping) ORMapping基本对应规则: 1:类跟表相对应 2:类的属性跟表的字段相对应 3:类的实例与表中具体的一条记录相对应 4:一个类可以对应多个表,一个表也可以对应对个类 5:DB中的表可以没有主键,但是Object中必须设置主键字段 6:DB中表与表之间的关系(如:外键)映射成为Object之间的关系 7:Object中属性的个数和名称可

  • spring boot + jpa + kotlin入门实例详解

    spring boot +jpa的文章网络上已经有不少,这里主要补充一下用kotlin来做. kotlin里面的data class来创建entity可以帮助我们减少不少的代码,比如现在这个User的Entity,这是Java版本的: @Entity public class User { @Id @GeneratedValue(strategy = GenerationType.AUTO) private long id; private String firstName; private S

  • Vue.js快速入门实例教程

    什么是vue vue是法语中视图的意思,Vue.js是一个轻巧.高性能.可组件化的MVVM库,同时拥有非常容易上手的API. 一.基本结构 index.html代码: <script src="../vue.js"></script> <div id="app"> {{ message }} </div> <script src="app.js"></script> <

  • jquery validate.js表单验证入门实例(附源码)

    小编上网查阅了许多关于jquery.validate的文章,大部门只是介绍它的api和用法,没有一个详细的的入门案例介绍,研究了半天还是无从下手.为此,小编自己做了一个jquery validate.js表单验证入门实例,写的不是特别好,但应该适用于初学者,分享给大家. 以下是validate.js表单验证入门实例参考源码,文章下面有源码下载地址: <html> <head> <meta http-equiv="Content-Type" content=

  • SpringMVC入门实例

    1介绍 MVC框架是什么 MVC全名是Model View Controller,是模型(model)-视图(view)-控制器(controller)的缩写,一种软件设计典范,用一种业务逻辑.数据.界面显示分离的方法组织代码,将业务逻辑聚集到一个部件里面,在改进和个性化定制界面及用户交互的同时,不需要重新编写业务逻辑.MVC被独特的发展起来用于映射传统的输入.处理和输出功能在一个逻辑的图形化用户界面的结构中. 模型-视图-控制器(MVC)是一个众所周知的以设计界面应用程序为基础的设计模式.它主

  • Android7.0指纹服务FingerprintService实例介绍

    指纹服务是Android系统中一个较为简单的服务(相比于AMS,WMS等),也比较独立,功能上包括几点 指纹的录入与删除 指纹认证 指纹的安全策略(错误次数判定) 和其他的system service 一样,应用程序通过FingerprintManager实现与FingerprintService的通信,除了上面所说的功能之外,FingerprintManager提供了一些别的的接口,重要的接口都会要求系统级别的权限,并且也不是公开的api(指纹的录入,删除,重命名,重置错误计数等) /** *

  • Spring Boot jpa Service层代码实例

    这篇文章主要介绍了Spring Boot jpa Service层代码实例,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下 package com.fei.service.impl; import java.util.ArrayList; import java.util.List; import javax.persistence.criteria.CriteriaBuilder; import javax.persistence.criter

  • 10个python爬虫入门实例(小结)

    昨天带伙伴萌学习python爬虫,准备了几个简单的入门实例 涉及主要知识点: web是如何交互的 requests库的get.post函数的应用 response对象的相关函数,属性 python文件的打开,保存 代码中给出了注释,并且可以直接运行哦 如何安装requests库(安装好python的朋友可以直接参考,没有的,建议先装一哈python环境) windows用户,Linux用户几乎一样: 打开cmd输入以下命令即可,如果python的环境在C盘的目录,会提示权限不够,只需以管理员方式

随机推荐