解决多客户端初始访问的问题

code/initread.go

@@ -9,7 +9,7 @@ import (
 	"strings"
 	"strings"
 )
 )
 
 
-func return_byte(file_path string, lines_num int) (string, error) {
+func return_init_str(file_path string, lines_num int) (string, error) {
 	lines := int64(lines_num)
 	lines := int64(lines_num)
 	file, err := os.Open(file_path)
 	file, err := os.Open(file_path)
 	if err != nil {
 	if err != nil {

code/server.go

@@ -122,7 +122,8 @@ func server(port int, directory string) {
 // 创建client对象
 // 创建client对象
 func gen(directory string, file_map map[string]map[client]bool) func(ws *websocket.Conn) {
 func gen(directory string, file_map map[string]map[client]bool) func(ws *websocket.Conn) {
 	f := func(ws *websocket.Conn) {
 	f := func(ws *websocket.Conn) {
-		cli := &client{time.Now().String(), ws, make(chan []byte, 1024)}
+		cli := &client{time.Now().String(), ws, make(chan []byte, 1024), ""}
+
 		queryform, err := url.ParseQuery(ws.Request().URL.RawQuery)
 		queryform, err := url.ParseQuery(ws.Request().URL.RawQuery)
 		if err != nil {
 		if err != nil {
 			log.Fatal(err)
 			log.Fatal(err)
@@ -138,13 +139,12 @@ func gen(directory string, file_map map[string]map[client]bool) func(ws *websock
 		if err != nil {
 		if err != nil {
 			return
 			return
 		}
 		}
-		lastcontent_msg, err := return_byte(file_path, 500)
+		lastcontent_msg, err := return_init_str(file_path, 500)
 		if err != nil {
 		if err != nil {
 			log.Fatal(err)
 			log.Fatal(err)
 			return
 			return
 		}
 		}
-		all_content := filename + "$$" + lastcontent_msg
-		manager.broadcast <- []byte(all_content)
+		cli.initstr = lastcontent_msg
 
 
 		// 监控文件
 		// 监控文件
 		if _, ok := file_map[filename]; ok {
 		if _, ok := file_map[filename]; ok {

code/ws.go

@@ -12,6 +12,7 @@ type client struct {
 	id      string
 	id      string
 	socket  *websocket.Conn
 	socket  *websocket.Conn
 	send    chan []byte
 	send    chan []byte
+	initstr string
 }
 }
 
 
 // 客户端管理
 // 客户端管理
@@ -90,7 +91,7 @@ func (c *client) write() {
 	//	manager.unregister <- c
 	//	manager.unregister <- c
 	//	c.socket.Close()
 	//	c.socket.Close()
 	//}()
 	//}()
-
+	c.socket.Write([]byte(c.initstr))
 	for {
 	for {
 		select {
 		select {
 		case message, ok := <-c.send:
 		case message, ok := <-c.send: