Loading [MathJax]/jax/output/CommonHTML/config.js
首页
学习
活动
专区
圈层
工具
发布
首页
学习
活动
专区
圈层
工具
社区首页 >问答首页 >发送大量python扭曲的消息

发送大量python扭曲的消息
EN

Stack Overflow用户
提问于 2014-02-21 21:31:23
回答 1查看 99关注 0票数 0

我有一个扭曲的TCPServer,它有大量的客户端连接。我需要能够让一个主客户端向该服务器发出命令,以便以非阻塞的方式向所有其他客户端连接发送消息。换句话说,服务器应该有一个命令处理程序(构建在lineReceived之上),它从主客户端接收一个特殊命令,然后启动一个线程或进程来遍历所有其他客户端,并向每个客户端发送一个命令(sendLine)。主客户端的命令处理程序应该在启动线程后立即返回。问题是,在twisted中对sendLine的任何调用都必须从主反应器线程调用,因此必须使用callFromThread来完成。那么,我的主命令处理程序是否可以执行以下操作:

代码语言:javascript
代码运行次数:0
运行
AI代码解释
复制
def handle_master_command(self,command):
    deferred=reactor.deferToThread(myfunc)
    return

def myfunc(self):
    for client in other_clients:
        reactor.callFromThread(send_stuff_to_client,client,stuff_to_send)

显然这只是伪代码,但是像这样的东西能工作吗?

EN

回答 1

Stack Overflow用户

发布于 2014-02-21 23:13:06

呃,LineReceiver.sendLine()已经是非阻塞的了;你不需要任何线程,只需这样做:

代码语言:javascript
代码运行次数:0
运行
AI代码解释
复制
def handle_master_command(self, command):
    for client in other_clients:
        send_stuff_to_client(client, stuff_to_send)

如果任何扭曲的api说它“必须从反应器线程调用”,这总是意味着它将是非阻塞的。

票数 1
EN
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接:

https://stackoverflow.com/questions/21945586

