Posted on 2011-01-19 17:08
點點滴滴 閱讀(805)
評論(0) 編輯 收藏 引用 所屬分類:
10 服務器
前面一直都在說接收數據時的處理方法，我們應該用專門的IO線程，接收到完整的消息包后加入到主線程的消息隊列，但是主線程如何發送數據還沒有探討過。
一般來說最直接的方法就是邏輯線程什么時候想發數據了就直接調用相關的socket API發送，這要求服務器的玩家對象中保存其連接的socket句柄。但是直接send調用有時候有會存在一些問題，比如遇到系統的發送緩沖區滿而阻塞住的情況，或者只發送了一部分數據的情況也時有發生。我們可以將要發送的數據先緩存一下，這樣遇到未發送完的，在邏輯線程的下一次處理時可以接著再發送。
考慮數據緩存的話，那這里這可以有兩種實現方式了，一是為每個玩家準備一個緩沖區，另外就是只有一個全局的緩沖區，要發送的數據加入到全局緩沖區的時候同時要指明這個數據是發到哪個socket的。如果使用全局緩沖區的話，那我們可以再進一步，使用一個獨立的線程來處理數據發送，類似于邏輯線程對數據的處理方式，這個獨立發送線程也維護一個消息隊列，邏輯線程要發數據時也只是把數據加入到這個隊列中，發送線程循環取包來執行send調用，這時的阻塞也就不會對邏輯線程有任何影響了。
采用第二種方式還可以附帶一個優化方案。一般對于廣播消息而言，發送給周圍玩家的數據都是完全相同的，我們如果采用給每個玩家一個緩沖隊列的方式，這個數據包將需要拷貝多份，而采用一個全局發送隊列時，我們只需要把這個消息入隊一次，同時指明該消息包是要發送給哪些socket的即可。有關該優化的說明在云風描述其連接服務器實現的blog文章中也有講到，有興趣的可以去閱讀一下。