是水饺不是水饺

Abp.VNext 用.NET Core Console 项目介绍Abp (一)

摘要：首先需要 Nuget 上下载 Volo.Abp.Core Volo.Abp.Autofac 项目结构 AbpConsole 项目 Program 代码引用了 Volo.Abp.Autofac 1 using AbpConsole; 2 using Microsoft.Extensions.Depe 阅读全文

posted @ 2023-02-03 23:19 是水饺不是水饺阅读(118) 评论(0) 推荐(0) 编辑

Redis 分布式锁

摘要：先理解线程锁，线程锁就是锁住线程的锁分布式锁就是锁住进程的锁在集群的环境下应该使用锁进程的方式 1 using StackExchange.Redis; 2 using System; 3 using System.Collections.Generic; 4 using System.Lin 阅读全文

posted @ 2023-02-01 16:44 是水饺不是水饺阅读(73) 评论(0) 推荐(0) 编辑

.net core 下使用 RabbitMQ 事务(八)

摘要： 1 public void TxProducer() 2 { 3 string queueName = "ORIGN_QUEUE"; 4 using(var connection = RabbitMQHelper.GetConnection("192.168.3.200", 5671)) 5 { 6 阅读全文

posted @ 2023-02-01 01:15 是水饺不是水饺阅读(13) 评论(0) 推荐(0) 编辑

.net core 下使用 RabbitMQ 失败重试 (七)

摘要：主要代码消息的 Properties.headers.x-death 属性中查询到消息投递源信息和消息被投递的次数； 1 2 var consumer = new EventingBasicConsumer(channel); 3 consumer.Received += (model, ea) 阅读全文

posted @ 2023-02-01 00:28 是水饺不是水饺阅读(72) 评论(1) 推荐(0) 编辑

.net core 下使用 RabbitMQ 设置1次消费1条消息 (六)

摘要：主要设置设置prefetchCount=1，来告知RabbitMQ，在未收到消费端的消息确认时，不再分发消息，也就确保了当消费端处于忙碌状态时，不再分配任务。 channel.BasicQos(prefetchSize: 0, prefetchCount: 1, global: false); 1 阅读全文

posted @ 2023-02-01 00:20 是水饺不是水饺阅读(86) 评论(0) 推荐(0) 编辑

.net core 下使用 RabbitMQ 消息没有正确路由到队列处理方式错误消息回调 (五)

摘要：消息回调 1 public void Producer() 2 { 3 string queueName = "RE_QUEUE"; 4 string exchangeName = "RE_EXCHANGE"; 5 using (var connection = RabbitMQHelper.Get 阅读全文

posted @ 2023-02-01 00:14 是水饺不是水饺阅读(33) 评论(0) 推荐(0) 编辑

.net core 下使用 RabbitMQ 交换机备份 (四)

摘要： 1 public void BackupMethod() 2 { 3 string queueName = "BACKUP_QUEUE"; 4 string exchangeName = "BACKUP_EXCHANGE"; 5 string backupQueue = "BACKUP_QUEUE_ 阅读全文

posted @ 2023-02-01 00:05 是水饺不是水饺阅读(23) 评论(0) 推荐(0) 编辑

.net core 下使用 RabbitMQ 延迟队列 (三)

摘要：延迟队列，跟死信队列差不多队列设置及参数：参数名类型作用x-message-tti(Time-To-Live) int，毫秒对消息设置预期的时间，过期将被丢弃x-max-length int 限制队列最大长度,个数，新增后删除最早的x-expires int，毫秒队列没有访问超时时，自动阅读全文

posted @ 2023-02-01 00:01 是水饺不是水饺阅读(106) 评论(0) 推荐(0) 编辑

.net core 下使用 RabbitMQ 死信队列 (二)

摘要：消息到死信队列的三种情况消息被拒(basic.reject or basic.nack)并且没有重新入队(requeue=false)；当前队列中的消息数量已经超过最大长度。消息在队列中过期，即当前消息在队列中的存活时间已经超过了预先设置的TTL(Time To Live)时间；以下是代码实阅读全文

posted @ 2023-01-31 21:18 是水饺不是水饺阅读(31) 评论(0) 推荐(1) 编辑

.net core 下使用 Kafka 延迟队列(四)

摘要：在电商业务中存在一个场景，用户生成订单，超过30分钟，将订单修改未支付，延迟队列就可以解决该场景问题 1 public class KafkaTopic 2 { 3 public static string Topic = "create-order"; 4 5 public static stri 阅读全文

posted @ 2023-01-31 00:33 是水饺不是水饺阅读(54) 评论(0) 推荐(0) 编辑

.net core 下使用 Kafka 批量发送消息，使用事务(四)

摘要：批量发送消息，使用事务，要么全失败要么全成功重要提示必须设置事物ID producerConfig.TransactionalId =Guid.NewGuid().ToString();//必须设置事物id 1 /// <summary> 2 /// 批量发送 3 /// </summary> 阅读全文

posted @ 2023-01-30 21:37 是水饺不是水饺阅读(89) 评论(0) 推荐(0) 编辑

.net core 下使用 Kafka 生产者批量发送给消息处理，使用事务(四)

摘要：生产者批量发送消息，使用事务，要么全部失败要么全部成功重要说明事物id必须要设置 producerConfig.TransactionalId =Guid.NewGuid().ToString();//必须设置事物id 1 /// <summary> 2 /// 批量发送 3 /// </su 阅读全文

posted @ 2023-01-30 21:26 是水饺不是水饺阅读(131) 评论(0) 推荐(0) 编辑

.net core 下使用 Kafka 动态创建分区，创建主题(三)

摘要： Kafka 动态创建分区，创建主题，代码接上一篇写在api里了 1 using Confluent.Kafka.Admin; 2 using Confluent.Kafka; 3 using KafkaCommom; 4 using Microsoft.AspNetCore.Http; 5 usi 阅读全文

posted @ 2023-01-30 18:00 是水饺不是水饺阅读(207) 评论(0) 推荐(0) 编辑

Liunx 关机与重启命令

摘要： Linux 关机与重启命令关机命令a56爆大奖在线娱乐们可以使用以下三种命令来关机 Linux ： 1、立刻关机（需要root用户） shutdown -h now 10 分钟后自动关机 shutdown -h 10 2、立刻关机 halt 3、立刻关机 poweroff 重启命令重启可以使用以下两种命令: 1、最阅读全文

posted @ 2023-01-29 18:51 是水饺不是水饺阅读(342) 评论(0) 推荐(0) 编辑

.net core 下使用 Kafka(二)

摘要：上篇文章介绍了 docker 下安装 kafka 这篇文章介绍如何在.net core 下使用 Kafka 项目结构 KafkaCommom 类库项目 KafkaWebAPI .net core webapi 项目 KafKaWorker 为 work service 辅助角色服务项目引用 Ka 阅读全文

posted @ 2023-01-29 18:44 是水饺不是水饺阅读(413) 评论(0) 推荐(1) 编辑

docker 下Kafka 单机安装（一）

摘要： docker-compose.yml 文件执行之前需要修改你的 KAFKA_ADVERTISED_HOST_NAME 1 version: '2' 2 3 services: 4 zoo1: 5 image: wurstmeister/zookeeper 6 restart: unless-st 阅读全文

posted @ 2023-01-29 14:49 是水饺不是水饺阅读(149) 评论(0) 推荐(0) 编辑

在写RabbitMq发送消息方法时候,发现一个问题 byte[] 怎么能转换成 ReadOnlyMemory<byte> 类型

摘要：在写RabbitMq 发现一个问题 byte[] 怎么能转换成 ReadOnlyMemory 类型后来查看 ReadOnlyMemory类型发现有个运算符重载 public static implicit operator ReadOnlyMemory(T[]? array); 这个方法到底是做什阅读全文

posted @ 2023-01-28 10:39 是水饺不是水饺阅读(99) 评论(0) 推荐(0) 编辑

RabbitMQ Liunx 下 docker 安装

摘要：这是docker 安装 docker run -d --hostname my-rabbit --name rabbit -p 15672:15672 -p 5672:5672 -e RABBITMQ_DEFAULT_USER=test -e RABBITMQ_DEFAULT_PASS=test - 阅读全文

posted @ 2023-01-27 23:46 是水饺不是水饺阅读(37) 评论(0) 推荐(0) 编辑

nginx通配符

摘要：例如静态文件配置是通过正则匹配 location ~ .(ico|js|css|png|jpg|mp4)$ { root D:/wwwroot; } 1、Nginx路径匹配符号 = a56爆大奖在线娱乐精确匹配 ^~ a56爆大奖在线娱乐uri以某个常规字符串开头,大多情况下用来匹配url路径，nginx不对url做编码，因此阅读全文

posted @ 2023-01-27 23:38 是水饺不是水饺阅读(564) 评论(0) 推荐(0) 编辑

ASP.NET MVC 之CodeFirst 数据迁移

摘要： CodeFirst模式下如果一个类的属性增加或者删除那么与其对应的就是数据库中所对应的字段增加或者删除一个属性变化还好，a56爆大奖在线娱乐们直接可以到数据库中找到，所对应的表中，对其修改，那么一次对多个类中的属性做修改，如果手动来操作是件很头疼的事情那么数据迁移很轻松的解决问题阅读全文

posted @ 2017-09-23 22:37 是水饺不是水饺阅读(144) 评论(0) 推荐(0) 编辑