קוד עבור במיוחד
ESP מחובר ל- Arduino ביציאה סדרתית וגם נרשם בנושא MQTT כדי לקבל ממנו נתונים. בעיקרון, זה שולח את הנתונים שהתקבלו בנושא MQTT ליציאה הסדרתית ולנתונים מהסידרה לנושא MQTT.

כדי לדעת יותר על ESP ו- MQTT, עיין במאמרים הקודמים שלנו.

קוד לסקריפט Python

סקריפט Python מותקן עם “Yowsup” WhatsApp API לקריאה ולשלוח הודעות מ- WhatsApp. ישנם שני קבצים בסקריפט זה לָרוּץ.PY וכן שִׁכבָה.PY.

הבנת הפעלת קבצים.PY
אנו נקרא לספריות שלנו בראש הקובץ
מ- Yowsup.ערימות מייבאות yowstackbuilder
מ- Yowsup.שכבות.ייבוא ​​Auth Autherror
מ- Yowsup.שכבות מייבאות yowlayerevent
מ- Yowsup.שכבות.ייבוא ​​רשת YownetWorkLayer
מ- Yowsup.env ייבוא ​​yowsupenv

אנו נקשר גם את קובץ השכבה בחלק העליון מכיוון שהכיתה העיקרית “Echolayer” קיים בתוך הקובץ הזה.
משכבה של ייבוא ​​שכבה

אנו יכולים לקרוא לקובץ השכבה כל דבר, אך עלינו לשים את אותו שם כאן.

בתוך ה PY, אנו נצהיר על המשתנה העיקרי שלנו לסיסמא ואירועים שאנו רוצים להתרחש.
אישורים = (“91xxxxxxxxxx”, “HKHWVW5/WNR493HXK8NKL/HTPNO =”)

עכשיו אנו מעבירים אותם לשכבה ובונים את הערימה. כמו כן, לולאה שתשמור על החיבור בשידור חי נקראת.
לַעֲרוֹם.SetCredential (אישורים)
לַעֲרוֹם.BroadcastEvent (YowlayerEvent (YownetWorkLayer.Event_state_connect)) #הוצאת אות Connect
לַעֲרוֹם.לולאה () #זו התוכנית Mainloop

הבנת שכבת קבצים.PY
קובץ זה מכיל את ספריית הפרוטוקול עבור MQTT ומסוגל לקבל הודעות מ- WhatsApp.

הבנת כיצד מתקבלות הודעות מ- WhatsApp
קובץ זה מכיל את הכיתה שתקבל כל הודעות שנכנסות למספר זה, וזה יהיה ישות התקשרות חוזרת כך שניתן להפעיל כל לולאה אחרת בתוך הקובץ.
@Protocolingcallback (“הוֹדָעָה”)
def onMessage (עצמי, מסג -פרוטוקולציה):
אם זה נכון:

ניתן להשיג נתוני הודעות וטופס מספר ממנו הגיעה ההודעה להלן.
incomming_message_data = messageprotocolentity.getbody ()

זה יקבל את גוף ההודעה שהוא המסר האמיתי. זה יאחסן במשתנה מחרוזת “incomming_message_data”
incomming_message_sender = messageprotocolentity.לקבל מ()

שורה זו תאחסן את מספר איש הקשר של ההודעה הנכנסת במשתנה המחרוזת “incomming_message_sender”

הבנת שכבות ה- MQTT לשליחה וקבלה
ראשית, אנו נובא ספריות הנחוצות ל- MQTT.
יבוא פאהו.MQTT.לקוח כ- MQTT
יבוא פאהו.MQTT.לפרסם כפרסום

כעת נצהיר על משתנה בשם לקוח עם לקוח MQTT.
לקוח = MQTT.לָקוּחַ()

כעת נבצע שני התקשרות פונקציות 1. לקבלת הודעות, 2. עושה משהו בחיבור מצליח.
לָקוּחַ.on_connect = on_connect
לָקוּחַ.on_message = on_message

לבסוף, נתחבר למתווך MQTT ביציאה, ונתחיל את הלקוח בתוך לולאה ללא חסימה
לָקוּחַ.לְחַבֵּר(“סַרְסוּר.HIVEMQ.com”, 1883, 60)
לָקוּחַ.LOOP_START ()

לאחר שהחיבור מצליח, אנו יכולים לשלוח הודעות באמצעות זה
לְפַרְסֵם.יחיד (נושא, הודעה_data, hostname =”סַרְסוּר.HIVEMQ.com”)

כאשר מתקבלת הודעה כלשהי ב- WhatsApp, היא מאוחסנת במחרוזת ואז סריקה את המחרוזת הזו עבור כמה מילות מפתח המגדירות את ההודעה הזו כפקודה להפעלת האור/כיבוי.
אליף (“אורות דלוקים” ב- incomming_msg): #do משהו בהתאמה

אם המצב מתאים, אנו שולחים את פקודת הבקרה למתווך MQTT.
לְפַרְסֵם.יחיד(“TS/Light”, “עַל”, שם מארח =”סַרְסוּר.HIVEMQ.com”)

כאשר התקבלה הודעה לא מוכרת, ההודעה ב- WhatsApp עונה שזה לא תקף.

וככה אנו יכולים להשתמש בגישור פרוטוקול כדי לשלוט במכשירי WhatsApp.

XANECS/AXIOM

התחייבות זו אינה שייכת לשום סניף במאגר זה, והיא עשויה להשתייך למזלג מחוץ למאגר.

החלף ענפים/תגיות

תגי סניפים

לא יכול היה להעמיס ענפים

אין מה להראות

לא יכול היה לטעון תגיות

אין מה להראות

שם כבר נמצא בשימוש

תג כבר קיים עם שם הסניף שסופק. פקודות GIT רבות מקבלות שמות תגיות וגם סניפים, ולכן יצירת סניף זה עלולה לגרום להתנהגות בלתי צפויה. האם אתה בטוח שאתה רוצה ליצור את הענף הזה?

בטל צור

• מְקוֹמִי
• מרחבי קוד

Https github cli

השתמש ב- Git או Checkout עם SVN באמצעות כתובת האתר האינטרנט.

לעבוד מהר עם ה- CLI הרשמי שלנו. למידע נוסף על ה- CLI.

נדרשת חתימה

אנא היכנס לשימוש ב- Codespaces.

השקת שולחן העבודה של GitHub

אם שום דבר לא קורה, הורד את שולחן העבודה של Github ונסה שוב.

השקת שולחן העבודה של GitHub

אם שום דבר לא קורה, הורד את שולחן העבודה של Github ונסה שוב.

הפעלת xcode

אם שום דבר לא קורה, הורד xcode ונסה שוב.

השקת קוד Visual Studio

מרחב הקוד שלך ייפתח לאחר שתוכן.

הייתה בעיה להכין את מרחב הקוד שלך, אנא נסה שוב.

התחייבות אחרונה

סטטיסטיקות GIT

קבצים

נכשלה לטעון מידע על התחייבות אחרונה.

הודעת התחייבות אחרונה

התחייב זמן

תקרא אותי.MD

Axiom היא תוכנית Python שמתחברת לשרת MQTT ומספקת ממשק לשירות ההודעות WhatsApp.

1. שיבטו את הריפו הזה.
2. התקן תלות

PIP התקן את yowsup2 paho-mqtt 

1. ערוך WASERVER/config.PY . אישורים יכולים להידרש מ- yowsup2 cli. ראה כאן.
2. לָרוּץ

שרת פיתון/שרת.PY 

1. צור שרת/config-prod.PY
2. בנה את התמונה עם Dockerfile המסופק . קבצי התצורה הנפרדים מאפשרים תצורות DEV/ייצור שונות.

לקבלת הודעות להירשם ל- WhatsApp/נכנס . הודעה תיראה כך:

