AsyncWebsocketConsumer VS AsyncConsumer

文章/答案/技术大牛

发布

1回答

django、websocket、django-channels

这是我第一次在Django遇到频道:)我在这里有两个主要的有用且几乎完整的来源:1) youtube 上的视频2) 频道的文档from channels.generic.websocket importAsyncWebsocketConsumer from channels.consumer import

浏览 132提问于2019-12-02得票数 2

回答已采纳

1回答

Django通道无法在生产环境中正常工作

python、django、channels、daphne、asgi

首先，让我给你看一小段代码 class LogConsumer(AsyncConsumer): async def websocket_connect(self, event):

浏览 60提问于2021-04-13得票数 0

1回答

Django通道-连接时发送数据

django、websocket、django-channels

如果可能的话，我想做这样的事情： from channels.db import database_sync_to_async class StreamConsumer(AsyncConsumer):

浏览 9提问于2020-06-11得票数 0

3回答

TypeError: object.init()只使用一个参数(初始化实例) WebSocket断开连接/public_chat/1/ [127.0.0.1:50083]

python、python-3.x、django、django-rest-framework、channel

),websockets.py def encode_json(cls, content): groups = Non

浏览 13提问于2021-01-11得票数 0

1回答

Django使用InMemoryChannelLayer引导后台工作人员不接收消息

django、django-channels

#consumer print(message) class LogConsumer(AsyncWebsocketConsumer

浏览 1提问于2020-08-07得票数 1

回答已采纳

1回答

Django频道无法在asyncio.sleep期间接收事件？

django、python-asyncio、django-channels、daphne

我正在使用AsyncWebSocketConsumer，我想让消费者在处理一个特定事件时休眠10秒钟。因此，在接收到该事件时，我调用await asyncio.sleep(10)。我的问题是，如果我正在使用AsyncConsumer，即使我处于异步睡眠状态，它是否应该继续发送未来的事件？

浏览 1提问于2020-06-13得票数 2

1回答

拒绝Django信道中所有连接的WebSocket服务器

python、django、reactjs、websocket、django-channels

我正在和django聊天(后端)和react (前端)。我使用Django通道来创建WebSocket服务器，但是它不能工作:当试图连接React时，它会将Forums.jsx:61 WebSocket connection to 'ws://localhost:8000/forums/divers/' failed: Error during WebSocket handshake: net::ERR_CONNECTION_RESET抛到导航器控制台中。今天早上它在工作，但是今天下午，在关闭并重新打开了2台服务器之后，它就不能工作了。在此期间，我只启动了一个将消息存储在数据库

浏览 2提问于2020-03-15得票数 1

回答已采纳

1回答

Django-通道2 Apache CentOS 7部署

django、apache、websocket、django-channels、daphne

我不能让Apache通过Daphne为websockets服务。Django==2.0.7 channels==2.1.3 asgiref==2.3.2 redis==2.10.6CHANNEL_LAYERS = { "BACKEND": "channels_redis.core.RedisChannelLayer", "hosts":

浏览 0提问于2018-09-11得票数 1

1回答

使用camel rest服务触发长操作

apache-camel、activemq、jbossfuse

我想使用camel rest call触发一个长操作。由于该操作需要大量时间，因此请求将超时，并在客户端显示错误消息。我不希望这事发生。<bean id="activemq" class="org.apache.activemq.camel.component.ActiveMQComponent"> <property n

浏览 0提问于2016-11-08得票数 0

2回答

如何通过将方法添加到.netcore 2.1中的启动中来调用作为后台工作人员的方法？

c#、.net、asp.net-mvc、asp.net-core、asp.net-web-api

当应用程序启动时，我很困惑如何调用AsyncConsumer或使用者。response.IsValid) public async Task AsyncConsumer

浏览 3提问于2020-02-18得票数 0

回答已采纳

1回答

使用Executor处理10000个线程

java、multithreading、threadpoolexecutor

