STOMP Objective-C 客户端 for iOS
StompKit 是对 objc-stomp 的重写,用于创建一个使用 ARC,Grand Central Dispatch 和 blocks 的现代事件驱动 Objective-C 库。
此库使用 CocoaAsyncSocket 的 Grand Central Dispatch 版本。
将 GCDAsynSocket.{h,m} 和 StompKit.{h,m} 添加到您的项目中。
导入 StompKit.h
头文件
#import "StompKit.h"
发送消息
// create the client
STOMPClient *client = [[STOMPClient alloc] initWithHost:@"localhost"
port:61613];
// connect to the broker
[client connectWithLogin:@"mylogin"
passcode:@"mypassword"
completionHandler:^(STOMPFrame *_, NSError *error) {
if (err) {
NSLog(@"%@", error);
return;
}
// send a message
[client sendTo:@"/queue/myqueue" body:@"Hello, iOS!"];
// and disconnect
[client disconnect];
}];
订阅接收消息
// create the client
STOMPClient *client = [[STOMPClient alloc] initWithHost:@"localhost"
port:61613];
// connect to the broker
[client connectWithLogin:@"mylogin"
passcode:@"mypassword"
completionHandler:^(STOMPFrame *_, NSError *error) {
if (err) {
NSLog(@"%@", error);
return;
}
// subscribe to the destination
[client subscribeTo:@"/queue/myqueue"
headers:@{@"selector": @"color = 'red'"}
messageHandler:^(STOMPMessage *message) {
// callback when the client receive a message
// for the /queue/myqueue destination
NSLog(@"got message %@", message.body); // => "Hello, iOS"
}];
}];