this is a dot net client and a windows server for rocketmq(rocket mq的c#客户端和windows服务端)
alibaba-rocketmq-4.2是rocket-mq windows服务器软件
client-ikvm-4.2为rocket-mq c#客户端dll
DefaultMQPushConsumer consumer = new DefaultMQPushConsumer();
consumer.setNamesrvAddr(nameAddress);
consumer.subscribe(t, "*");
consumer.setConsumeFromWhere(ConsumeFromWhere.CONSUME_FROM_FIRST_OFFSET);
consumer.setConsumerGroup(group);
if (port > 0) { consumer.setClientPort(port); }
consumer.registerMessageListener(new ChainwayMessageListener());
consumer.start();
public class ChainwayMessageListener : MessageListenerConcurrently
{
public ConsumeConcurrentlyStatus consumeMessage(List l, ConsumeConcurrentlyContext ccc)
{
//业务代码
}
}
DefaultMQProducer producer = new DefaultMQProducer(group);
producer.setNamesrvAddr(nameAddress);
if (port > 0) producer.setClientPort(port)
producer.start();