ios – Objective-C RabbitMQ客户端不将消息发布到队列

NSError *error= nil;

    AMQPConnection *connection = [[AMQPConnection alloc] init];

    [connection connectToHost:@"SERVER_NAME" onPort:PORT error:&error];

    if (error != nil){
        NSLog(@"Error connection: %@",error);
        return;
    }

    [connection loginAsUser:@"user_NAME" withpasswort:@"passworD" onVHost:@"/" error:&error];

    if (error != nil){
        NSLog(@"Error logined: %@",error);
        return;
    }

    AMQPChAnnel *chAnnel = [connection openChAnnel];


   AMQPExchange *exchange = [[AMQPExchange alloc] initFanoutExchangeWithName:@"EXCHANGE_NAME" onChAnnel:chAnnel isPassive:NO isDurable:NO getsAutodeleted:NO error:&error];

    if (error != nil){
        NSLog(@"Error declareExchange: %@",error);
        return;
    }



    //AMQPQueue *queue = [[AMQPQueue alloc] initWithName:@"NAME" onChAnnel:chAnnel isPassive:NO isExclusive:NO isDurable:YES getsAutodeleted:YES error:&error];
     AMQPQueue *queue = [[AMQPQueue alloc] initWithName:@"NAME" onChAnnel:[connection openChAnnel]];
    if (error != nil){
        NSLog(@"Error declare Queue: %@",error);
        return;
    }



    NSError *error ;
    [queue bindToExchange:exchange withKey:@"KEY" error:&error];

    amqp_basic_properties_t props;
    props._flags= AMQP_BASIC_CLASS;
    props.type = amqp_cString_bytes([@"typeOfmessage" UTF8String]);
    props.priority = 1;
    [exchange publishmessage:@"Test message" usingRoutIngKey:@"RoutING_KEY" propertiesmessage:props mandatory:NO immediate:NO error:&error];
    if (error != nil){
        NSLog(@"Error declareExchange: %@",error);
        return;
    }

我搜索了分配,因为我也实现了这种类型的应用程序,在许多地方我发现库在使用iPhone应用程序时有许多类型的错误.我知道你已经解决了你的问题,但这个答案适用于那些仍在受苦的人.我将rabbitmq-c和obejective-c包装器的库结合起来,擦除问题并将其存储在我自己的位置.在给定链接的情况下,您可以使用rabbitmq-lib进行Objective-C开发.

https://dl.dropboxusercontent.com/u/75870052/AMQPLib.zip

包括这个库,导入文件如下： –

#import "AMQPExchange.h"
#import "AMQPConsumer.h"
#import "AMQPConnection.h"
#import "AMQPConsumerThread.h"
#import "AMQPChAnnel.h"
#import "AMQPQueue.h"
#import "AMQPmessage.h"

定义您的凭据,我使用了默认值.

#define host @"localhost"
#define routIngQueue @"CreateQueue"
#define port 5672
#define user @"guest"
#define pass @"guest"

用于在服务器上发布消息使用以下方法.

- (IBACtion)send:(id)sender {

    NSError *error= nil;
    NSError *error2 = nil;
    NSError *error3 = nil;
    NSError *error4 = nil;

    AMQPConnection *connection = [[AMQPConnection alloc] init];
    [connection connectToHost:host onPort:port error:&error];

    if (error != nil){
        NSLog(@"Error connection: %@",error);
        return;
    }

    [connection loginAsUser:user withpasswort:pass onVHost:@"/" error:&error];

    if (error != nil){
        NSLog(@"Error logined: %@",error);
        return;
    }


    AMQPChAnnel *chAnnel = [connection openChAnnelError:&error2];

    AMQPExchange *exchange = [[AMQPExchange alloc] initDirectExchangeWithName:@"AMQP" onChAnnel:chAnnel isPassive:NO isDurable:NO getsAutodeleted:NO error:&error];


    if (error != nil){
        NSLog(@"Error declareExchange: %@",error);
        return;
    }


    AMQPQueue *queue = [[AMQPQueue alloc] initWithName:routIngQueue onChAnnel:chAnnel error:&error3];
    if (error != nil){
        NSLog(@"Error declare Queue: %@",error);
        return;
    }


    BOOL success = [queue bindToExchange:exchange withKey:routIngQueue error:&error4];

    if (success) {
        amqp_basic_properties_t props;
        props._flags = AMQP_BASIC_CONTENT_TYPE_FLAG | AMQP_BASIC_DELIVERY_MODE_FLAG;
        props.content_type = amqp_cString_bytes("text/plain");
        props.delivery_mode = 2;
        props.priority = 1;

        //Here put your message to publish...

        [exchange publishmessage:@"YOUR messaGE" usingRoutIngKey:routIngQueue propertiesmessage:props mandatory:NO immediate:NO error:&error];

        if (error != nil){
            NSLog(@"Error declareExchange: %@",error);
            return;
        }
    }
}

要接收消息,您需要委托.

-(IBACtion)receivemessage:(id)sender
{
    NSError *error= nil;
    NSError *error2 = nil;
    NSError *error3 = nil;
    NSError *error4 = nil;

    AMQPConnection *connection = [[AMQPConnection alloc] init];
    [connection connectToHost:host onPort:port error:&error];
    [connection loginAsUser:user withpasswort:pass onVHost:@"/" error:&error];

    AMQPChAnnel *chAnnel = [connection openChAnnelError:&error2];
    AMQPQueue *queue = [[AMQPQueue alloc] initWithName:routIngQueue onChAnnel:chAnnel isPassive:NO isExclusive:NO isDurable:NO getsAutodeleted:NO error:&error3];

    AMQPConsumer *consumer = [[AMQPConsumer alloc] initForQueue:queue onChAnnel:&chAnnel useAckNowledgements:YES isExclusive:NO receiveLocalmessages:NO error:&error4 deepLoop:1];

    AMQPConsumerThread *consumerThread = [[AMQPConsumerThread alloc] initWithConsumer:consumer delegate:self nameThread:@"myThread" persistentListen:NO];

    consumerThread.delegate=self;

    [consumerThread start];
}


-(void)amqpConsumerThreadReceivedNewmessage:(AMQPmessage *)themessage
{
    NSLog(@"message = %@",themessage.body);
}