La puissante bibliothèque de signaux de Python : clignotant

1. Signal

Bonjour à tous, je suis mon vieux cousin~

Un signal est une sorte de notification ou dicton Dans le cadre de la communication, les signaux sont divisés en émetteurs et récepteurs. L'expéditeur envoie un signal et le processus du récepteur recevant le signal passera à la fonction de traitement du signal après l'exécution, il reviendra à la position d'origine pour continuer l'exécution.

Les signaux courants sous Linux, en saisissant Ctrl+C via le clavier, consistent à envoyer un signal au système pour lui dire de quitter le processus en cours.

La caractéristique d'un signal est que l'émetteur informe l'abonné de ce qui s'est passé. L'utilisation des signaux est divisée en 3 étapes : définition des signaux, surveillance des signaux et envoi des signaux.

Le module de communication qui fournit le concept de signal est un clignotant.

Blinker est une puissante bibliothèque de signaux basée sur Python, qui prend en charge à la fois la communication point à point simple et la multidiffusion point à multipoint. Le mécanisme de signalisation de Flask est basé sur celui-ci. Bien que le noyau de Blinker soit petit, il est très puissant. Il prend en charge les fonctionnalités suivantes :

• Prend en charge l'enregistrement des signaux nommés globaux
• Prend en charge les signaux anonymes #🎜. 🎜## 🎜🎜# Prend en charge les signaux nommés personnalisés
• Prend en charge les connexions persistantes et les connexions de courte durée avec les récepteurs
• Se déconnecte automatiquement des récepteurs via des références faibles
#🎜🎜 # Prend en charge l'envoi de données de n'importe quelle taille
• Prend en charge la collecte de la valeur de retour du récepteur de signal
• Sécurité des fils
• #🎜 🎜# 2. Blinker utilise
• méthode d'installation :

pip install blinker

2.1 Signal de dénomination

from blinker import signal
# 定义一个信号
s = signal('king')
def animal(args):
print('我是小钻风，大王回来了，我要去巡山')
# 信号注册一个接收者
s.connect(animal)
if "__main__" == __name__:
# 发送信号
s.send()

2.2 Signaux anonymes#🎜 🎜 #

blinker prend également en charge les signaux anonymes, c'est-à-dire qu'il n'est pas nécessaire de spécifier une valeur de signal spécifique. Chaque signal anonyme créé est indépendant les uns des autres.

from blinker import Signal
s = Signal()
def animal(sender):
print('我是小钻风，大王回来了，我要去巡山')
s.connect(animal)
if "__main__" == __name__:
s.send()

2.3 Signal multicast

Le signal multicast est une caractéristique qui peut mieux refléter les avantages du signal. Plusieurs récepteurs sont enregistrés sur le signal et l'expéditeur n'a besoin d'envoyer qu'une seule fois pour transmettre les informations à plusieurs récepteurs.

from blinker import signal
s = signal('king')
def animal_one(args):
print(f'我是小钻风，今天的口号是: {args}')
def animal_two(args):
print(f'我是大钻风，今天的口号是: {args}')
s.connect(animal_one)
s.connect(animal_two)
if "__main__" == __name__:
s.send('大王叫我来巡山，抓个和尚做晚餐！')

2.4 Le destinataire s'abonne au sujet

Le destinataire prend en charge l'abonnement au sujet spécifié, uniquement lorsque le sujet spécifié envoie un message avant de l'envoyer au destinataire. Cette méthode distingue bien les différents sujets.

from blinker import signal
s = signal('king')
def animal(args):
print(f'我是小钻风，{args} 是我大哥')
s.connect(animal, sender='大象')
if "__main__" == __name__:
for i in ['狮子', '大象', '大鹏']:
s.send(i)

2.5 Utilisation du décorateur

En plus de l'enregistrement des fonctions, il existe une méthode d'enregistrement du signal plus simple, à savoir le décorateur.

from blinker import signal
s = signal('king')
@s.connect
def animal_one(args):
print(f'我是小钻风，今天的口号是: {args}')
@s.connect
def animal_two(args):
print(f'我是大钻风，今天的口号是: {args}')
if "__main__" == __name__:
s.send('大王叫我来巡山，抓个和尚做晚餐！')

2.6 Décorateurs pouvant s'abonner à des sujets

La méthode d'inscription de Connect présente un inconvénient lors de l'utilisation de décorateurs, c'est-à-dire qu'elle ne peut pas s'abonner à des sujets, il existe donc un connect_via plus avancé méthode pour le prendre en charge Abonnez-vous aux sujets.

from blinker import signal
s = signal('king')
@s.connect_via('大象')
def animal(args):
print(f'我是小钻风，{args} 是我大哥')
if "__main__" == __name__:
for i in ['狮子', '大象', '大鹏']:
s.send(i)

2.7 Vérifiez si le signal a un récepteur

S'il faut beaucoup de temps à un expéditeur pour se préparer avant d'envoyer un message, afin d'éviter de gaspiller des performances à cause de non récepteur , vous pouvez donc d'abord vérifier s'il existe un récepteur pour un certain signal, et ne l'envoyer qu'après avoir confirmé qu'il existe un récepteur, afin d'être précis.

