# RocketMQ-Client

**Repository Path**: leefafa/RocketMQ-Client

## Basic Information

- **Project Name**: RocketMQ-Client
- **Description**: RocketMQ-Client For .Net
- **Primary Language**: C#
- **License**: Not specified
- **Default Branch**: master
- **Homepage**: None
- **GVP Project**: No

## Statistics

- **Stars**: 1
- **Forks**: 0
- **Created**: 2021-07-13
- **Last Updated**: 2022-08-22

## Categories & Tags

**Categories**: Uncategorized

**Tags**: None

## README

# RocketMQ-Client
<p>this is a dot net client and a windows server for rocketmq（rocket mq的c#客户端和windows服务端）</p>

<p>alibaba-rocketmq-4.2是rocket-mq windows服务器软件</p>
<p>client-ikvm-4.2为rocket-mq c#客户端dll</p>

### 启动推送型消费者
```
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();`
### 建议使用jdk1.8
### 建议使用已经封装过的ChainwayMQ
https://github.com/franknew/DataSync