MqttFramework.h
#import <Foundation/Foundation.h>
#import "MQTTClient.h"
#import "BusinessModuleProtocol.h"
#import "BusinessFramework.h"
#import "AppDelegate.h"
@interface MqttFramework : NSObject<MQTTDelegate,BusinessModuleProtocol>
{
BusinessFramework *businessFrameworks_;
}
/**
* @brief 单例模式的设置
*
* @param [in] N/A
* @param [out] N/A
* @return void
* @note
*/
+(MqttFramework *)getMQttFrameInstance;
/**
* @brief 给mqtt服务器发送消息 暂时未做使用 待扩展
*
* @param [in] N/A
* @param [out] N/A
* @return void
* @note
*/
+(void)publishMessage:(NSString *)message withTopicType:(NSString *)topicType;
/**
* @brief 请求的结果处理
*
* @param [in] N/A
* @param [out] N/A
* @return void
* @note
*/
-(void)requestResult:(NSString *)topic withData:(id)resultData;
/**
* @brief 定义mqtt消息主题
*
* @param [in] N/A
* @param [out] N/A
* @return void
* @note
*/
-(void)productTheme:(NSString *)theme;
/**
* @brief 重连mqtt服务器
*
* @param [in] N/A
* @param [out] N/A
* @return void
* @note
*/
-(void)reconnectMqtt;
@end
MqttFramework.m
#import "MqttFramework.h"
#import "MQTTClient.h"
#import "XmlAdept.h"
#import "ASIFormDataRequest.h"
@implementation MqttFramework
/**
* @brief 得到模块控制器的句柄单例
*
* @param [in] N/A
* @param [out] N/A
* @return void
* @note
*/
static MqttFramework *mqttInstance = nil;
+(MqttFramework*)getMQttFrameInstance
{
@synchronized(self)
{
if(mqttInstance==nil)
{
mqttInstance=[[self alloc]init];
}
}
return mqttInstance;
}
#pragma --mark BusinessModuleProtocol delegate
- (int)initBusinessModule:(BusinessModuleInfo*)info
{
info.businessModuleIdEX = @"MqttFrameWork";//
businessFrameworks_ = info.businessFramework;
return 0;
}
- (int)callBusinessProcessEX:(NSString *)capabilityId withMessageType:(NSString *)MessageType WithMessage:(id)messageVector
{
NSLog(@"capabilityId = %@ topic = %@ messageVector = %@",capabilityId,MessageType,messageVector);
AppDelegate *app = (AppDelegate *)[[UIApplication sharedApplication] delegate];
MQTTClient *mosq = [app mosquittoClient];
// [mosq setHost:Mqtt_URL];
// [mosq connect];
// [mosq subscribe:@"nanode/red_led"];
// [mosq subscribe:@"nanode/green_led"];
// [mosq subscribe:@"iCombo"];
// [mosq subscribe:@"iPhone"];
//1.组装xml工作
//2.发送请求消息
//在此正式调用mqtt请求
NSString *sendStr = [[NSString alloc] initWithData:[XmlAdept makeMqttXML:MessageType withDictionary:(NSDictionary *)messageVector] encoding:NSUTF8StringEncoding];
// /****************去掉最后换行符********************/
int index = sendStr.length-1;
sendStr = [sendStr substringToIndex:index];
// /*********************end*************************/
// ASIFormDataRequest *formDataRequest = [ASIFormDataRequest requestWithURL:nil];
//NSString *messageEx = [formDataRequest encodeURL:sendStr];
// NSString *messageEx = [formDataRequest encodeURL:@"我家"];
//[mosq publishString:sendStr toTopic:@"iCombo" retain:YES];
// NSLog(@"%@",messageEx);
NSString *string = [NSString stringWithFormat:@"**%@**",sendStr];
NSLog(@"senderMesg = %@",string);
[mosq publishString:sendStr toTopic:@"iCombo" retain:NO];
return 0;
}
-(void)requestResult:(NSString *)topic withData:(id)resultData
{
NSLog(@"发送业务广播 给监听者");
[businessFrameworks_ broadcastBusinessNotifyEX:topic withInParam:resultData];
}
/**
* @brief 定义mqtt消息主题
*
* @param [in] N/A
* @param [out] N/A
* @return void
* @note
*/
-(void)productTheme:(NSString *)theme
{
AppDelegate *app = (AppDelegate *)[[UIApplication sharedApplication] delegate];
MQTTClient *mosq = [app mosquittoClient];
NSUserDefaults *ud = [NSUserDefaults standardUserDefaults];
if ([[ud objectForKey:@"host"] isEqualToString:@"no"])
{
[mosq setHost:Mqtt_URL];
}
else
{
[mosq setHost:[ud stringForKey:@"host"]];
}
//[mosq setHost:Mqtt_URL];
[mosq connect];
[mosq subscribe:theme];
}
/**
* @brief 重连mqtt服务器
*
* @param [in] N/A
* @param [out] N/A
* @return void
* @note
*/
-(void)reconnectMqtt
{
AppDelegate *app = (AppDelegate *)[[UIApplication sharedApplication] delegate];
MQTTClient *mosq = [app mosquittoClient];
NSUserDefaults *ud = [NSUserDefaults standardUserDefaults];
if ([ud stringForKey:@"host"])
{
[mosq setHost:[ud stringForKey:@"host"]];
}
else
{
[mosq setHost:Mqtt_URL];
}
[mosq reconnect];
}
#pragma --mark mosquittoclientDelegate
- (void) didConnect:(NSUInteger)code
{
if (code == 0)
{
NSLog(@"连接本地mosquito代理服务器返回码为:%d 连接mqtt成功",code);
}
else
{
NSLog(@"连接Mqtt服务器失败");
}
}
- (void) didDisconnect
{
NSLog(@"mqtt disconnect!");
}
//处理各个主题对应的message
- (void) didReceiveMessage: (NSString*)message topic:(NSString*)topic
{
NSLog(@"%@ => %@", topic, message);
//deal with diffrent message here:
//if else 分支处理
//1.xml的解析工作
//将收到的消息处理后然后广播出去 接收者会根据主题处理自己的业务
NSArray *resultArr = [[NSArray alloc]initWithObjects:message, nil];
NSArray *list = [XmlAdept mqttParseMessageNode:resultArr];
NSString *type = [[list objectAtIndex:0] objectForKey:@"type"];
[self requestResult:type withData:list];
}
//publish后回调的messageId
- (void) didPublish: (NSUInteger)messageId
{
NSLog(@"send messageId = %d",messageId);
}
//定制一个主题
- (void) didSubscribe: (NSUInteger)messageId grantedQos:(NSArray*)qos
{
NSLog(@"messageId = %d grantedQos = %@",messageId,qos);
}
//取消一个主题
- (void) didUnsubscribe: (NSUInteger)messageId
{
NSLog(@"unsubscibe messageId = %d",messageId);
}
/**
* @brief 给mqtt服务器发送消息 对外接口
*
* @param [in] N/A
* @param [out] N/A
* @return void
* @note
*/
+(void)publishMessage:(NSString *)message withTopicType:(NSString *)topicType
{
AppDelegate *app = (AppDelegate *)[[UIApplication sharedApplication] delegate];
MQTTClient *mosq = [app mosquittoClient];
[mosq publishString:message toTopic:topicType retain:NO]; //消息的retain类型设置为NO让其不在消息缓冲池中保留
}
-(void)dealloc
{
[super dealloc];
}
@end
原文地址：http://blog.csdn.net/cerastes/article/details/37504877
