5.2 سرور tcp مقدماتی

package main

import (
	"fmt"
	"log"
	"net"
)

// ساختار هر پیام در سرور
type Message struct {
	// ادرس ip ارسال کننده پیام
	from    string
	// متن و محتوای پیام
	payload []byte
}

// ساختار سرور
type Server struct {
	// ادرس و یا پورت سرور
	listenAddr string
	// listener
	ln         net.Listener
	// چنل پیام برای انتقال پیام های دریافتی از اتصال ها بین گوروتین ها
	msgch      chan Message
}

// ایجاد یک سرور جدید
func newServer(listenAddr string) *Server {
	return &Server{
		listenAddr: listenAddr,
		msgch:      make(chan Message, 10),
	}
}

// شروع سرور و دریافت اتصال های جدید
func (s *Server) start() error {
	// شروع سرور
	ln, err := net.Listen("tcp", s.listenAddr)
	if err != nil {
		return err
	}
	// مقدار دهی listener
	s.ln = ln
	// با تابع acceptLoop اتصال های جدید به سرور را مدیریت میکنیم
	// با استفاده از go هر اتصال را روی یک گوروتین مجزا مدیریت میکنیم
	go s.acceptLoop()

	return nil
}

// اینجا برای استاپ کردن سرور یک متد جدید تعریف میکنیم
func (s *Server) stop() {
	if s.ln != nil {
		s.ln.Close()
	}
}

func (s *Server) acceptLoop() {
	for {
		// اتصال های موجود را تایید میکنیم متغییر conn را با اتصال مورد نظر مقدار دهی میکنیم
		conn, err := s.ln.Accept()
		if err != nil {
			fmt.Println("accept error:", err)
			continue
		}
		// با استفاده از این تابع مقادیر ارسال شده توسط اتصال را به چنل message میدهیم
		go s.readLoop(conn)
	}
}

func (s *Server) readLoop(conn net.Conn) {
	defer conn.Close()
	buf := make([]byte, 2048)

	for {
		// پیام ارسال شده توسط هر اتصال را به متغییر buf میدهیم
		n, err := conn.Read(buf)
		if err != nil {
			fmt.Println("read error:", err)
			continue
		}

		s.msgch <- Message{
			// ادرس ip ارسال کننده پیام از نوع net.IP
			from:    conn.RemoteAddr().String(),
			// متن پیام
			payload: buf[:n],
		}

		// بعد از دریافت هر پیام یک پیام به عنوان پاسخ ارسال میکنیم
		conn.Write([]byte("your message recived!\n"))
	}
}

func main() {
	// ساخت سرور
	server := newServer(":3000")

	//start the server
	if err := server.start(); err != nil {
		log.Fetal(err)
	}

	go func() {
		// در ازای هر پیام مقادیر آن را چاپ میکنیم
		for msg := range server.msgch {
			fmt.Printf("recived new from connection(%s): %s\n", msg.from, msg.payload)
		}
	}()

	// Run an infinite loop to keep the program running
	select {}

}

▶ اجرای کد کپی ✖ بستن خروجی