from blinker import signal
s = signal('king')
q = signal('queue')
def animal(sender):
print('我是小钻风，大王回来了，我要去巡山')
s.connect(animal)
if "__main__" == __name__:
res = s.receivers
print(res)
if res:
s.send()
res = q.receivers
print(res)
if res:
q.send()
else:
print("孩儿们都出去巡山了")

{4511880240: <weakref at 0x10d02ae80; to 'function' at 0x10cedd430 (animal)>}
我是小钻风，大王回来了，我要去巡山
{}
孩儿们都出去巡山了

2.8 Vérifiez si l'abonné est abonné à un certain signal

Vous pouvez également vérifier si l'abonné est abonné à un certain signal

from blinker import signal
s = signal('king')
q = signal('queue')
def animal(sender):
print('我是小钻风，大王回来了，我要去巡山')
s.connect(animal)
if "__main__" == __name__:
res = s.has_receivers_for(animal)
print(res)
res = q.has_receivers_for(animal)
print(res)

True
False

3. Basé sur les signaux clignotants Flask

Flask intègre le clignotant comme solution pour les applications de découplage. Dans Flask, les scénarios d'utilisation des signaux sont les suivants : avant l'arrivée de la requête et après la fin de la requête. Dans le même temps, Flask prend également en charge les signaux personnalisés.

3.1 Démo Simple Flask

from flask import Flask
app = Flask(__name__)
@app.route('/',methods=['GET','POST'],endpoint='index')
def index():
return 'hello blinker'
if __name__ == '__main__':
app.run()

Lorsque vous accédez à 127.0.0.1:5000, renvoyez le bonjour clignotant au navigateur.

3.2 Signaux personnalisés

Parce que Flask intègre des signaux, lors de l'utilisation de signaux dans Flask, ils sont importés de Flask.

from flask import Flask
from flask.signals import _signals
app = Flask(__name__)
s = _signals.singal('msg')
def QQ(args):
print('you have msg from QQ')
s.connect(QQ)
@app.route('/',methods=['GET','POST'],endpoint='index')
def index():
s.send()
return 'hello blinker'
if __name__ == '__main__':
app.run()

3.3 Le propre signal de Flask

En plus de personnaliser les signaux, vous pouvez également utiliser des signaux intégrés dans Flask. Il existe de nombreux types de signaux fournis avec Flask, comme suit :

请求
request_started = _signals.signal('request-started')# 请求到来前执行
request_finished = _signals.signal('request-finished')# 请求结束后执行
模板渲染
before_render_template = _signals.signal('before-render-template')# 模板渲染前执行
template_rendered = _signals.signal('template-rendered')# 模板渲染后执行
请求执行
got_request_exception = _signals.signal('got-request-exception')# 请求执行出现异常时执行
request_tearing_down = _signals.signal('request-tearing-down')# 请求执行完毕后自动执行（无论成功与否）
appcontext_tearing_down = _signals.signal('appcontext-tearing-down') # 请求上下文执行完毕后自动执行（无论成功与否）
请求上下文中
appcontext_pushed = _signals.signal('appcontext-pushed')# 请求上下文push时执行
appcontext_popped = _signals.signal('appcontext-popped')# 请求上下文pop时执行
message_flashed = _signals.signal('message-flashed')# 调用flask在其中添加数据时，自动触发

Ce qui suit est un exemple de la façon d'utiliser les signaux dans Flask avant que la demande n'arrive

from flask import Flask
from flask.signals import _signals, request_started
import time
app = Flask(__name__)
def wechat(args):
print('you have msg from wechat')
# 从flask中引入已经定好的信号，注册一个函数
request_started.connect(wechat)
@app.route('/',methods=['GET','POST'],endpoint='index')
def index():
return 'hello blinker'
if __name__ == '__main__':
app.run()

Quand. Lorsque la demande arrive, Flask informera le destinataire via request_started, qui est la fonction wechat. À ce moment, la fonction wechat est exécutée en premier puis renvoie le résultat au navigateur.

Mais cette méthode d'utilisation n'est pas très authentique, car les signaux ne prennent pas en charge les méthodes asynchrones, donc généralement les récepteurs de signaux dans les environnements de production sont des frameworks configurés avec une exécution asynchrone, comme le célèbre framework asynchrone céleri en Python.

4. Résumé des avantages des signaux

 :

1. Applications découplées : décomposez les applications couplées exécutées en série en exécutions multi-niveaux
2. Publier les abonnés : réduisez l'utilisation des appelants et avertissez plusieurs abonnés avec un seul appel

Inconvénients du signal :

1. Ne prend pas en charge l'asynchrone
2. Capacité limitée à prendre en charge les abonnements aux sujets

Chaque like, vue, chaque commentaire, chaque retweet de votre part est très important pour moi, merci pour votre soutien.

D'accord, à la prochaine fois. J'aime encore plus les chats, la technologie et le vieux cousin de Sisi⁽⁽ଘ( ˙꒳˙ )ଓ⁾⁾

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!