# Rocketmq.Client

**Repository Path**: ymjake/rocketmq-client-csharp

## Basic Information

- **Project Name**: Rocketmq.Client
- **Description**: Apache RocketMQ Client
- **Primary Language**: Unknown
- **License**: Apache-2.0
- **Default Branch**: master
- **Homepage**: None
- **GVP Project**: No

## Statistics

- **Stars**: 0
- **Forks**: 0
- **Created**: 2025-11-16
- **Last Updated**: 2026-02-13

## Categories & Tags

**Categories**: Uncategorized

**Tags**: None

## README

# RocketMQ C# Client with FIFO Accelerator

[![License](https://img.shields.io/badge/license-Apache%202-4EB1BA.svg)](https://www.apache.org/licenses/LICENSE-2.0.html)
[![NuGet](https://img.shields.io/nuget/v/YMJake.RocketMQ.Client.svg)](https://www.nuget.org/packages/YMJake.RocketMQ.Client/)

Enhanced C# client for Apache RocketMQ 5.x with full feature support and FIFO Consume Accelerator.

## Features

All official RocketMQ 5.x C# features are fully implemented:

- ✅ Producer with standard messages
- ✅ Producer with FIFO messages
- ✅ Producer with timed/delay messages
- ✅ Producer with transactional messages
- ✅ Producer with recalling timed/delay messages
- ✅ Simple consumer (pull mode with `Receive()`)
- ✅ Push consumer with concurrent message listener
- ✅ Push consumer with FIFO message listener
- ✅ Lite push consumer with dynamic subscription
- ✅ **Push consumer with FIFO consume accelerator** (Enhanced feature)
- ✅ **Message filtering with Tag and SQL92 expressions** (v5.2.8)
- ✅ **OpenTelemetry distributed tracing** (v5.3.0)

Supports .NET 8.0 (LTS) and .NET 10.0

## Installation

```bash
dotnet add package YMJake.RocketMQ.Client
```

### Optional: OpenTelemetry Instrumentation

```bash
dotnet add package YMJake.RocketMQ.Client.OpenTelemetry
```

Automatic distributed tracing with W3C Trace Context propagation. See [package docs](https://www.nuget.org/packages/YMJake.RocketMQ.Client.OpenTelemetry/) for details.

## Examples

See [RocketMQ.Client.Examples](RocketMQ.Client.Examples) for sample code.

## License

Apache License 2.0. Based on [Apache RocketMQ Clients](https://github.com/apache/rocketmq-clients).

## Packages

- **Main Client**: [YMJake.RocketMQ.Client](https://www.nuget.org/packages/YMJake.RocketMQ.Client/)
- **OpenTelemetry**: [YMJake.RocketMQ.Client.OpenTelemetry](https://www.nuget.org/packages/YMJake.RocketMQ.Client.OpenTelemetry/)
- **Repository**: [Gitee](https://gitee.com/ymjake/rocketmq-clients)