< "טלפון": "4915112345678", "הוֹדָעָה": "שלום מאדם!" >

מספר טלפון בדוגמה זו יאוים בדרך כלל +49 151 12345678 . עבור הודעות קבוצתיות, מספר הטלפון נמצא בטופס 4915112345678-1400000000 (מספר הטלפון של יוצר הקבוצה וחותמת חותמת יוניקס).

כדי לשלוח הודעות, פרסם ל- WhatsApp/יוצא:

< "טלפון": "4915112345678", "הוֹדָעָה": "שלום מבוט!" >

נכון לעכשיו יש רק בפקודה מיושמת

לקבלת מידע קבוצתי (חברים, כותרת), פרסם ל- WhatsApp/CMD

< "CMD": "group_info", "טלפון": "4915112345678-1400000000", "התקשר חזרה": "any_string_here" >

ההתקשרות תשמש לזיהוי התגובה לפקודה זו. רצוי להשתמש ב- UUID לשם כך. התגובה תפורסם לנושא WhatsApp/IQ:

< "CMD": "group_info", "התקשר חזרה": "any_string_here", "קבוצה": "4915112345678-1400000000", "משתתפים": < "4915112345678": "מנהל", "4915187654321": ריק, >, "נושא": "קבוצת דוגמא" >

על אודות

MQTT-Interface לשירות ההודעות WhatsApp

איך WhatsApp תור את ההודעות שלך?

אלו שם, חבר! זה’זה הולך להיות כמעט שנתיים של המגיפה בעוד כמה חודשים, והדרך בה התאימנו את אורח החיים שלנו, הו ילד! כולנו נשארנו מחוברים ואפילו עשינו את עבודתנו באמצעות פלטפורמות העברת הודעות שונות. השימוש בפלטפורמות מרובות, כולל WhatsApp, אינסטגרם ופייסבוק, עלה משמעותית. WhatsApp היה זה עם השימוש הגבוה ביותר, ועם הודו הייתה WhatsApp’השוק הגדול ביותר השנה! אבל האם ידעת ש- WhatsApp משתמשת באחד ממבני הנתונים הבסיסיים ביותר, תור, המשמשת פלטפורמת העברת הודעות זו כדי להעביר את ההודעות שלך בהצלחה?

מה זה תור?

תור, כפי שהשם מציין, הוא בדיוק כמו זה בחיים האמיתיים. לתור יש שני קצוות, ראש וזנב, ופריטים מתווספים רק בקצה הזנב ומוסרים מקצה הראש. דמיין קבוצת אנשים שמחכים בתור כדי להשיג פיצה, ואת האדם הראשון שהגיע לשם, אני.ה., הראשון בתור, יינתן העדפה והיא תהיה זו שתקבל את הפיצה או להיות “נדחף החוצה.” מושג זה טכני ידוע בשם FIFO או הראשון ב- First Out.

מהו תור הודעה?

כמעיד על הכותרת, תור הודעה הוא תור מלא בהודעות. שירות אסינכרוני זה משמש להעברת הודעות או נתונים בין שני אנשים או קבוצת אנשים. האדם ששולח את ההודעה לתור הוא המפיק, וזה שמקבל את ההודעה הוא הצרכן. מהתור’נקודת מבט, הודעה היא רק אוסף של בתים ויכול להיות כל דבר החל מהודעת טקסט רגילה או הודעה המכילה לקוח’מזהה הזמנה או אפילו הודעת שגיאה.

• במערכת תורי הודעה ישנם שרתים מרובים המכונים מתווכים. מתווכים אלה אמינים מאוד וניתנים להרחבה, והם יוצרים אשכול. לאחר הפקת הודעה או נשלחת מצד המפיק, ההודעה מאוחסנת בתור ההודעה עד שהצרכן זמין לקחת את ההודעות.
• ברגע שהצרכן או הנמען יהיה זמין לקחת את ההודעה, התור דוחף את ההודעה לצרכן ומחכה שהצרכן יעבד את ההודעה לחלוטין.
• לאחר שהצרכן מעבד את ההודעה, הוא נמחק לחלוטין מהתור.

פתרונות תור הודעה

ישנן מספר רב של קוד פתוח ותוכנות בחינם המשמשות לתור הודעות.

קפקא: אפאצ’ה קפקא’מערכת ההודעות S היא מערכת רישומי פרסום מחושבת היטב ומערכת תורים שיכולה להתמודד עם נפחי נתונים גבוהים מאוד. Kafka הוא סובלני תקלות ומפקח ללא הרף על הצמתים באמצעות שירותים שונים, מה שמאפשר לעבוד איתם.

ארנב MQ: RabbitMQ הוא אחת ממערכות מתווך העברת הודעות פתוחות ביותר שנמצאות במקור שהטמיעו במקור את פרוטוקול התורים המתקדם (AMQP). תורים הם חוט יחיד במערכת זו, ותור אחד יכול להתמודד עם עד 50,000 הודעות.

Amazon SQS: שירות תורים פשוט של אמזון הוא מערכת תורי הודעות מופצת המשמשת לניתוק שירותי מיקרו ויישומים שונים מבלי לדרוש מהם לשמור על תורי ההודעות שלהם. Amazon SQS מספקת גם ממשק API לשירותי אינטרנט שמשתמשים יכולים לגשת אליו באמצעות שפות תכנות נפוצות.

ActiveMQ: ActiveMQ היא מערכת מתווך נוספת של הודעות שנכתבה ב- Java ויש לה לקוח שירות Message Message מלא של Java. יש לו תמיכה מובנית ב- AJAX ו- REST ותומכת בפרוטוקולים שונים כמו AMQP, MQTT, STOMP וכו ‘.

איך WhatsApp מספק את ההודעות שלך?

לפני שנכנס לאופן התור ההודעות ב- WhatsApp, תן’זה מבין את האפליקציה עצמה. מקודד באמצעות שפת התכנות של ארלנג, WhatsApp הוא המשמש ביותר עם כמעט 2 מיליארד משתמשים חודשיים. WhatsApp משתמש בפרוטוקול ההודעות והנוכחות הניתנות למקור פתוח (XMPP) כדי להקל על הודעות מיידיות בין שני צדדים. בתחילה, WhatsApp התחיל באמצעות השרת ejabbered. עם מספר כה גבוה של משתמשים מדי יום, חיוני ששרתים יתמודדו עם העומס ביעילות והמערכת אמינה. בשנים, הקוד הוקם מחדש, עבר מ- XMPP לפרוטוקול מעוצב פנימי ושינוי כמה רכיבי ליבה כדי לשפר ולהשיג ביצועי שרת אופטימליים.

כמו וכשאתה שולח הודעה, היא תור בשרת עד שהמקלט מתחבר מחדש כדי לאחזר את ההודעות הללו. אז כשאתה טקסט לחבר שלך, ואם הם לא עושים’יש גישה לאינטרנט לקבלת ההודעות, הודעות אלה הן תורים בשרתי WhatsApp, ותהליך זה ידוע בשם “אחסן וקדימה” מַנגָנוֹן. רק כאשר המקלט מקבל את ההודעות הן שנמחקו מהשרת ונמחקו מהתור. מאוחר יותר, כאשר למקלט יש חיבור לאינטרנט, הודעות אלה מועברות אליהם או מאוחדות על ידי המקלט. כאשר המקלט סוף סוף מאשר כי ההודעה התקבלה, אחזור ההודעה המוצלח של ההודעה נשלח חזרה לשרת WhatsApp, וזה כאשר אתה רואה את סימן הסימון הכפול ליד ההודעות שלך.

מבני נתונים אלה נמשכים זמן רב, ובהבנה טובה של זה ייקחו לך דרך ארוכה. אז בפעם הבאה שהמורה שלך מתחיל לדון במבני נתונים, שם לב שם טוב. כֵּן? בסדר?

ובכן, אז נתראה בפעם הבאה!