Golang l&agrave; một ng&ocirc;n ngữ lập tr&igrave;nh m&atilde; nguồn mở bao gồm nhiều t&iacute;nh năng như thư viện chuẩn, quản l&yacute; g&oacute;i, nhập kiểu tĩnh, hỗ trợ kiểm thử v&agrave; nền tảng độc lập . Golang l&agrave; một trong những ng&ocirc;n ngữ kh&aacute; được ưa chuộng gần đ&acirc;y v&agrave; c&oacute; nhu cầu sử dụng cao trong lập tr&igrave;nh. Kh&oacute;a học n&agrave;y TEK4.VN sẽ cung cấp c&aacute;c kh&aacute;i niệm cơ bản v&agrave; n&acirc;ng cao về Golang, v&iacute; dụ xử l&yacute; ngoại lệ, mạng v&agrave; tạo mẫu. Trong kh&oacute;a học n&agrave;y, bạn cũng sẽ học c&aacute;c kh&aacute;i niệm cốt l&otilde;i về t&iacute;nh đồng thời. Bạn cũng sẽ được cung cấp c&aacute;c c&acirc;u hỏi v&agrave; b&agrave;i tập gi&uacute;p luyện tập kỹ năng tư duy phản biện v&agrave; giải quyết vấn đề sử dụng Golang. Sau khi ho&agrave;n th&agrave;nh kh&oacute;a học, bạn c&oacute; thể sử dụng Golang để viết c&aacute;c ứng dụng hiệu quả v&agrave; thực tế sử dụng t&iacute;nh đồng thời.
<h3 style="text-align: justify;">Mục ti&ecirc;u</h3>
<ul style="text-align: justify;">
<li style="font-weight: 400;" aria-level="1">Học c&aacute;c kh&aacute;i niệm cơ bản của Golang</li>
<li style="font-weight: 400;" aria-level="1">Học về t&iacute;nh đồng thời v&agrave; c&aacute;c khối kiến thức x&acirc;y dựng li&ecirc;n quan đến t&iacute;nh đồng thời</li>
<li style="font-weight: 400;" aria-level="1">Học c&aacute;ch x&acirc;y dựng một ứng dụng web ho&agrave;n chỉnh bằng Golang</li>
</ul>

Golang từ cơ bản đến nâng cao

Trong b&agrave;i học n&agrave;y, ch&uacute;ng ta sẽ l&agrave;m quen với kỹ thuật Fan-In, Fan-Out được sử dụng để multiplex v&agrave; demultiplex dữ liệu trong Go.
Fan-In l&agrave; kỹ thuật kết hợp dữ liệu từ nhiều đầu v&agrave;o th&agrave;nh một thực thể duy nhất. Trong khi đ&oacute;, Fan-Out c&oacute; nghĩa l&agrave; chia dữ liệu từ một nguồn th&agrave;nh nhiều phần nhỏ hơn. Trong b&agrave;i học n&agrave;y, ch&uacute;ng ta sẽ học c&aacute;ch sử dụng cả hai kỹ thuật n&agrave;y.
<img style="width: 600px; display: block; margin-left: auto; margin-right: auto;" src="https://tek4.vn/public_files/b6016879-ab66-481b-bfe1-eceeed6b7b63" alt="Fan-In, Fan-Out" />
Dưới đ&acirc;y l&agrave; đoạn code từ b&agrave;i học trước, trong đ&oacute; hai hoạt động nhận đang chặn lẫn nhau.
<pre class="language-go" data-content="%C2%A0%C2%A0%C2%A0%C2%A0fmt.Println(%3C-positionChannel1)%0A%C2%A0%C2%A0%C2%A0%C2%A0fmt.Println(%3C-positionChannel2)" data-language="go" data-ace-language="golang" data-name-language="GoLang" data-main-file="main.go"><code> fmt.Println(&lt;-positionChannel1)
 fmt.Println(&lt;-positionChannel2)</code></pre>
C&aacute;c hoạt động n&agrave;y đang thay phi&ecirc;n nhau in gi&aacute; trị l&ecirc;n console v&agrave; tiếp tục thực hiện t&iacute;nh to&aacute;n tiếp theo. 
<div class="code-editor__wrapped code-editor__edit__wrapped" data-id="1eb3009e-76b4-4bca-87e4-adedb0d291c2">
<table class="code-editor__table" data-id="32113df8-96fa-4e54-b85a-e3d3215beb7a">
<tbody>
<tr class="code-editor__edit__row__first">
<td colspan="2">RUN_CODE (*** ph&acirc;n biệt ***)</td>
</tr>
<tr>
<td>GoLang</td>
<td>
<pre class="language-go" data-content="package" data-language="go" data-ace-language="golang" data-name-language="GoLang" data-main-file="main.go"><code>package main

import ( "fmt"
		"math/rand"
		"time")

func updatePosition(name string) &lt;-chan string { 
	positionChannel := make(chan string)

	go func() {
		for i := 0; ; i++ {
			positionChannel &lt;- fmt.Sprintf("%s %d", name , i)
			time.Sleep(time.Duration(rand.Intn(1e3)) * time.Millisecond)
		}
	}()

	return positionChannel
}

func main() {
	positionChannel1 := updatePosition("Legolas :") 
	positionChannel2 := updatePosition("Gandalf :")
	

	for i := 0; i &lt; 5; i++ {
		fmt.Println(&lt;-positionChannel1)
		fmt.Println(&lt;-positionChannel2)
	}

	fmt.Println("Done with getting updates on positions.")
}</code></pre>
</td>
</tr>
</tbody>
</table>
</div>
Nhưng nếu bạn muốn nhận th&ocirc;ng tin cập nhật vị tr&iacute; ngay khi dữ liệu vừa được cập nhật th&igrave; sao? Đ&oacute; l&agrave; l&uacute;c kỹ thuật Fan-In được sử dụng. Bằng c&aacute;ch sử dụng kỹ thuật n&agrave;y, ch&uacute;ng ta sẽ kết hợp đầu v&agrave;o từ hai k&ecirc;nh v&agrave; gửi ch&uacute;ng qua một k&ecirc;nh duy nhất. Xem đoạn code dưới đ&acirc;y để hiểu c&aacute;ch thực hiện: 
<div class="code-editor__wrapped code-editor__edit__wrapped" data-id="b8463ec3-3bdf-4ebb-b374-60a3f26904cb">
<table class="code-editor__table" data-id="8d741e61-3a9e-43fd-b4fb-49ce618411f3">
<tbody>
<tr class="code-editor__edit__row__first">
<td colspan="2">RUN_CODE (*** ph&acirc;n biệt ***)</td>
</tr>
<tr>
<td>GoLang</td>
<td>
<pre class="language-go" data-content="package" data-language="go" data-ace-language="golang" data-name-language="GoLang" data-main-file="main.go"><code>package main

import ( "fmt"
		 "math/rand"
		 "time")

func updatePosition(name string) &lt;-chan string { 
	positionChannel := make(chan string)

	go func() {
		for i := 0; ; i++ {
			positionChannel &lt;- fmt.Sprintf("%s %d", name , i)
			time.Sleep(time.Duration(rand.Intn(1e3)) * time.Millisecond)
		}
	}()

	return positionChannel
}

func fanIn(mychannel1, mychannel2 &lt;-chan string) &lt;-chan string {
	mychannel := make(chan string) 

	go func() { 
		for {
			mychannel &lt;- &lt;-mychannel1 
		}
	}()

	go func() { 
		for {
			mychannel &lt;- &lt;-mychannel2
		}
	}()

	return mychannel
}

func main() {
	positionsChannel := fanIn(updatePosition("Legolas :"), updatePosition("Gandalf :"))
	

	for i := 0; i &lt; 10; i++ {
		fmt.Println(&lt;-positionsChannel)
	}

	fmt.Println("Done with getting updates on positions.")
}</code></pre>
</td>
</tr>
</tbody>
</table>
</div>
Trọng t&acirc;m của kỹ thuật n&agrave;y nằm ở h&agrave;m <code>fanIn</code>:
<pre class="language-go" data-content="func%20fanIn(mychannel1%2C%20mychannel2%20%3C-chan%20string)%20%3C-chan%20string%20%7B%0A%C2%A0%C2%A0%C2%A0%C2%A0mychannel%20%3A%3D%20make(chan%20string)%C2%A0%0A%C2%A0%C2%A0%C2%A0%C2%A0%0A%C2%A0%C2%A0%C2%A0%C2%A0go%20func()%20%7B%C2%A0%0A%C2%A0%C2%A0%C2%A0%C2%A0%C2%A0%C2%A0%C2%A0%C2%A0for%20%7B%0A%C2%A0%C2%A0%C2%A0%C2%A0%C2%A0%C2%A0%C2%A0%C2%A0%C2%A0%C2%A0%C2%A0%C2%A0mychannel%20%3C-%20%3C-mychannel1%C2%A0%0A%C2%A0%C2%A0%C2%A0%C2%A0%C2%A0%C2%A0%C2%A0%C2%A0%7D%0A%C2%A0%C2%A0%C2%A0%C2%A0%7D()%0A%0A%C2%A0%C2%A0%C2%A0%C2%A0go%20func()%20%7B%C2%A0%0A%C2%A0%C2%A0%C2%A0%C2%A0%C2%A0%C2%A0%C2%A0%C2%A0for%20%7B%0A%C2%A0%C2%A0%C2%A0%C2%A0%C2%A0%C2%A0%C2%A0%C2%A0%C2%A0%C2%A0%C2%A0%C2%A0mychannel%20%3C-%20%3C-mychannel2%C2%A0%0A%C2%A0%C2%A0%C2%A0%C2%A0%C2%A0%C2%A0%C2%A0%C2%A0%7D%0A%C2%A0%C2%A0%C2%A0%C2%A0%7D()%0A%0A%C2%A0%C2%A0%C2%A0%C2%A0return%20mychannel%0A%7D" data-language="go" data-ace-language="golang" data-name-language="GoLang" data-main-file="main.go"><code>func fanIn(mychannel1, mychannel2 &lt;-chan string) &lt;-chan string {
 mychannel := make(chan string) 
 
 go func() { 
 for {
 mychannel &lt;- &lt;-mychannel1 
 }
 }()

 go func() { 
 for {
 mychannel &lt;- &lt;-mychannel2 
 }
 }()

 return mychannel
}</code></pre>
Ở đ&acirc;y, ch&uacute;ng ta nhận hai k&ecirc;nh l&agrave;m đầu v&agrave;o v&agrave; chỉ định một k&ecirc;nh l&agrave; đối số trả về, tức l&agrave; <code>mychannel</code> l&agrave; k&ecirc;nh Fan-In. Sau đ&oacute;, ch&uacute;ng ta khai b&aacute;o hai goroutine từ d&ograve;ng 23 đến d&ograve;ng 33 để nhận dữ liệu từ <code>mychannel1</code> v&agrave; <code>mychannel2</code> v&agrave; gửi ch&uacute;ng đến k&ecirc;nh Fan-In, <code>mychannel</code>, tr&ecirc;n d&ograve;ng 25 v&agrave; d&ograve;ng 31. Do đ&oacute;, dữ liệu sẽ được truyền đến <code>mychannel</code> ngay khi n&oacute; được nhận bởi <code>mychannel1</code> v&agrave; <code>mychannel2</code> v&igrave; c&aacute;c goroutine đang chạy đồng thời.
Th&ecirc;m v&agrave;o đ&oacute;, ch&uacute;ng ta truyền h&agrave;m <code>updatePosition</code> cho cả Legolas v&agrave; Gandalf v&agrave;o h&agrave;m <code>fanIn</code> tr&ecirc;n d&ograve;ng 40. C&aacute;c logic c&ograve;n lại l&agrave; tương tự. Sự kh&aacute;c biệt duy nhất l&agrave; <code>mychannel1</code> v&agrave; <code>mychannel2</code> giao tiếp với <code>mychannel</code> thay v&igrave; giao tiếp trực tiếp với chương tr&igrave;nh main như trước đ&oacute;. Bạn sẽ thấy trong đầu ra, c&aacute;c th&ocirc;ng tin cập nhật vị tr&iacute; kh&ocirc;ng c&ograve;n được in tuần tự nữa. Do đ&oacute;, bằng c&aacute;ch sử dụng kỹ thuật n&agrave;y, ch&uacute;ng ta c&oacute; thể giải quyết vấn đề chặn trước đ&oacute;.
B&acirc;y giờ ch&uacute;ng ta chuyển sang kỹ thuật Fan-Out. Đoạn code dưới đ&acirc;y tạo ra một mảng số ngẫu nhi&ecirc;n v&agrave; in tất cả c&aacute;c gi&aacute; trị sau khi đ&atilde; nh&acirc;n đ&ocirc;i. 
<div class="code-editor__wrapped code-editor__edit__wrapped" data-id="335b66ba-45b9-4f0d-8a2c-79ef09f820bc">
<table class="code-editor__table" data-id="30ccaa37-011b-4957-86ea-ef0be0883cbb">
<tbody>
<tr class="code-editor__edit__row__first">
<td colspan="2">RUN_CODE (*** ph&acirc;n biệt ***)</td>
</tr>
<tr>
<td>GoLang</td>
<td>
<pre class="language-go" data-content="package" data-language="go" data-ace-language="golang" data-name-language="GoLang" data-main-file="main.go"><code>package main

import (
	"fmt"
	"math/rand"
	"strconv"
	"time"
)

func main() {
	var myNumbers [10]int
	for i := 0; i &lt; 10; i++{ 
		rand.Seed(time.Now().UnixNano())
		myNumbers[i]=rand.Intn(50)
	}
	
	mychannelOut := channelGenerator(myNumbers)

	mychannel1 := double(mychannelOut)
	mychannel2 := double(mychannelOut)

	mychannelIn := fanIn(mychannel1, mychannel2)


	for i := 0; i &lt; len(myNumbers); i++ {
		fmt.Println(&lt;-mychannelIn)
	}
}

func channelGenerator(numbers [10]int) &lt;-chan string {
	channel := make(chan string)
	go func() {
		for _, i := range numbers {
			channel &lt;- strconv.Itoa(i)
		}
		close(channel)
	}()
	return channel 
}

func double(inputchannel &lt;-chan string) &lt;-chan string {
	channel := make(chan string)
	go func() {
		for i := range inputchannel {
			num, err := strconv.Atoi(i)
			 if err != nil {
 			
 			 }
			 channel &lt;- fmt.Sprintf("%d * 2 = %d", num,num*2)
		}
		close(channel)
	}()
	return channel
}


func fanIn(inputchannel1, inputchannel2 &lt;-chan string) &lt;-chan string {
	channel := make(chan string)
	go func() {
		for {
			select {
			case message1 := &lt;-inputchannel1: 
				channel &lt;- message1
			case message2 := &lt;-inputchannel2: 
				channel &lt;- message2
			}
		}
	}()
	return channel
}</code></pre>
</td>
</tr>
</tbody>
</table>
</div>
Ch&uacute;ng ta c&ugrave;ng ph&acirc;n t&iacute;ch đoạn code. Từ d&ograve;ng 12 đến d&ograve;ng 15, ch&uacute;ng ta chỉ đơn giản tạo một mảng c&aacute;c số ngẫu nhi&ecirc;n trong khoảng từ 0 đến 49.
<pre class="language-go" data-content="for%20i%20%3A%3D%200%3B%20i%20%3C%2010%3B%20i%2B%2B%7B%C2%A0%0A%C2%A0%C2%A0%C2%A0%C2%A0%C2%A0%C2%A0%C2%A0%C2%A0rand.Seed(time.Now().UnixNano())%0A%C2%A0%C2%A0%C2%A0%C2%A0%C2%A0%C2%A0%C2%A0%C2%A0myNumbers%5Bi%5D%3Drand.Intn(50)%0A%7D" data-language="go" data-ace-language="golang" data-name-language="GoLang" data-main-file="main.go"><code>for i := 0; i &lt; 10; i++{ 
 rand.Seed(time.Now().UnixNano())
 myNumbers[i]=rand.Intn(50)
}</code></pre>
Tr&ecirc;n d&ograve;ng 17, ch&uacute;ng ta tạo ra k&ecirc;nh chung <code>mychannelOut</code> bằng c&aacute;ch sử dụng h&agrave;m <code>channelGenerator</code>.
H&agrave;m <code>channelGenerator</code> như sau:
<pre class="language-go" data-content="func%20channelGenerator(numbers%20%5B10%5Dint)%20%3C-chan%20string%20%7B%0A%C2%A0%C2%A0%C2%A0%C2%A0channel%20%3A%3D%20make(chan%20string)%0A%C2%A0%C2%A0%C2%A0%C2%A0go%20func()%20%7B%0A%C2%A0%C2%A0%C2%A0%C2%A0%C2%A0%C2%A0%C2%A0%C2%A0for%20_%2C%20i%20%3A%3D%20range%20numbers%20%7B%0A%C2%A0%C2%A0%C2%A0%C2%A0%C2%A0%C2%A0%C2%A0%C2%A0%C2%A0%C2%A0%C2%A0%C2%A0channel%C2%A0%20%3C-%C2%A0%20strconv.Itoa(i)%0A%C2%A0%C2%A0%C2%A0%C2%A0%C2%A0%C2%A0%C2%A0%C2%A0%7D%0A%C2%A0%C2%A0%C2%A0%C2%A0%C2%A0%C2%A0%C2%A0%C2%A0close(channel)%0A%C2%A0%C2%A0%C2%A0%C2%A0%7D()%0A%C2%A0%C2%A0%C2%A0%C2%A0return%20channel%C2%A0%0A%7D" data-language="go" data-ace-language="golang" data-name-language="GoLang" data-main-file="main.go"><code>func channelGenerator(numbers [10]int) &lt;-chan string {
 channel := make(chan string)
 go func() {
 for _, i := range numbers {
 channel &lt;- strconv.Itoa(i)
 }
 close(channel)
 }()
 return channel 
}</code></pre>
H&agrave;m trả về một k&ecirc;nh nhận dữ liệu từ goroutine được tạo ra trong ch&iacute;nh h&agrave;m n&agrave;y. Ch&uacute;ng ta chỉ đơn giản chuyển đổi c&aacute;c gi&aacute; trị số nguy&ecirc;n từ mảng đầu v&agrave;o th&agrave;nh chuỗi v&agrave; gửi v&agrave;o k&ecirc;nh.
Trong chương tr&igrave;nh main (d&ograve;ng 19-20), ch&uacute;ng ta fan-out k&ecirc;nh chung <code>mychannel</code> th&agrave;nh hai goroutine, được tạo ra từ b&ecirc;n trong h&agrave;m <code>double</code>.
<pre class="language-go" data-content="func%20double(inputchannel%20%3C-chan%20string)%20%3C-chan%20string%20%7B%0A%C2%A0%C2%A0%C2%A0%C2%A0channel%20%3A%3D%20make(chan%20string)%0A%C2%A0%C2%A0%C2%A0%C2%A0go%20func()%20%7B%0A%C2%A0%C2%A0%C2%A0%C2%A0%C2%A0%C2%A0%C2%A0%C2%A0for%20i%20%3A%3D%20range%20inputchannel%20%7B%0A%C2%A0%C2%A0%C2%A0%C2%A0%C2%A0%C2%A0%C2%A0%C2%A0%C2%A0%C2%A0%C2%A0%C2%A0num%2C%20err%20%3A%3D%20strconv.Atoi(i)%0A%C2%A0%C2%A0%C2%A0%C2%A0%C2%A0%C2%A0%C2%A0%C2%A0%C2%A0%C2%A0%C2%A0%C2%A0%C2%A0if%20err%20!%3D%20nil%20%7B%0A%C2%A0%C2%A0%C2%A0%C2%A0%C2%A0%C2%A0%C2%A0%C2%A0%C2%A0%C2%A0%C2%A0%C2%A0%C2%A0%C2%A0%C2%A0%C2%A0%2F%2F%20handle%20error%0A%C2%A0%C2%A0%C2%A0%C2%A0%C2%A0%C2%A0%C2%A0%C2%A0%C2%A0%C2%A0%C2%A0%C2%A0%C2%A0%7D%0A%C2%A0%C2%A0%C2%A0%C2%A0%C2%A0%C2%A0%C2%A0%C2%A0%C2%A0%C2%A0%C2%A0%C2%A0%C2%A0channel%20%3C-%20fmt.Sprintf(%22%25d%20*%202%20%3D%20%25d%22%2C%20num%2Cnum*2)%0A%C2%A0%C2%A0%C2%A0%C2%A0%C2%A0%C2%A0%C2%A0%C2%A0%7D%0A%C2%A0%C2%A0%C2%A0%C2%A0%C2%A0%C2%A0%C2%A0%C2%A0close(channel)%0A%C2%A0%C2%A0%C2%A0%C2%A0%7D()%0A%C2%A0%C2%A0%C2%A0%C2%A0return%20channel%0A%7D" data-language="go" data-ace-language="golang" data-name-language="GoLang" data-main-file="main.go"><code>func double(inputchannel &lt;-chan string) &lt;-chan string {
 channel := make(chan string)
 go func() {
 for i := range inputchannel {
 num, err := strconv.Atoi(i)
 if err != nil {
 // handle error
 }
 channel &lt;- fmt.Sprintf("%d * 2 = %d", num,num*2)
 }
 close(channel)
 }()
 return channel
}</code></pre>
H&agrave;m <code>double</code> nhận k&ecirc;nh chung l&agrave;m đầu v&agrave;o v&agrave; gửi dữ liệu đến một k&ecirc;nh kh&aacute;c. Lưu &yacute; rằng c&oacute; hai thực thể của h&agrave;m <code>double</code>, điều đ&oacute; ngụ &yacute; rằng hai goroutine đang đồng thời nhận dữ liệu từ một k&ecirc;nh duy nhất. Đ&acirc;y ch&iacute;nh l&agrave; kỹ thuật fan-out, ch&uacute;ng ta ph&acirc;n phối dữ liệu được gửi từ một k&ecirc;nh đến hai k&ecirc;nh đồng thời, chia sẻ việc t&iacute;nh to&aacute;n nh&acirc;n đ&ocirc;i c&aacute;c số nguy&ecirc;n v&agrave; trả về ch&uacute;ng dưới dạng chuỗi giữa hai goroutine.
Ở d&ograve;ng 22, ch&uacute;ng ta fan-in kết quả từ c&aacute;c k&ecirc;nh được trả về bởi h&agrave;m <code>double</code> v&agrave; in ra console.
Kỹ thuật Fan-In, Fan-Out c&oacute; thể rất hữu &iacute;ch khi ta muốn chia nhiệm vụ th&agrave;nh c&aacute;c nhiệm vụ con v&agrave; sau đ&oacute; kết hợp kết quả từ những nhiệm vụ đ&oacute;.