作者文章归档：liangliangyy
在上篇文章中，我们介绍了消费端的确认，那么在生产者有没有确认机制呢？答案是有的。 参考我们发送消息的代码段: channel.basic_publish(exchange='testexchange', routing_key='hello', body='Hello World!{}'.format(i), mandatory=True, properties=pika.BasicProperties( ...
首先，我们先看下这样的业务场景，在消息发出后，Consumer接收到了生产者所发出的消息，但在Consumer突然出错崩溃，或者异常退出了，但是生产者消息已经发出来了，那么这个消息可能就会丢失，为了解决这样的问题，RabbitMQ引入了ack机制。 消费者在订阅队列时，可以指定autoAck参数，当autoAck等于false时，RabbitMQ会等待消费者显式地回复确认信号后才从内存(或者磁盘)中移去消息(实质上是先打上删除标记，之后再删除)。当autoAck等于true时，RabbitMQ会⾃自动把发送出去的消息置为确认， 然后从内存(或者磁盘)中删除，而不管消费者是否真正地消费到...
基本介绍
RabbitMQ, 是一个使用erlang编写的AMQP(高级消息队列协议)的服务实现. 简单来说, 就是一个功能强大的消息队列服务.流程上来说，是发消息者(producer)把消息放到队列(queue)中去，然后收消息者(consumer)从队列中取出消息. RabbitMQ在这个基本概念之上, 多做了一层抽象, 在发消息者和队列之间, 加入了交换器 (Exchange). 这样发消息者和队列就没有直接联系, 转而变成发消息者把消息给交换器, 交换器根据调度策略再把消息再给队列。 rabbitmq中几个比价重要的概念如下: - Producer，生产者，创建消息，然后发...
asyncio介绍 熟悉c#的同学可能知道，在c#中可以很方便的使用async和await来实现异步编程，那么在python中应该怎么做呢，其实python也支持异步编程，一般使用asyncio这个库，下面介绍下什么是asyncio:
asyncio 是用来编写 并发 代码的库，使用async/await语法。 asyncio 被用作多个提供高性能Python异步框架的基础，包括网络和网站服务，数据库连接库，分布式任务队列等等。 asyncio 往往是构建 IO 密集型和高层级 结构化 网络代码的最佳选择。
asyncio中的基本概念 可以看见，使用asyncio库我们也可以在pyt...
这个播放器是大学时候做的毕业设计，使用qt+phonon实现，支持音视频播放，支持同步显示歌词。是无意中在电脑里翻出了这个项目的源码，然后在ubuntu机器中安装了下环境编译之后竟然能够成功运行，看着这个界面和源码真是感慨良多，转眼已经毕业好几年了，真的是物是人非。。。 为了不让它在电脑继续里吃灰，还是分享出来，希望可以帮到可以用到的人吧，下面大体介绍下编译方式。 安装方式: 以ubuntu为例： 安装依赖 sudo apt update
sudo apt install qt4* -y sudo apt install qtcreator -y
s...
我们经常会有这样的需求，比如评论功能，每个评论都有可能会有自己的子评论，如果在界面只展示成一列的话非常不美观，也不能体现出他们的层级关系。那么我们今天就来看看如何使用Django的模版来生成树状结构，以本站为例,效果如下图所示：
那么我们要怎么实现呢？首先先看看评论实体的定义，如下所示: class Comment(models.Model): body = models.TextField('正文', max_length=300) author = models.ForeignKey(settings.AUTH_USER_MODEL, verbose...