鐃緒申鐃緒申奪箸燃悗鐃� Go 鐃粛ットワー鐃緒申鐃竣ワ申鐃緒申鐃緒申潺鐃�
鐃緒申単鐃淑ワ申鐃緒申奪肇廛鐃緒申鐃緒申鐃緒申蓮鐃緒申優奪肇錙種申鐃緒申廛鐃緒申鐃緒申鐃淳ワ申鐃術のフレー鐃緒申錙種申鐃緒申任鐃緒申鐃緒申屬離鐃緒申鐃竣ワ申廛鐃緒申鐃緒申鐃緒申任鐃緒申鐃�
echo 鐃緒申鐃緒申鐃出￥申鐃緒申 Hello World 鐃夙わ申鐃緒申覆蕁�鐃緒申鐃緒申奪箸鐃� FizzBuzz 鐃夙わ申鐃獣わ申鐃夙わ申鐃緒申鐃叔わ申鐃順う鐃緒申
鐃夙りあ鐃緒申鐃緒申動鐃緒申鐃緒申鐃緒申鐃塾ワ申鐃緒申奪箸覆鐃緒申鐃緒申任發刻申鐃緒申忘鐃緒申鐃処う鐃祝なわ申泙鐃緒申鐃緒申鐃緒申泙鐃緒申鐃祝ワ申鐃緒申奪箸鐃緒申襪鰹申箸如鐃� 鐃粛ットワー鐃緒申鐃竣ワ申鐃緒申鐃緒申潺鵐阿嚢佑鐃緒申覆鐃緒申箸鐃緒申鐃緒申覆鐃緒申鐃緒申筌�鐃初ー鐃緒申鐃緒申鐃塾緒申鐃竣な器申鐃獣わ申悗屬鐃緒申箸鐃緒申任鐃緒申泙鐃緒申鐃�
鐃夙わ申鐃緒申鐃緒申鐃夙で￥申 Go 鐃叔ワ申鐃緒申廛鐃淑ワ申鐃緒申奪箸鐃緒申鐃緒申鐃緒申鐃銃みまわ申鐃緒申鐃緒申 (鐃緒申鐃緒申鐃緒申鐃緒申鐃緒申鐃緒申)
鐃淑降￥申鐃緒申鐃緒申佑鐃緒申討匹鐃緒申鐃緒申鐃緒申澤廚鐃緒申鐃術わ申鐃緒申鐃塾わ申鐃緒申鐃緒申發件申討鐃緒申鐃緒申泙鐃緒申鐃�
鐃緒申慮鐃緒申鐃駿わ申鐃楯ワ申鐃緒申鐃�
- 鐃緒申鐃緒申離鐃緒申薀わ申鐃緒申鐃夙へわ申鐃緒申鐃緒申鐃緒申長鐃緒申鐃緒申鐃峻わ申鐃緒申鐃曙た鐃緒申鐃祝￥申他鐃塾ワ申鐃初イ鐃緒申鐃緒申箸悗鐃緒申鐃緒申鐃緒申鐃緒申戮鐃淑わ申鐃処う鐃祝わ申鐃暑。
- 鐃緒申鐃初イ鐃緒申鐃緒申箸鐃緒申鐃緒申任鐃緒申鐃塾は￥申 (1)鐃暑ー鐃緒申側鐃緒申鐃緒申 kick 鐃緒申鐃緒申鐃緒申, (2)鐃緒申鐃緒申鐃緒申鐃初ー, (3)鐃緒申鐃緒申鐃緒申鐃初ー
鐃緒申3鐃緒申鐃緒申鐃粛わ申鐃緒申必鐃竣わ申鐃緒申鐃暑。 - 鐃緒申鐃緒申鐃峻わ申鐃塾ワ申奪鐃緒申鐃緒申鐃緒申鐃縮居申鐃緒申造縫丱奪侫鐃緒申鐃藷グわ申鐃緒申函鐃緒申鐃獣ワ申鐃緒申鐃緒申鐃緒申鐃緒申鐃緒申鐃緒申鐃緒申鐃緒申鐃緒申納鐃緒申鐃緒申鐃緒申覆鐃緒申茲�鐃緒申
鐃緒申鐃初イ鐃緒申鐃緒申箸鐃緒申鐃緒申鐃夙ワ申鐃緒申鐃夙わ申鐃緒申鐃獣てわ申鐃殉わ申鐃塾で￥申鐃銃易わ申 DoS 鐃緒申鐃盾が鐃緒申能鐃祝なってわ申鐃殉わ申鐃緒申
鐃緒申鐃塾常申鐃緒申鐃緒申鐃夙わ申鐃緒申鐃獣わ申 OOM Killer 鐃緒申動鐃緒申鐃淑どわ申鐃緒害鐃緒申鐃緒申鐃緒申襦�
Read 鐃塾ワ申鐃初ー鐃緒申鐃緒申
鐃緒申鐃緒申鐃緒申鐃初ー鐃緒申鐃緒申鐃叔なわ申鐃緒申鐃緒申鐃緒申鐃緒申鐃初ー鐃巡サ鐃緒申鐃出￥申鐃緒申鐃緒申鐃� kick 鐃淑どでわ申 Read() 鐃緒申鐃銃わ申鐃緒申 goroutine 鐃緒申澆鐃緒申必鐃竣わ申鐃緒申鐃緒申泙鐃緒申鐃�
Go 鐃緒申 Read() 鐃緒申同鐃緒申的鐃緒申 API 鐃祝なってわ申鐃緒申里如鐃� select 鐃淑どわ申箸辰鐃渋常申鐃� channel
鐃緒申鐃緒申鐃緒申鐃緒申圓弔鐃緒申箸呂任鐃緒申泙鐃緒申鐃�
Read() 鐃峻わ申鐃緒申 goroutine 鐃緒申澆鐃緒申砲蓮鐃� Read() 鐃薯エラー鐃緒申鐃緒申澆鐃緒申鐃緒申鐃宿�鐃竣わ申鐃緒申鐃緒申泙鐃緒申鐃�
net.Conn 鐃熟ワ申鐃緒申奪疋鐃緒申鐃緒申佞忘鐃緒申鐃銃わ申鐃緒申里如鐃渋常申鐃� goroutine 鐃緒申鐃緒申 conn.Close()
鐃緒申討喀个鐃緒申鐃緒申箸鐃� Read() 鐃緒申澆鐃緒申鐃殉わ申鐃緒申
鐃緒申鐃塾常申隋� Read() 鐃緒申 io.EOF 鐃緒申鐃緒申鐃叔なわ申鐃緒申 closed connection 鐃緒申鐃緒申 Read 鐃緒申鐃処う鐃夙わ申鐃緒申鐃夙わ申鐃緒申
鐃緒申鐃初ー鐃緒申鐃緒申鐃緒申呂鐃夙�鐃緒申鐃緒申鐃暑こ鐃夙になわ申泙鐃緒申鐃緒申鐃緒申離鐃緒申蕁種申鐃� io.EOF 鐃塾よう鐃祝醐申鐃緒申鐃緒申鐃曙た鐃術随申鐃緒申鐃術意わ申鐃緒申鐃�
鐃緒申鐃緒申錣縁申任呂鐃緒申鐃殉わ申鐃緒申
鐃粛ットワー鐃緒申鐃緒申鐃初ー鐃緒申鐃緒申鐃緒申鐃緒申鐃緒申忙弔鐃緒申鐃緒申鐃緒申隼廚鐃緒申鐃緒申發件申鐃殉わ申鐃藷が￥申鐃緒申箸鐃緒申 Go 鐃緒申 conn.Read() 鐃緒申
鐃瞬わ申鐃緒申鐃初ー鐃塾逸申鐃緒申鐃緒申鐃緒申鐃緒申鐃緒申討鐃緒申覆鐃緒申里如鐃緒申鐃所き鐃獣わ申鐃緒申鐃緒申(鐃緒申鐃暑い鐃緒申 EOF 鐃緒申鐃緒申鐃緒申鐃緒申鐃�)鐃塾ワ申鐃初ー鐃緒申鐃緒申鐃緒申忙弔鐃緒申茲�鐃祝わ申鐃殉わ申鐃順う鐃緒申
他鐃緒申 goroutine 鐃緒申鐃緒申 conn.Close() 鐃緒申鐃銃ばわ申討鐃緒申襪�鐃宿わ申鐃緒申鐃緒申鐃緒申鐃塾わ申判鐃叔わ申鐃緒申鐃緒申法鐃緒申鐃淑わ申鐃塾で￥申
client.Stop() 鐃緒申討喀个鐃緒申討鐃緒申鐃緒申泙鐃緒申鐃緒申鐃緒申隆愎鐃緒申僚鐃緒申鐃緒申聾鐃述わ申鐃殉わ申鐃緒申
func (c *Client) receiver() {
defer c.Stop() // receiver 鐃緒申鐃淳まわ申箸鐃緒申呂鐃緒申覆蕕削申鐃緒申里鐃淳わ申鐃�.
// 1鐃峻わ申512byte鐃緒申鐃緒申鐃渋わ申鐃緒申.
reader := bufio.NewReaderSize(c.conn, 512)
for {
// Read() 鐃緒申鐃緒申 goroutine 鐃緒申鐃緒申鐃叔わ申鐃緒申里鐃緒申颪靴鐃緒申鐃�
// 鐃緒申側鐃緒申 conn.Close() 鐃緒申鐃銃￥申鐃緒申鐃初ー鐃叔誌申未里鐃緒申鐃�.
// 鐃緒申鐃初ー鐃緒申 io.EOF 鐃叔わ申鐃緒申箸聾造鐃淑わ申鐃緒申
msg, err := reader.ReadString(byte('\n'))
if msg != "" {
//log.Printf("receiver: Received %#v", msg)
c.recv <- msg
}
if err != nil {
log.Println("receiver: ", err)
return
}
}
}鐃緒申鐃初イ鐃緒申鐃緒申箸鐃緒申鐃緒申能鐃緒申鐃�
鐃緒申奪鐃緒申鐃緒申鐃緒申鐃緒申鐃緒申鐃緒申鐃緒申他鐃緒申 goroutine 鐃緒申鐃緒申 conn.Close() 鐃緒申討喀个鐃緒申鐃�
鐃緒申鐃緒申半端鐃淑ワ申奪鐃緒申鐃緒申鐃緒申鐃緒申鐃緒申鐃緒申能鐃緒申鐃緒申鐃緒申鐃緒申里如鐃� conn.Close() 鐃緒申鐃緒申鐃緒申 goroutine 鐃緒申鐃緒申圓鐃緒申泙鐃緒申鐃�
鐃緒申鐃塾わ申鐃緒申法鐃� channel 鐃緒申鐃緒申鐃術わ申鐃緒申鐃緒申鐃緒申 goroutine 鐃緒申鐃緒申鐃緒申鐃緒申里鐃峻わ申鐃殉わ申鐃緒申
鐃緒申鐃緒申離鐃緒申鐃竣ワ申鐃緒申鐃緒申鐃淳わ申鐃淑わ申鐃夙わ申鐃緒申鐃淑わ申鐃塾わ申鐃緒申鐃緒申 goroutine 鐃緒申鐃緒申 (鐃緒申鐃緒申 goroutine 鐃緒申
conn.Close() 鐃緒申討屬鐃緒申箸納鐃緒申鐃� goroutine 鐃緒申澆泙鐃�)鐃叔わ申鐃緒申鐃緒申鐃緒申澆鐃緒申覆鐃緒申箸鐃緒申鐃緒申覆鐃�
goroutine 鐃緒申鐃緒申鐃緒申鐃緒申鐃緒申鐃祝わ申鐃緒申分鐃緒申鐃緒申 channel 鐃緒申鐃緒申覆鐃緒申鐃出なわ申泙鐃緒申鐃�
鐃殉わ申鐃緒申鐃緒申鐃初イ鐃緒申鐃緒申箸鐃緒申鐃淳わ申複鐃緒申鐃塾常申鐃叔￥申複鐃緒申鐃緒申 goroutine 鐃緒申鐃緒申討个鐃緒申鐃叔緒申鐃緒申鐃緒申鐃緒申鐃殉わ申鐃緒申
鐃緒申鐃緒申鐃緒申里忙箸鐃緒申鐃緒申鐃緒申優鐃舜わ申鐃緒申鐃緒申鐃緒申鐃瞬ワ申鐃獣ワ申鐃緒申鐃緒申箸鐃緒申鐃緒申覆鐃緒申里如鐃緒申鐃緒申里茲�鐃淑ワ申鐃緒申鐃宿になわ申任鐃緒申腓�鐃緒申
type Client struct {
// ...
stopA chan bool,
stopB chan bool,
// ...
}
func newClient() *Client {
c := &Client{
//...
// 1鐃緒申魯屮鐃緒申奪鐃緒申鐃緒申鐃緒申鐃緒申鐃緒申鐃緒申任鐃緒申鐃処う鐃祝￥申 buffered channel 鐃緒申箸鐃�.
stopA: make(chan bool, 1),
stopB: make(chan bool, 1),
// ...
}
// ...
return c
}
func (c *Client) Stop() {
select {
case c.stopA <- true:
default: // 鐃緒申鐃緒申鐃緒申潺鐃獣ワ申鐃緒申鐃緒申鐃緒申鐃緒申鐃緒申鐃緒申鐃銃わ申鐃銃わ申屮鐃緒申奪鐃緒申鐃緒申覆鐃�
}
select {
case c.stopB <- true:
default:
}
//...
}鐃緒申鐃緒申鐃盾う鐃緒申鐃緒申鐃准にわ申鐃暑た鐃緒申法鐃� channel 鐃緒申 close 鐃緒申鐃獣ワ申鐃緒申鐃緒申鐃緒申鐃緒申忙箸鐃緒申泙鐃緒申鐃�
close() 鐃緒申同鐃緒申鐃緒申鐃緒申鐃粛ワ申鐃緒申个鐃緒申鐃淑ｏ申鐃緒申鐃銃び出わ申鐃緒申2鐃緒申鐃淑降わ申 panic 鐃薯起わ申鐃緒申鐃塾で￥申 recover
鐃緒申箸辰鐃縮居申襪件申泙鐃緒申鐃�
func (c *Client) Stop() {
// 鐃緒申鐃淑みわ申 defer recover() 鐃叔はワ申鐃緒申
defer func() {
if r := recover(); r != nil {
log.Println(r)
}
}()
close(c.stop)
}
func (c *Client) sender() {
defer func() {
if err := c.conn.Close(); err != nil {
log.Println(err)
}
log.Printf("%v is closed", c)
clientWait.Done() // graceful shutdown鐃緒申. 鐃緒申鐃�
c.closed <- c // room 鐃塾ワ申鐃初イ鐃緒申鐃緒申抜鐃緒申鐃緒申鐃�. 鐃緒申鐃�
}()
for {
select {
case <-c.stop:
//log.Println("sender: Received stop")
return
case msg := <-c.send:
//log.Printf("sender: %#v", msg)
_, err := c.conn.Write([]byte(msg))
// net.Error.Temporary() 鐃緒申魯鐃宿ルす鐃緒申必鐃竣わ申多分鐃淑わ申.
// 鐃書き刻申鐃淳でわ申鐃緒申鐃出ワ申鐃夙随申鐃緒申 len(msg) 鐃緒申蠑�鐃緒申鐃緒申鐃緒申鐃緒申必鐃緒申 err != nil 鐃淑ので￥申
// Write() 鐃緒申鐃緒申鐃緒申鐃緒申鐃粛わ申無鐃暑し鐃銃ワ申鐃初ー鐃熟ワ申疋鐃藷グわ申鐃緒申鐃緒申圓鐃�
if err != nil {
log.Println(err)
return
}
}
}
}鐃緒申鐃緒申鐃駿縁申隆鐃緒申鐃�
鐃緒申鐃緒申側鐃緒申1鐃緒申奪鐃緒申鐃緒申鐃緒申離鐃緒申鐃緒申鐃緒申鐃緒申鐃緒申造鐃緒申討鐃緒申鐃塾で￥申鐃緒申鐃緒申鐃峻わ申鐃緒申奪鐃緒申鐃緒申鐃緒申鐃緒申鐃緒申鐃緒申鐃緒申造鐃緒申鐃出￥申
鐃緒申鐃緒申鐃縮居申鐃緒申造忙箸鐃緒申鐃緒申箸鐃緒申匹鐃緒申泙鐃緒申鐃�
鐃緒申鐃緒申 goroutine 鐃舜ワ申奪鐃緒申鐃緒申鐃緒申鐃緒申鐃緒申鐃� channel 鐃緒申 buffered 鐃祝わ申鐃暑こ鐃夙で￥申
room goroutine 鐃緒申鐃緒申鐃緒申鐃緒申鐃緒申鐃緒申圓鐃緒申鐃緒申覆鐃緒申箸鐃緒申鐃緒申鐃緒申未鐃緒申鐃緒申鐃緒申鐃緒申鐃殉わ申鐃緒申
鐃出ッフワ申鐃緒申鐃緒申鐃獣ぱわ申鐃祝なっわ申鐃緒申鐃緒申単鐃祝ワ申奪鐃緒申鐃緒申鐃緒申鐃� drop 鐃緒申鐃緒申函鐃緒申鐃緒申薀わ申鐃緒申鐃夙は駕申鐃緒申鐃塾らず鐃緒申 鐃緒申鐃緒申鐃緒申鐃緒申鐃緒申奪鐃緒申鐃緒申鐃緒申鐃緒申鐃夙器申鐃緒申砲覆辰討鐃緒申泙鐃緒申里如鐃緒申鐃緒申両鐃緒申魯鐃緒申薀わ申鐃緒申鐃夙わ申鐃緒申鐃叔わ申鐃殉わ申鐃緒申
鐃緒申鐃緒申鐃緒申鐃緒申鐃出ッフワ申鐃緒申鐃緒申鐃獣ぱわ申鐃祝なわ申鐃緒申魯優奪肇錙種申鐃緒申鐃緒申鐃緒申鐃緒申鐃緒申戮譴随申鐃緒申鐃緒申鐃緒申任呂鐃緒申鐃殉わ申鐃緒申
CPU鐃緒申鐃緒申鐃緒申1鐃縦わ申鐃緒申無鐃緒申鐃塾にわ申鐃緒申鐃緒申鐃緒申離鐃緒申薀わ申鐃緒申鐃夙を扱わ申鐃緒申鐃淑どに￥申鐃緒申奪鐃緒申鐃緒申鐃緒申鐃塾�鐃縮わ申多鐃緒申鐃夙￥申
単鐃緒申鐃緒申鐃銃のワ申鐃初イ鐃緒申鐃緒申箸鐃緒申鐃緒申鐃� goroutine 鐃祝緒申分鐃祝実行醐申鐃緒申鐃峻わ申鐃熟ってなわ申鐃緒申鐃緒申鐃塾駕申能鐃緒申鐃緒申鐃緒申鐃緒申泙鐃緒申鐃�
鐃淑ので￥申鐃出ッフワ申鐃緒申鐃緒申鐃獣ぱわ申鐃祝なっわ申鐃緒申鐃緒申無鐃緒申鐃渋わ申鐃峻つのわ申鐃薯けまわ申鐃緒申鐃緒申鐃緒申鐃緒申鐃緒申屬鐃緒申圓弔鐃緒申箸砲鐃緒申泙鐃緒申鐃� goroutine 鐃塾実刻申優鐃緒申鐃縮わ申鐃緒申鐃緒申任鐃緒申覆鐃緒申里如鐃緒申鐃緒申泙鐃祝ワ申鐃初イ鐃緒申鐃緒申箸鐃渋随申鐃緒申鐃緒申圓鐃緒申鐃緒申鐃緒申鐃緒申 鐃峻ってわ申鐃暑ク鐃初イ鐃緒申鐃緒申箸鐃緒申鐃緒申鐃� goroutine 鐃祝実行醐申鐃緒申与鐃緒申鐃緒申鐃淑わ申鐃緒申能鐃緒申鐃熟残わ申泙鐃緒申鐃緒申鐃� 鐃緒申鐃緒申任鐃緒申鐃緒申抻鐃緒申鐃銃逸申鐃熟わ申鐃淑わ申鐃緒申蠅刻申鐃熟わ申鐃叔わ申鐃緒申
// Send msg to the client.
func (c *Client) Send(msg string) error {
// 鐃緒申鐃緒申離鐃緒申薀わ申鐃緒申鐃夙わ申鐃駿わ申鐃夙わ申鐃祝￥申鐃緒申鐃塾わ申鐃駿わ申鐃緒申鐃緒申鐃緒申鐃淑わ申鐃塾で￥申 select 鐃緒申箸辰鐃�
// 鐃緒申鐃緒申鐃緒申鐃緒申鐃緒申鐃叔わ申鐃淑わ申鐃緒申鐃緒申鐃緒申鐃緒申襦�
// 鐃緒申鐃緒申鐃緒申鐃緒申 room goroutine 鐃緒申 sender goroutine 鐃緒申鐃渋�鐃緒申鐃緒申辰討襪随申鐃祝ワ申鐃緒申鐃粛ワ申鐃�
// 鐃出ッフワ申鐃緒申鐃緒申鐃獣ぱわ申鐃祝なってわ申鐃緒申鐃緒申硫鐃叔緒申鐃緒申發�鐃緒申里如鐃緒申鐃緒申鐃緒申鐃瞬わ申鐃峻わ申.
// 鐃出ッフワ申鐃祝駈申鐃緒申鐃緒申鐃緒申鐃緒申箸鐃緒申忙鐃緒申鐃� time.After 鐃緒申鐃緒申鐃緒申鐃緒申鐃緒申里鐃縮居申未覆里如鐃� select 鐃緒申2鐃淑にわ申鐃緒申.
select {
case c.send <- msg:
return nil
default:
select {
case c.send <- msg:
return nil
case <-time.After(time.Millisecond * 10):
return errors.New("Can't send to client")
}
}
}room 鐃塾ワ申鐃初イ鐃緒申鐃緒申抜鐃緒申鐃�
鐃緒申鐃緒申鐃殉ででワ申鐃初イ鐃緒申鐃緒申箸鐃緒申鐃緒申鐃緒申鐃緒申鐃淑�鐃熟でわ申鐃銃わ申鐃殉わ申鐃緒申鐃緒申鐃緒申鐃緒申鐃初イ鐃緒申鐃緒申箸鐃緒申弔鐃緒申鐃緒申鐃緒申鐃� room 側鐃緒申鐃緒申鐃獣てわ申
鐃緒申鐃初イ鐃緒申鐃緒申醗鐃緒申鐃緒申鐃緒申鐃緒申亮造砲鐃緒申離鐃緒申薀わ申鐃緒申鐃夙わ申鐃緒申鐃緒申鐃淑わ申鐃夙￥申 channel 鐃緒申 GC 鐃緒申鐃曙ず鐃緒申鐃緒申蝓種申鐃�
鐃緒申鐃銃わ申鐃殉わ申鐃殉わ申鐃緒申
鐃緒申鐃緒申 goroutine 鐃叔確実わ申 conn.Close() 鐃緒申討喀个鐃緒申茲�鐃祝わ申鐃緒申鐃塾で￥申鐃緒申鐃緒申鐃叔逸申鐃緒申 room 鐃緒申
鐃緒申奪鐃緒申鐃緒申鐃緒申鐃緒申鐃緒申鐃処う鐃祝わ申鐃殉わ申鐃緒申
room 鐃緒申鐃緒申鐃緒申 client 鐃緒申鐃緒申鐃熟￥申 slice 鐃叔はなわ申 map 鐃祝わ申鐃暑こ鐃夙で￥申同鐃緒申鐃緒申続鐃緒申鐃緒申鐃緒申鐃緒申鐃緒申鐃緒申鐃緒申
鐃緒申鐃初イ鐃緒申鐃緒申蛤鐃緒申鐃祝わ申鐃緒申鐃緒申鐃緒申屬鐃緒申鐃緒申砲任鐃緒申泙鐃緒申鐃�
slice 鐃緒申鐃緒申鐃緒申鐃緒申任虜鐃緒申鐃緒申鐃緒申味鐃緒申罠わ申鐃緒申鐃緒申里鐃�
(slice 鐃緒申未鐃銃わ申鐃舜醐申鐃緒申鐃緒申鐃祝誌申鐃夙わ申鐃縦ってわ申鐃�GC鐃緒申鐃緒申覆鐃緒申里妊蝓種申鐃緒申鐃緒申鐃塾で縮わ申鐃緒申鐃緒申鐃緒申鐃緒申鐃緒申悒鐃緒申鐃緒申佑鐃緒申鐃緒申鐃緒申鐃緒申鐃宿�鐃竣わ申鐃緒申鐃緒申)鐃緒申
鐃緒申鐃緒申鐃緒申鐃緒申 delete() 鐃緒申鐃緒申鐃緒申鐃緒申悩僂鐃� map 鐃緒申鐃緒申鐃緒申鐃准でわ申鐃緒申
func newRoom() *Room {
r := &Room{
Join: make(chan *Client),
Closed: make(chan *Client),
Recv: make(chan string),
Purge: make(chan bool),
Stop: make(chan chan bool),
clients: make(map[*Client]bool),
}
go r.run()
return r
}
func (r *Room) run() {
defer log.Println("Room closed.")
for {
select {
case c := <-r.Join:
log.Printf("Room: %v is joined", c)
if err := r.sendLog(c); err != nil {
log.Println(err)
c.Stop()
} else {
r.clients[c] = true
}
case c := <-r.Closed: // c 鐃緒申鐃緒申澪僂鐃�.
log.Printf("Room: %v has been closed", c)
// delete 鐃熟誌申鐃所さ鐃曙た鐃緒申鐃緒申鐃緒申無鐃緒申鐃獣わ申鐃初何鐃盾し鐃淑わ申
delete(r.clients, c)
/// ...
}graceful shutdown
鐃緒申鐃塾ワ申鐃緒申奪箸任麓鐃緒申鐃緒申鐃緒申討泙鐃緒申鵑�￥申鐃純え鐃出ワ申鐃緒申鐃出￥申鐃緒申了鐃緒申鐃緒申鐃緒申続鐃緒申離鐃緒申薀わ申鐃緒申鐃夙に緒申了鐃緒申奪鐃緒申鐃緒申鐃緒申鐃緒申鐃緒申鐃緒申鐃緒申討鐃緒申鐃� 鐃緒申続鐃緒申了鐃緒申鐃緒申箸鐃緒申辰鐃緒申鐃緒申佑砲鐃緒申鐃緒申鐃緒申覆鐃緒申能鐃緒申鐃盾あ鐃緒申泙鐃緒申鐃� graceful shutdown 鐃塾種申鐃緒申鐃緒申鐃緒申鐃緒申鐃緒申鐃銃みまわ申鐃順う鐃緒申
鐃緒申鐃塾ワ申鐃緒申奪箸任鐃� room 鐃緒申鐃縦わ申鐃銃わ申鐃初、鐃緒申鐃緒申鐃初イ鐃緒申鐃緒申箸鐃緒申鐃緒申任鐃緒申圓辰董鐃緒申廛鐃緒申鐃緒申鐃緒申鐃塾誌申鐃緒申鐃塾わ申鐃宿わ申鐃緒申鐃緒申鐃叔わ申鐃緒申/> SIGINT (Ctrl-C 鐃緒申鐃緒申鐃緒申鐃緒申) 鐃緒申 SIGTERM (鐃緒申鐃竣ワ申鐃緒申鐃淑わ申鐃緒申 kill 鐃緒申鐃殉ワ申匹鐃緒申鐃緒申鐃緒申鐃�) 鐃緒申 graceful shutdown 鐃緒申鐃殉わ申鐃順う鐃緒申
go 鐃緒申 main() 鐃舜随申鐃緒申鐃緒申了鐃緒申鐃緒申函鐃渋常申砲鐃緒申鐃緒申鐃� goroutine 鐃緒申動鐃緒申鐃銃わ申鐃銃わ申廛鐃緒申鐃緒申鐃準が鐃緒申了鐃緒申鐃殉わ申鐃緒申
鐃淑ので￥申 main() 鐃舜随申鐃塾最醐申如鐃緒申鐃緒申鐃緒申淵鐃緒申鐃峻って￥申 room 鐃緒申鐃緒申潺鐃獣ワ申鐃緒申鐃緒申鐃緒申鐃緒申鐃所、鐃緒申鐃緒申鐃初イ鐃緒申鐃緒申箸鐃�
鐃緒申鐃叔わ申鐃峻つとわ申鐃緒申鐃緒申鐃緒申鐃緒申颪�まわ申鐃緒申
鐃緒申鐃初イ鐃緒申鐃緒申箸僚鐃塾誌申鐃緒申圓弔里鐃� sync.WaitGroup 鐃緒申鐃緒申鐃術わ申鐃緒申里鐃緒申擇任鐃緒申鐃�
鐃緒申鐃初イ鐃緒申鐃緒申鐃緒申鐃緒申鐃緒申鐃緒申鐃� wg.Add(1) 鐃緒申圓鐃緒申鐃緒申鐃緒申鐃� goroutine 鐃緒申 conn.Close() 直鐃緒申鐃� wg.Done()
鐃緒申圓鐃緒申鐃� main 鐃舜随申鐃塾最醐申任鐃� wg.Wait() 鐃緒申討咾泙鐃緒申鐃�
// main() 鐃塾最醐申
sigc := make(chan os.Signal, 1)
signal.Notify(sigc, syscall.SIGUSR1, syscall.SIGTERM, os.Interrupt)
for sig := range sigc {
switch sig {
case syscall.SIGUSR1:
room.Purge <- true
case syscall.SIGTERM, os.Interrupt:
room.Stop <- true
// 鐃緒申鐃銃わ申 client 鐃緒申 sender 鐃緒申鐃峻わ申
clientWait.Wait()
// 鐃緒申鐃緒申鐃�
return
}
}func (c *Client) sender() {
defer func() {
if err := c.conn.Close(); err != nil {
log.Println(err)
}
log.Printf("%v is closed", c)
clientWait.Done()
c.closed <- c
}()
//...鐃殉とわ申
鐃緒申鐃緒申奪箸魯鐃緒申鐃竣ワ申妨鐃緒申鐃緒申泙鐃緒申鐃緒申鐃緒申鐃緒申鐃緒申鐃緒申鐃緒申丱鐃出ワ申鐃夙�鐃緒申鐃緒申鐃緒申里如鐃緒申螢�鐃緒申鐃緒申鐃緒申 - 鐃曙ス鐃楯ンス件申鐃塾プワ申鐃緒申鐃緒申鐃緒申鐃緒申
鐃書くのわ申鐃書しわ申鐃叔わ申鐃緒申
鐃緒申鐃緒申分鐃緒申鐃緒申鐃緒申奪箸鐃緒申鐃緒申鐃緒申鐃緒申颪韻鐃処う鐃祝なわ申弌鐃緒申鐃緒申鐃淑鰹申鐃塾ワ申鐃緒申鐃出￥申鐃緒申鐃淳計をすわ申箸鐃緒申鐃緒申腓わ申忙鐃緒申佑砲覆鐃熟わ申鐃叔わ申鐃緒申
鐃緒申鐃塾プワ申鐃緒申鐃緒申鐃熟誌申覆鐃祝考わ申鐃緒申鐃淳計わ申鐃緒申鐃緒申里任鐃緒申鐃緒申鐃渋常申鐃緒申匹鐃緒申鐃緒申鐃緒申鐃緒申鐃塾ってわ申鐃暑・鐃竣わ申鐃縦わ申鐃緒申鐃緒申鐃緒申 鐃緒申鐃述駈申鐃緒申鐃銃わ申鐃緒申鐃緒申鐃緒申鐃緒申
@methane
