Skip to content

H
hel-developer-guide
Commit 4d61dbb3 authored by custom's avatar custom
Browse files
Options

Conflict resolution

parents 33c426b2 1742901e
Hide whitespace changes
Inline Side-by-side
Showing with 283 additions and 258 deletions
前端组件/hlsDataSource.md
View file @ 4d61dbb3
# hlsDataSource标签
数据源组件hlsDataSource
* ```
<h:hlsDataSource id="hlsDataSource" autoQuery="true" successEnd="successEnd">
<h:transport parameter="parameter">
<h:read url="" type="GET" />
</h:transport>
</h:hlsDataSource>
```
| ** 属性** | **参数** | **说明** |
| --- | --- | --- |
| id | 唯一英文标识 | 数据源唯一标志，返回数据源对象，包含查询返回的数据 |
| autoQuery | true\/false | 自动查询标志，默认为true，true代表自动发送查询请求，false代表不发送查询请求 |
| successEnd | function | 异步请求成功的回调函数，参数:data\(查询返回的数据\) |
| parameter | function | 函数返回一个对象，会自动封装到查询条件中 |
| url | 查询字符串 | 查询字符串，对应后台的数据接口 |
| type | GET\/POST | 对应发送GET请求跟POST请求 |
前端组件/hlsMaskedTextBox.md
View file @ 4d61dbb3
...@@ -12,7 +12,7 @@ ...@@ -12,7 +12,7 @@
#### **一般属性** #### **一般属性**
> **提示:** > **提示:**
> >
> * 属性用法请参考kendoui API文档的maskedTextBox:[http:\/\/docs.telerik.com\/kendo-ui\/api\/javascript\/ui\/maskedtextbox](http://docs.telerik.com/kendo-ui/api/javascript/ui/maskedtextbox) > * 属性用法请参考kendoui API文档的maskedTextBox:[http:\/\/docs.telerik.com\/kendo-ui\/api\/javascript\/ui\/maskedtextbox](http://docs.telerik.com/kendo-ui/api/javascript/ui/maskedtextbox)
| 属性名 | 类型 | | 属性名 | 类型 |
...@@ -37,7 +37,7 @@ ...@@ -37,7 +37,7 @@
``` ```
> **提示:** > **提示:**
> >
> * 上述所有属性直接添加在标签内即可，（**\[\*\***属性名\]**\*\* = "..."**） > * 上述所有属性直接添加在标签内即可，（**\[\*\***属性名\]**\*\* = "..."**）
#### **子标签** #### **子标签**
...@@ -59,6 +59,8 @@ function rules(){ ...@@ -59,6 +59,8 @@ function rules(){
``` ```
> **提示**： > **提示**：
> >
> * 遇到**object**类型 就向下添加子标签，当遇到普通类型时，就添加到当前的标签上。 > * 遇到**object**类型 就向下添加子标签，当遇到普通类型时，就添加到当前的标签上。
后端开发/消息机制.md
View file @ 4d61dbb3
# 消息系统 # 消息系统
## 1.简介 ## 1.简介
融租易 的消息系统提供`唯一`和`广播`以及`主题`三种模式，实现方式为 RabbitMQ。 融租易 的消息系统提供`唯一`和`广播`以及`主题`三种模式，实现方式为 RabbitMQ。
### 1.1 RabbitMQ介绍 ### 1.1 RabbitMQ介绍
RabbitMQ 是实现 AMQP（高级消息队列协议）的消息中间件的一种，用于在分布式系统中存储转发消息，在易用性、扩展性、高可用性等方面表现不俗。消息中间件主要用于组件之间的解耦。rabbitmq多应用于批量数据异步处理、并行任务串行化，高负载任务的负载均衡等 重量级，高并发，异步高可靠性场景。 RabbitMQ 是实现 AMQP（高级消息队列协议）的消息中间件的一种，用于在分布式系统中存储转发消息，在易用性、扩展性、高可用性等方面表现不俗。消息中间件主要用于组件之间的解耦。rabbitmq多应用于批量数据异步处理、并行任务串行化，高负载任务的负载均衡等 重量级，高并发，异步高可靠性场景。
### 1.2 配置rabbit ### 1.2 配置rabbit
（1）用户要先在 `applicationContext-rabbitmq.xml` 中 添加`<beans:import resource="rabbitmq.xml"/>`。 （1）用户要先在 `applicationContext-rabbitmq.xml` 中 添加`<beans:import resource="rabbitmq.xml"/>`。
（2）然后在`config.properties`中自行添加mq相关的配置如图： （2）然后在`config.properties`中自行添加mq相关的配置如图：
![](/assets/config.png) ![](/assets/config.png)
## 2 交换机和队列定义 ## 2 交换机和队列定义
在融租易的接口管理的消息队列模块定义功中，提供了自定义队列和交换机的功能，可以根据配置实现自定义的队列和交换机的匹配，避免了在xml中的繁琐配置。 在融租易的接口管理的消息队列模块定义功中，提供了自定义队列和交换机的功能，可以根据配置实现自定义的队列和交换机的匹配，避免了在xml中的繁琐配置。
### 2.1 定义交换机 ### 2.1 定义交换机
在 java 代码中，注入 IMessagePublisher 类。 在 java 代码中，注入 IMessagePublisher 类。
```java ```java
public class XXXSenderTest { public class XXXSenderTest {
@Autowired @Autowired
private IMessagePublisher messagePublisher; private IMessagePublisher messagePublisher;
public void sendMessageTest (){ public void sendMessageTest (){
// 向 队列：queue1 中发送消息 ： message1（字符串） // 向 队列：queue1 中发送消息 ： message1（字符串）
messagePublisher.message("queue1","message1"); messagePublisher.message("queue1","message1");
User user = new User(); User user = new User();
user.setUserName("YJP"); user.setUserName("YJP");
// 向队列：queue2 中发送消息：bean（对象） // 向队列：queue2 中发送消息：bean（对象）
messagePublisher.message("queue2", user); messagePublisher.message("queue2", user);
} }
} }
``` ```
> 之前的 rPush 命令不再推荐使用，改为 message > 之前的 rPush 命令不再推荐使用，改为 message
以上代码示例了如何发送一个消息 以上代码示例了如何发送一个消息
1. 注入 IMessagePublisher 用于发送消息 1. 注入 IMessagePublisher 用于发送消息
2. message 方法执行发送命令，注意 2 个参数的类型 2. message 方法执行发送命令，注意 2 个参数的类型
3. 消息类型是对象的会转换为 json 格式 3. 消息类型是对象的会转换为 json 格式
> 类型的转换是透明的，调用者一般不需要关心 > 类型的转换是透明的，调用者一般不需要关心
### 2.2 监听队列中的消息 ### 2.2 监听队列中的消息
监听队列消息的 java 实现 监听队列消息的 java 实现
```java ```java
@QueueMonitor(queue="queue1") @QueueMonitor(queue="queue1")
public XXXReceiver implements IMessageConsumer<String>{ public XXXReceiver implements IMessageConsumer<String>{
/** /**
* 第一个参数的类型，与 IMessageConsumer 的泛型类型一致 * 第一个参数的类型，与 IMessageConsumer 的泛型类型一致
*/ */
public void onMessage(String message,String queue) { public void onMessage(String message,String queue) {
System.out.println("got message :"+message); System.out.println("got message :"+message);
} }
} }
``` ```
关键点： 关键点：
1. 监听类需要在 Spring 中定义为 bean （也可以通过 @Component 之类的注解自动扫描注册） 1. 监听类需要在 Spring 中定义为 bean （也可以通过 @Component 之类的注解自动扫描注册）
2. 添加注解 QueueMonitor，表示这个类要监听队列 `queue1` 2. 添加注解 QueueMonitor，表示这个类要监听队列 `queue1`
3. 实现接口 IMessageConsumer，指定泛型类型 3. 实现接口 IMessageConsumer，指定泛型类型
如果消息类型是 java bean 对象，比如 1.1章节 例子中 的 User，那么需要实现的接口是IMessageConsumer&lt; User&gt;。 如果消息类型是 java bean 对象，比如 1.1章节 例子中 的 User，那么需要实现的接口是IMessageConsumer&lt; User&gt;。
> 绝大部分时候，都要保证发送的消息类型与接收的类型一致! > 绝大部分时候，都要保证发送的消息类型与接收的类型一致!
## 3 发布/订阅 ## 3 发布/订阅
发布订阅模式的特点是：一个消息会被所有订阅者收到（只会收到一次）。 发布订阅模式的特点是：一个消息会被所有订阅者收到（只会收到一次）。
### 3.1 发布一个消息 ### 3.1 发布一个消息
发布一条消息的 java 代码实例 发布一条消息的 java 代码实例
```java ```java
public class XXXPublisher { public class XXXPublisher {
@Autowired @Autowired
private IMessagePublisher messagePublisher; private IMessagePublisher messagePublisher;
public void publishTest (){ public void publishTest (){
// 向频道 : channel1 发布一个字符串消息 // 向频道 : channel1 发布一个字符串消息
messagePublisher.publish("channel1","message1"); messagePublisher.publish("channel1","message1");
User bean = new User(); User bean = new User();
bean.setUserName("YPP"); bean.setUserName("YPP");
// 向频道：channel2 发布一个 java bean // 向频道：channel2 发布一个 java bean
messagePublisher.publish("channel2",bean); messagePublisher.publish("channel2",bean);
} }
} }
``` ```
基本点，与章节 3.1 类似 基本点，与章节 3.1 类似
1. 注入 IMessagePublisher 1. 注入 IMessagePublisher
2. publish 方法（这个与队列不同！） 2. publish 方法（这个与队列不同！）
3. 支持多种类型 3. 支持多种类型
### 3.2 订阅一个消息 ### 3.2 订阅一个消息
示例 java 类 示例 java 类
```java ```java
@TopicMonitor(channel={"channel1"}) @TopicMonitor(channel={"channel1"})
publish class XXXSubscriber implements IMessageConsumer<String>{ publish class XXXSubscriber implements IMessageConsumer<String>{
public void onMessage(String message,String pattern) { public void onMessage(String message,String pattern) {
System.out.println("onMessage:"+message); System.out.println("onMessage:"+message);
} }
} }
``` ```
基本点，与章节 3.2 类似 基本点，与章节 3.2 类似
1. 添加注解 TopicMonitor，channel是一个数组，可以同时订阅多个频道，需要保证消息类型一致。 1. 添加注解 TopicMonitor，channel是一个数组，可以同时订阅多个频道，需要保证消息类型一致。
2. 实现接口 IMessageConsumer，用于接收消息 2. 实现接口 IMessageConsumer，用于接收消息
这个类需要定义为 Spring bean，或者通过注解自动扫描注册。 这个类需要定义为 Spring bean，或者通过注解自动扫描注册。
## 4.扩展RabbitMQ ## 4.扩展RabbitMQ
若使用框架默认的RabbitMQ不能满足你的需求，你可以通过自定义消息队列满足你的需求。你可以在项目中新建 若使用框架默认的RabbitMQ不能满足你的需求，你可以通过自定义消息队列满足你的需求。你可以在项目中新建
applicationContext-xxx.xml文件（配置如下）。 applicationContext-xxx.xml文件（配置如下）。
### 4.1 获取连接 ### 4.1 获取连接
通过connectionFactory获取与RabbitMQ服务器的连接。你可以再此配置所需**缓存**\(模式，大小\),**virtual-host**\(默认”\/"\)等属性 通过connectionFactory获取与RabbitMQ服务器的连接。你可以再此配置所需**缓存**\(模式，大小\),**virtual-host**\(默认”\/"\)等属性
```xml ```xml
<rabbit:connection-factory id="connectionFactory" host="${rabbitmq.host}" username="${rabbitmq.username}" password="${rabbitmq.password}" port="${rabbitmq.port}"/> <rabbit:connection-factory id="connectionFactory" host="${rabbitmq.host}" username="${rabbitmq.username}" password="${rabbitmq.password}" port="${rabbitmq.port}"/>
``` ```
### 4.2 队列 ### 4.2 队列
hap中队列根据注解动态初始化，默认队列为持久化，广播队列为非持久化。用户也可在xml通过&lt;**rabbit:queue&gt;标签**根据自身需求定义所需的队列属性如：**durable**\( 持久化属性 \),**auto-delete**\(连接关闭后是否删除队列\)**。** hap中队列根据注解动态初始化，默认队列为持久化，广播队列为非持久化。用户也可在xml通过&lt;**rabbit:queue&gt;标签**根据自身需求定义所需的队列属性如：**durable**\( 持久化属性 \),**auto-delete**\(连接关闭后是否删除队列\)**。**
```xml ```xml
<rabbit:queue name="queueTest" durable="true" auto-delete="false"></rabbit:queue> <rabbit:queue name="queueTest" durable="true" auto-delete="false"></rabbit:queue>
``` ```
### 4.3 路由 ### 4.3 路由
rabbitmq主要由3种路由方式**direct\(单播\),topic\(多播\),fanout\(广播\),**rabbitmq会根据使用的路由通过routing-key发送给路由里的队列。路由通过&lt;**rabbit:direct-exchange&gt;**&lt;**rabbit:** **topic-exchange&gt;**&lt;**rabbit:** **fanout-exchange&gt;标签**申明**。** rabbitmq主要由3种路由方式**direct\(单播\),topic\(多播\),fanout\(广播\),**rabbitmq会根据使用的路由通过routing-key发送给路由里的队列。路由通过&lt;**rabbit:direct-exchange&gt;**&lt;**rabbit:** **topic-exchange&gt;**&lt;**rabbit:** **fanout-exchange&gt;标签**申明**。**
### 4.4 绑定路由 ### 4.4 绑定路由
将队列绑定到相应路由，把队列和路由联系起来。由 ** &lt;rabbit:bindings&gt; 标签**声明。（示例如下 将队列绑定到相应路由，把队列和路由联系起来。由 ** &lt;rabbit:bindings&gt; 标签**声明。（示例如下
```xml ```xml
<!-- 定义direct exchange，绑定queueTest --> <!-- 定义direct exchange，绑定queueTest -->
<rabbit:direct-exchange name="exchangeTest" durable="true" auto-delete="false"> <rabbit:direct-exchange name="exchangeTest" durable="true" auto-delete="false">
<rabbit:bindings> <rabbit:bindings>
<rabbit:binding queue="queueTest" key="queueTestKey"></rabbit:binding> <rabbit:binding queue="queueTest" key="queueTestKey"></rabbit:binding>
</rabbit:bindings> </rabbit:bindings>
</rabbit:direct-exchange> </rabbit:direct-exchange>
``` ```
### 4.5 RabbitTemplate ### 4.5 RabbitTemplate
用于发送消息，通过 `rabbit:template` 标签声明，注入bean后可使用convertAndSend等方法发送信息也可使用receiveAndConvert等方法**同步**接受消息。需要参数exchange和 routing-key来确定发往的队列。 可使用自定义的retryTemplate扩展retry机制。 用于发送消息，通过 `rabbit:template` 标签声明，注入bean后可使用convertAndSend等方法发送信息也可使用receiveAndConvert等方法**同步**接受消息。需要参数exchange和 routing-key来确定发往的队列。 可使用自定义的retryTemplate扩展retry机制。
```xml ```xml
!--定义rabbit template用于数据的接收和发送 --> !--定义rabbit template用于数据的接收和发送 -->
<rabbit:template id="amqpTemplate" connection-factory="connectionFactory" <rabbit:template id="amqpTemplate" connection-factory="connectionFactory"
routing-key="queueTestKey" exchange="exchangeTest"/> routing-key="queueTestKey" exchange="exchangeTest"/>
``` ```
### 5.6 监听队列（异步接收消息） ### 5.6 监听队列（异步接收消息）
通过container容易声明监听，在容器中配置监听所需队列名称和监听的方法messageRciver 通过container容易声明监听，在容器中配置监听所需队列名称和监听的方法messageRciver
```xml ```xml
<rabbit:listener-container <rabbit:listener-container
connection-factory="connectionFactory"> connection-factory="connectionFactory">
<rabbit:listener queues="queueTest" ref="messageReceiver" /> <rabbit:listener queues="queueTest" ref="messageReceiver" />
</rabbit:listener-container> </rabbit:listener-container>
<bean id="messageRecevicer" ref="com.hand.hap.QueueListenter"> <bean id="messageRecevicer" ref="com.hand.hap.QueueListenter">
``` ```
队列监听java类 队列监听java类
```java ```java
public class QueueListenter implements MessageListener { public class QueueListenter implements MessageListener {
@Override @Override
public void onMessage(Message msg) { public void onMessage(Message msg) {
//相关业务处理 //相关业务处理
} }
} }
``` ```
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment