最近，项目中使用到了ActiveMQ获取第三方推送过来的数据。具体背景是：公司需要监控全国各地车辆实时运行的GPS数据，但监控本身不是公司做的，而是交给第三方公司做，第三方采集GPS数据后推送给我们。全国各地，近万台车辆，每台车辆每隔几秒就发送一次GPS位置数据，如果我们提供API给第三方公司去调用，显然无论是第三方还是我们这边，服务器都是是扛不住的，这么做也是不合理的，于是，便采取了消息队列，第三方采集到的数据直接推送到消息队列代理服务器，而己方从消息队列服务器取数据处理。以下对项目实践及其中遇到的一些问题及解决进行概要总结。
1、ActiveMQ NMS简介
关于NMS，这里主要谈两点。
NMS API：ActiveMQ定义的一套API接口规范，你可以理解为一个API的接口，它指明了生产者或消费者如何与消息队列服务器通信。
NMS Providers：NMS API的具体实现，基于Windows或ActiveMQ下的各种协议，提供了各种实现，目前提供了ActiveMQ、STOMP、MSMQ、EMS、WCF、AMQP、MQTT、XMS几种实现。具体项目中，我采取的是ActiveMQ实现。
至于消息队列涉及到的其他概念，什么Broker、Queue、Topic、Producer、Consumer，这里不做介绍，各位可以自己查资料，这些 概念本身也不难理解的。
2、关于异常下的Broker重连
这个异常，可能是由于网络异常，也可能是长时间没有通信，Broker把Client给断掉了，不去管它。起初，这个项目是从一位离职员工的手头接过来的，给的说法是只需要维护就够了，基本上不用调整。当时虽然说是做了重连，后来发现，就跟没做一样。发现这个，是起源于第三方频繁通知，MQ队列有积压，通知我们尽快处理。项目拿到手一看，我勒个去，直接起了一个Timer在那儿定时监控Connection状态，如果状态不对立刻重新打开连接。先不说Socket连接的浪费情况，及Timer这个.NET中近乎Bug的一个东西，这种做法实际中行之无效，因为连接异常情况
延伸阅读
- ssh框架 2016-09-30
- 阿里移动安全 [无线安全]玩转无线电——不安全的蓝牙锁 2017-07-26
- 消息队列NetMQ 原理分析4-Socket、Session、Option和Pipe 2024-03-26
- Selective Search for Object Recognition 论文笔记【图片目标分割】 2017-07-26
- 词向量-LRWE模型-更好地识别反义词同义词 2017-07-26
- 从栈不平衡问题 理解 calling convention 2017-07-26
- php imagemagick 处理 图片剪切、压缩、合并、插入文本、背景色透明 2017-07-26
- Swift实现JSON转Model - HandyJSON使用讲解 2017-07-26
- 阿里移动安全 Android端恶意锁屏勒索应用分析 2017-07-26
- 集合结合数据结构来看看(二) 2017-07-26
学习是年轻人改变自己的最好方式