האזנה לערוץ בתוך כמה פונקציות במקביל

[nigun]

@יוסף-בן-שמעון
איך אני יאזין למשתנה בין הערוצים? עם האזנה אינסופית עם if ובמקרה שהמשתנה שונה מהקריאה הקודמת לעשות פעולה כל שהיא?

[יוסף בן שמעון]

@nigun אני מדבר על משהו כזה

package main

import (
	"fmt"
	"time"
)

var data string

func main() {
	c := make(chan string)

	go func(c chan string) {
		time.Sleep(2 * time.Second)
		data = "foo"
		close(c)

	}(c)

	go func() {
		<-c
		fmt.Println(data)

	}()
	go func() {
		<-c
		fmt.Println(data)

	}()

	time.Sleep(4 * time.Second)
}

[nigun]

@יוסף-בן-שמעון
אני צריך שליחה רב פעמית
זאת אומרת שאני יוסיף ויוריד מאזינים (שיוכלו להאזין פעם אחת או יותר)
ולשלוח כל הזמן (עם שרת HTTP ) מידע שיעבור לכל המאזינים
את האמת אני צריך לשלוח את המידע לרוב רק למאזין אחד, (כי כל מאזין שייך למשתמש אחר)
ואני שולח את הבקשה בצורה כזאת USER:DATA ולמאזין אני בונה לולאה שמאזינה כל הזמן לערוץ
ואם היוזר שווה ליוזר שלו הוא עושה את הפעולה המבוקשת ואם לא הוא חוזר להאזין,
האם אני עובד נכון או לא?

[יוסף בן שמעון]

@nigun אמר בהאזנה לערוץ בתוך כמה פונקציות במקביל:

האם אני עובד נכון או לא?

אני מאמין שככל שתסביר יותר את הסיטואציה יגדלו הסיכויים שתהיה לך תשובה מדוייקת יותר. (סיטואציה, לא צרכים נגזרים מהסיטואציה)

[nigun]

@יוסף-בן-שמעון
אני לרוב מסתבך כשכותבים מידי הרבה פרטים, אבל אם זה יעזור אז מצויין.
אני בונה מרכזיה באסטריסק שבו אני רוצה לשלוט על חלק מהמאזינים
דהיינו לדחוף להם באמצע האזנה פקודות שונות דרך API משרת HTTP
(אמנם יש לאסטריסק API לשליחת פקודות כאלו ,אבל אני לא הצלחתי להשתמש בו למה שאני צריך)
לכן חשבתי ללכת על הכיוון של ערוצי GO שפשוט כל שיחה (שאני רוצה לשלוט עליה) תאזין לערוץ
ובAPI החיצוני אני ישלח את שם המאזין שבו אני רוצה לשלוט , ואת הפקודה שאני רוצה שהוא יבצע
כשמתקבל בקשה כל המאזינים יבצעו בדיקה האם הבקשה מופנית אליהם, ואם כן יבצעו אותה
לקינוח אני יכול להחזיר באותה צורה הודעה דרך ערוץ אחר לשרת HTTP שהפעולה התבצעה +מידע על התוצאה.

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

[יוסף בן שמעון]

@nigun סורי, לא הצלחתי להבין איך נכנסו הערוצים לתמונה, למה לא לעשות כמו שעשו כל הדורות מימות אסמבלי ועד ימינו, כשמגיע השלב שאתה רוצה לדחוף פקודה למאזין, קרא לפונקציה חיצונית, תעביר לה פרמטרים נצרכים (user, data) ותקבל את הערך המוחזר. (אולי בגלל שאני לא מכיר אסטריסק)

[nigun]

@יוסף-בן-שמעון
פשוט אין שלב שבו אני רוצה לקרוא למאזין
אני תמיד רוצה להשאיר את האופציה לקריאה פתוחה
למשל אם המאזין הרגע התחיל להקשיב לקובץ באורך של שעה, ואני רוצה להעיף אותו משם ,שיקשיב למשהו אחר
אני פשוט בונה את כל הפקודות בצורה אסינכרונית , דהיינו שמפעיל את הפקודה "השמע קובץ פלוני" אבל עם go לפני הפקודה
ומיד אחר כך ממשיך להמתין לפקודות שלי
ככה זה נראה בערך בקוד

 for {
                     	msg := <-c
                        msgsplit := strings.Split(mesege, ":")
                        if msgsplit[0] == user {

                                filename := msgsplit[1]
                           
                                go myAgi.StreamFile(filename, "")
                              

                        }

בקוד הנ"ל המאזין מקבל את הערך מהערוץ בודק האם זה תואם את השם שלו
אם כן , הוא בודק מה הערך השני שנשלח (אחרי הנקודותיים)
ומשמיע את הקובתץ למאזין ומיד אחרי הפקודה להשמיע את הקובץ הוא חוזר להאזין.

[יוסף בן שמעון]

@nigun מה דעתך על שימוש במפה, שהמפתחות שלה הם המזהים של המשתמשים, נראה לי יותר קריא ונקי
כל משתמש שמתחבר אתה מקים לו ערוץ, וכשהוא יתנתק אתה דואג לנתק אותו כדי לשחרר את הערוץ ולעצור את ההאזנה האינסופית

package main

import (
	"fmt"
	"time"
)

var usersChannels = make(map[string]chan string)

func main() {
	go helloUser("A")
	go helloUser("B")
	time.Sleep(500)
	sendDataToUser("A", "Hi")
	sendDataToUser("B", "By")
	time.Sleep(500)
	disconnectUser("A")
	sendDataToUser("A", "Hi")
	time.Sleep(5000)
}

func helloUser(name string) {
	usersChannels[name] = make(chan string) // כאן אתה מוסיף את הערוץ של המשתמש למפה
	for {
		msg, isConnected := <-usersChannels[name] // מאזין למידע מהערוץ
		if !isConnected { // אם המידע הוא שהערוץ נסגר, זה אומר שהמשתמש התנתק ואפשר לעצור את הפונקציה
			return
		}
		fmt.Println(msg)
	}
}

func disconnectUser(name string) { // סוגר את הערוץ כדי לעצור את ההאזנה ומוחק את המשתמש מהמפה
	close(usersChannels[name])
	delete(usersChannels, name)
}

func sendDataToUser(name, data string) {
	channel, hasUser := usersChannels[name]
	if hasUser { // כדי למנוע מצב שהמשתמש כבר התנתק והערוץ שלו לא קיים במפה
		channel <- data
	}
}

[יוסף בן שמעון]

@nigun אליבא דאמת שימוש בערוצים במקרה הזה סתם מכביד על הקוד, קח מוטציה קלילה יותר של זה, במקום ערוצים שמתי קולבקים

package main

import (
	"fmt"
	"time"
)

var usersCallback = make(map[string]func(data string))

func main() {
	go helloUser("A")
	go helloUser("B")
	time.Sleep(500)
	sendDataToUser("A", "Hi")
	sendDataToUser("B", "By")
	time.Sleep(500)
	disconnectUser("A")
	sendDataToUser("A", "Hi")
	time.Sleep(5000)
}

func helloUser(name string) {
	usersCallback[name] = func(msg string) {
		fmt.Println(msg)
	}
}

func disconnectUser(name string) {
	delete(usersCallback, name)
}

func sendDataToUser(name, data string) {
	callback, hasUser := usersCallback[name]
	if hasUser {
		callback(data)
	}
}

[nigun]

@יוסף-בן-שמעון
את האמת אני לא מכיר בכלל את הקונספט של קולבקים
כנראה אני אשב על זה מתי שהוא ללמוד את זה (לא נראה מסובך)