# rabbitmqclient-Plen-wang

**Repository Path**: me860/rabbitmqclient-Plen-wang

## Basic Information

- **Project Name**: rabbitmqclient-Plen-wang
- **Description**: 为
- **Primary Language**: C#
- **License**: Not specified
- **Default Branch**: master
- **Homepage**: None
- **GVP Project**: No

## Statistics

- **Stars**: 0
- **Forks**: 0
- **Created**: 2019-08-29
- **Last Updated**: 2020-12-19

## Categories & Tags

**Categories**: Uncategorized

**Tags**: None

## README

# rabbitmqclient
rabbitmq .net client

## 接受消息
```
private static void Listening()
        {
            RabbitMqClient.Instance.ActionEventMessage += mqClient_ActionEventMessage;
            RabbitMqClient.Instance.OnListening();
        }

        private static void mqClient_ActionEventMessage(EventMessageResult result)
        {
            if (result.EventMessageBytes.EventMessageMarkcode == MessageTypeConst.ZgUpdatePurchaseStatus)
            {
                var message =
                    MessageSerializerFactory.CreateMessageSerializerInstance()
                        .Deserialize<UpdatePurchaseOrderStatusByBillIdMqContract>(result.MessageBytes);

                result.IsOperationOk = true; //处理成功

                Console.WriteLine(message.ModifiedBy);
            }
        }
```

## 发送消息
```

private static void SendEventMessage()
        {
            for (var i = 1; i < 10000; i++)
            {
                var originObject = new UpdatePurchaseOrderStatusByBillIdMqContract()
                {
                    UpdatePurchaseOrderStatusType = 1,
                    RelationBillType = 10,
                    RelationBillId = 10016779,
                    UpdateStatus = 30,
                    ModifiedBy = i
                };

                var sendMessage =
                    EventMessageFactory.CreateEventMessageInstance(originObject, MessageTypeConst.ZgUpdatePurchaseStatus);

                RabbitMqClient.Instance.TriggerEventMessage(sendMessage, "CMQ.Purchase", "CMQ.Purchase");

                Console.WriteLine(i);
            }
        }

```