# finder-mq

**Repository Path**: ifinder/finder-mq

## Basic Information

- **Project Name**: finder-mq
- **Description**: support reconnect and tls
- **Primary Language**: Java
- **License**: Not specified
- **Default Branch**: master
- **Homepage**: None
- **GVP Project**: No

## Statistics

- **Stars**: 0
- **Forks**: 0
- **Created**: 2018-09-15
- **Last Updated**: 2022-06-24

## Categories & Tags

**Categories**: Uncategorized

**Tags**: None

## README

# finder-mq

#### 项目介绍
finder-mq

#### 软件架构
软件架构说明


#### 安装教程

1. xxxx
2. xxxx
3. xxxx

#### 使用说明

1. 


 
 <!---------------->
 <bean id="sslParam" class="cn.finder.mq.SslParam">
 		<property name="caPath" value="D:\\study\\mqtt\\emq\\cacert.crt"/>
 		<property name="crtPath" value="D:\\study\\mqtt\\emq\\client-cert.crt"/>
 		<property name="keyPath" value="D:\\study\\mqtt\\emq\\client-key-pkcs8.pem"/>
 		<property name="password" value="mypass"/>
 	</bean>
  	<bean id="finderMqttClient" class="cn.finder.mq.FinderMqttClient"  init-method="initConnect">
  		<constructor-arg index="0" value="client-1"/>
  		<constructor-arg index="1" value="ssl://push.xxxxxx:8883"/>
  		
  		<property name="userName" value="client-1"/>
  		<property name="password" value="client-1"/>
  		<property name="cleanSession" value="false"/>
  		<property name="reconnectWithStart" value="true"/>
  		<property name="sslParam" ref="sslParam"/>
  		<property name="callback" ref="msgCallBack"/>
  		
  	</bean>
	 
	 <bean id="msgCallBack" class="com.xxx.MsgCallBack">
	 	<constructor-arg index="0" ref="finderMqttClient"/>
	 </bean>


在servlet中可以加入启动订阅

FinderMqttClient finderMqttClient= AppApplicationContextUtil.getContext().getBean("finderMqttClient", FinderMqttClient.class);
	
	String[] topics;
	
	@Override
	public void init(ServletConfig servletConfig) throws ServletException {

		String enabled = servletConfig.getInitParameter("enabled");
		
		
		if("true".equalsIgnoreCase(enabled)){
			logger.info("MessageServlet.init  starting....  ");
			
			topics=servletConfig.getInitParameter("subscribe").split(",");
			
			if(topics.length>0){
				try {
					finderMqttClient.subscribe(topics);
				} catch (MqttException e) {
					logger.info(e);
				}
			}
			
			
			//doSubscribe();
		}
		
		
	
	}


2. xxxx
3. xxxx

#### 参与贡献

1. Fork 本项目
2. 新建 Feat_xxx 分支
3. 提交代码
4. 新建 Pull Request


#### 码云特技

1. 使用 Readme\_XXX.md 来支持不同的语言，例如 Readme\_en.md, Readme\_zh.md
2. 码云官方博客 [blog.gitee.com](https://blog.gitee.com)
3. 你可以 [https://gitee.com/explore](https://gitee.com/explore) 这个地址来了解码云上的优秀开源项目
4. [GVP](https://gitee.com/gvp) 全称是码云最有价值开源项目，是码云综合评定出的优秀开源项目
5. 码云官方提供的使用手册 [https://gitee.com/help](https://gitee.com/help)
6. 码云封面人物是一档用来展示码云会员风采的栏目 [https://gitee.com/gitee-stars/](https://gitee.com/gitee-stars/)