复制
相关文章
Python之Rabbitmq发送消息
Rabbitmq是一个在AMQP基础上完整的,可复用的企业消息系统。他遵循Mozilla Public License开源协议。
Wu_Candy
2022/07/04
1.1K0
Python之Rabbitmq发送消息
Python模拟发送Slack消息
有一个看似很简单的小需求,但是对于一个Python入门的新手来讲还是有些难度的,虽然人家也有写好的代码,但是自己就是不想直接去搬人家的代码,在不懂得时候还装的那么高大上,没办法,就是想自己折腾折腾,别人能写的出来,就说明在某些地方肯定有相关的文章,所以不要怕折腾…
公众号: 云原生生态圈
2021/11/15
1.4K0
Python模拟发送Slack消息
python实现定时发送qq消息
因为生活中老是忘记各种事情,刚好又在学python,便突发奇想通过python实现提醒任务的功能(尽管TIM有定时功能),也可定时给好友、群、讨论组发送qq消息。其工作流程是:访问数据库提取最近计划——>根据数据内容(提醒时间、提醒对象、提醒内容)设置定时任务——>给特定qq好友发送消息。
py3study
2020/01/16
5K1
【说站】python socket发送消息的方法
以上就是python socket发送消息的方法,希望对大家有所帮助。更多Python学习指路:python基础教程
很酷的站长
2022/11/24
1.2K0
【说站】python socket发送消息的方法
消息队列的消息大量积压怎么办?
系统出现性能问题,来不及处理上游发的消息,导致消息积压。消息积压是正常现象,但积压太多就需要处理了。就像水库,日常蓄水是正常的,但下游泄洪能力太差,导致水库水位一直不停上涨,就不正常!
JavaEdge
2022/11/30
1.6K0
消息队列的消息大量积压怎么办?
Python stomp 发送消息无法显示文本
根据官方的说, Stomp 如设置了 content-length 就认为是二进制的消息,如果没有设置的话就是文本消息。
HoneyMoose
2023/09/16
2000
Python stomp 发送消息无法显示文本
钉钉发送报警消息的Python实现
我司使用钉钉作为主要的内部通讯工具,基本上大家在电脑和手机上都开着,消息可以第一时间查看,报警消息的即时性要求比较高,我们计划使用钉钉来发送报警通知。本文将简要介绍发送消息的API使用样例。钉钉的API接口文档,请查阅钉钉开放平台。
Debian中国
2018/12/21
3.3K2
Python 通过 stomp 发送消息到 ActiveMQ 的代码
只需要下面简单的几行代码,我们就可以把我们本地数据发送到 ActiveMQ 上面去。
HoneyMoose
2023/09/20
2180
Python 通过 stomp 发送消息到 ActiveMQ 的代码
RabbitMq消息发送
如果要发送一个消息,可以使用channel类的basicPublish方法参考如下,其中在rabbitmqTemplate中封装的方式是:
写一点笔记
2022/08/11
8610
RabbitMq消息发送
微信小程序 python 发送订阅消息
https://developers.weixin.qq.com/miniprogram/dev/api-backend/open-api/subscribe-message/subscribeMessage.send.html
前Thoughtworks-杨焱
2021/12/07
1.2K0
udp发送广播消息
import socket if __name__ == '__main__': # 创建udpsocket udp_socket = socket.socket(socket.AF_INET, socket.SOCK_DGRAM) # 设置socket选项, 开启发送广播消息的功能 # 1. SOL_SOCKET:当前socket # 2. SO_BROADCAST: 广播选项 # 3. True:开启发送广播消息功能 udp_socket.set
汪凡
2019/03/01
2.7K0
RabbitMQ延迟消息发送
典型的场景有微信、支付宝等第三方支付回调接口,会在用户支付后3秒、5秒、30秒等等时间后向应用服务器发送回调请求,确保应用服务器可以正确收到消息。
兜兜毛毛
2019/10/23
2.6K0
RabbitMQ延迟消息发送
kafka发送消息的简单理解
李子健
2023/06/11
2730
发送kafka消息的shell脚本
开发和学习时需要造一些kafka消息,于是写了段脚本实现,在这里记录备忘,后面会常用到;
程序员欣宸
2020/03/18
2.5K0
发送kafka消息的shell脚本
【RocketMQ】发送事务消息
事务消息:提供类似XA或Open XA的分布式事务功能,通过事务消息能达到分布式事务的最终一致。
凯哥Java
2022/12/16
1.1K0
【RocketMQ】发送事务消息
消息中间件—RocketMQ消息发送
摘要:使用客户端发送一条消息很Easy,在这背后RocketMQ完成了怎么样的操作呢? 大道至简,消息队列可以简单概括为:“一发一存一收”,在这三个过程中消息发送最为简单,也比较容易入手,适合初中阶童鞋作为MQ研究和学习的切入点。因此,本篇主要从一条消息发送为切入点,详细阐述在RocketMQ这款分布式消息队列中发送一条普通消息的大致流程和细节。在阅读本篇之前希望读者能够先仔细读下关于RocketMQ分布式消息队列Remoting通信模块的两篇文章: (1)消息中间件—RocketMQ的RPC通信(一) (2)消息中间件—RocketMQ的RPC通信(二)
用户2991389
2018/09/05
2.4K0
消息中间件—RocketMQ消息发送
环信发送消息
特殊说明: 解决问题的光鲜,藏着磕Bug的痛苦。 万物皆入轮回,谁也躲不掉! 以上文章,均是我实际操作,写出来的笔记资料,不会出现全文盗用别人文章!烦请各位,请勿直接盗用!
收心
2022/01/19
1.2K0
微信小程序 python 发送客服消息
发表于2020-03-312020-04-03 作者 wind #!/usr/bin/python # coding=utf-8 import requests, json, sys, time, logging if sys.getdefaultencoding() != 'utf-8': reload(sys) sys.setdefaultencoding('utf-8') logging.basicConfig(format='%(asctime)s - %(pathname)
前Thoughtworks-杨焱
2021/12/07
9860
python发送微信及企业微信消息
直接使用第三方库 itchat,其文档中有详细使用方式; https://itchat.readthedocs.io/zh/latest/
用户1558882
2019/06/21
10K0
python发送微信及企业微信消息
使用python通过接口方式发送钉钉消息
目前钉钉支持群聊消息的通过接口发送,需要建立群聊: 1、创建群聊 2、群聊设置自定义机器人: 根据提示自定义设置,最后获取webhook地址 相关说明文档 3、发送消息实现: def
JQ实验室
2022/01/11
2K0
使用python通过接口方式发送钉钉消息

相似问题

Azure servicebus python -如何发送大量消息

16

扭曲的发送文件。python

18

扭曲套接字立即发送消息

21

扭曲的python请求/响应消息和大量二进制数据传输

16

消息传递正在发送大量弹出的SMS消息

23
添加站长 进交流群

领取专属 10元无门槛券

AI混元助手 在线答疑

扫码加入开发者社群
关注 腾讯云开发者公众号

洞察 腾讯核心技术

剖析业界实践案例

扫码关注腾讯云开发者公众号
领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档
查看详情【社区公告】 技术创作特训营有奖征文