public class myConsumer { public void asyncConsumer() throws InterruptedException, ExecutionException

浏览 2提问于2015-09-10得票数 0

1回答

Django-通道AsyncConsumer不工作

django、python-asyncio、django-channels

number'] UserFactory.create_batch(number, groups=(id,))class BackgroundTaskConsumer(AsyncConsumer): async def create_users(self, message):

浏览 2提问于2020-04-20得票数 0

回答已采纳

1回答

从topic收到消息后，Camel路由不能异步工作

spring、apache-camel

我们有驼峰路径，它从主题中读取，然后对接收到的消息执行一些转换。为了实现并发，添加了线程池，以便一旦从主题接收到进一步异步工作的消息，线程就会生成，而不是它的顺序线程。就像收到消息一样，线程从池中挑选，并开始处理，直到该线程没有完成处理，下一条消息不会被挑选。 xml

浏览 0提问于2018-10-25得票数 1

1回答

获取Django信道响应的图像完整url

python、django、django-channels

我已经使用Django通道创建了一个套接字，该套接字返回了分类对象的序列化数据。但是在响应中，没有完整的URL( IP地址不存在)。这个问题类似于这个问题。不同之处在于，我从使用者(Django通道)调用序列化程序。而在链接中，序列化程序是从视图中调用的。在使用者中，没有解决方案中提到的请求对象。Django通道表示，消费者中的作用域与视图中的request相似。那么，在这种情况下，如何才能获得完整的图像url呢？

浏览 2提问于2020-12-29得票数 4

1回答

Camel不会为一个使用者并行处理消息

java、spring、hibernate、jms、apache-camel

在我们的设置中，我们使用了camel、jms、spring和hibernate，并且我们有很多类似的消息。所以它们需要由一个由Spring创建的处理器来处理。但是我可以看到，处理器只运行一次。我也检查了线程转储和日志，所以我现在可以说，这是一个事实，软件没有以正确的方式扩展。public class MyRouteBuilder extends SpringRouteBuilder { ApplicationContext context; public void configure() throws

浏览 1提问于2015-09-25得票数 2

1回答

定制Django通道中间件在Websocket连接之前未完成处理

django、asynchronous、websocket、django-rest-framework、django-channels

我有一个现有的WSGI应用程序，我正在添加Django通道来提供websocket功能。我使用WebsocketConsumer创建了一个使用者，将自定义中间件添加到路由文件中，并实现了从传入连接请求中提取令牌的基本版本。我可以成功地打印数据库中的令牌，因此我知道正确的信息正在传递。我可以连接到套接字，但它总是作为范围内的匿名用户返回。似乎get_user_from_token函数在执行connect函数之前没有机会执行，因为TokenAuthMiddleware类的__call__函数中的所有打印都是打印的，而来自get_user_from_Token的打印没有打印。我试着将使用者转换为异

浏览 6提问于2020-04-01得票数 1

1回答

当拒绝与django-通道的连接时，如何返回错误消息？

django、django-channels

我已经设置了django-通道以及一个端点来处理web套接字连接，但是，当连接被拒绝时，我仍然停留在如何返回错误消息/错误代码方面。例如，如果用户没有足够的权限，我不希望接受连接，并希望返回原因。

浏览 7提问于2022-01-12得票数 0

1回答

camel中具有队列的线程DSL行为

java、multithreading、apache-camel

使用下面的路由，我希望来自queue1的10条消息应该是并发的进程，但一次只能得到一个进程。context.addRoutes(new RouteBuilder() { from("test-jms:queue:test.queue1").threads(10) .process(sleep(1)); // sleep id is 1

浏览 1提问于2015-09-21得票数 3

1回答

Akka Actors竞争消费者

java、apache-camel、cluster-computing、akka、actor

我正在试用一个使用Akka和Camel的竞争事件消费者实现。我正在使用Akka 2.3.2和Camel 5.8.0。我正在将camel连接到ActiveMQ代理，并使用生产者从另一端生成消息。在下面的代码中，EventManager是创建使用者池的主程序，EventProcessor是消息处理的参与者。 import org.apache.activemq.ActiveMQConnection; import o

浏览 1提问于2014-05-02得票数 0

回答已采纳

1回答

django通道websocket在握手期间关闭

python、django、websocket、django-channels

我正在尝试使用channels readthedocs https://channels.readthedocs.io/en/latest/tutorial/index.html中的教程将一个简单的聊天室集成到我当前的网站项目中当我尝试加载我的网站的主页，它应该自动连接到全球聊天时，我得到了这个后端控制台 HTTP GET / 200 [0.01, 127.0.0.1:58286]HTTP GET /static/chatroom/images/profiles

浏览 25提问于2020-07-06得票数 1

回答已采纳

点击加载更多