Socket服务器是网络服务中常用的服务器。使用go语言实现这个业务场景是很容易的。
这样的网络通讯，需要一个服务端和至少一个客户端。
我们计划构建一个这样的通讯工程。服务端启动后等待客户端的访问。客户端发送一段信息给服务端。服务端接收到信息后，再回馈给客户端一段信息。
首先要建立服务端。服务端最先要做的事情就是"建立Socket端口监听"。
netListen, err := net.Listen("tcp", "localhost:1024")
上面的代码，表名监听的是本机端口1024，而使用的通讯协议是TCP。
当监听结束，模块任务完成后，最后要close这个netListen。
defer netListen.Close()
使用日志功能，让服务端窗口能看到服务端已经运行了。
Log("Waiting for clients ...")
之后使用一个for循环，无尽的等待那些不知何时来访问的客户端信息。
for循环体内，要监听netListen的信息接收情况：
conn, err := netListen.Accept()
当有来自客户端的访问时，接受访问。并在服务端的日志记录已经有客户端连接成功了。
Log(conn.RemoteAddr().String(), "tcp connect success")
conn.RemoteAddr().String()表示的就是远程客户端。
然后，我们开启一个goroutine处理连接任务。
go handleConnection(conn)
处理过程就是接收客户端信息和反馈给客户端信息。
n, err := conn.Read(buffer)
conn.Write([]byte(strTemp))
服务端代码示例
package main
import (
"net"
"fmt"
"os"
"log"
"time"
)
func main() {
//建立socket端口监听
netListen, err := net.Listen("tcp", "localhost:1024")
CheckError(err)
defer netListen.Close()
Log("Waiting for clients ...")
//等待客户端访问
for{
conn, err := netListen.Accept() //监听接收
if err != nil{
continue //如果发生错误，继续下一个循环。
}
Log(conn.RemoteAddr().String(), "tcp connect success") //tcp连接成功
go handleConnection(conn)
}
}
//处理连接
func handleConnection(conn net.Conn) {
buffer := make([]byte, 2048) //建立一个slice
for{
n, err := conn.Read(buffer) //读取客户端传来的内容
if err != nil{
Log(conn.RemoteAddr().String(), "connection error: ", err)
return //当远程客户端连接发生错误（断开）后，终止此协程。
}
Log(conn.RemoteAddr().String(), "receive data string:\n", string(buffer[:n]))
//返回给客户端的信息
strTemp := "CofoxServer got msg \""+string(buffer[:n])+"\" at "+time.Now().String()
conn.Write([]byte(strTemp))
}
}
//日志处理
func Log(v ...interface{}) {
log.Println(v...)
}
//错误处理
func CheckError(err error) {
if err != nil{
fmt.Fprintf(os.Stderr, "Fatal error: %s", err.Error())
}
}
客户端的业务逻辑是，发送信息给服务端，然后接收服务端的反馈。
conn, err := net.DialTCP("tcp", nil, tcpAddr)
用TCP协议拨号(Dial)到服务端。如果没有发生错误，就说明拨通了。于是在客户端日志记录连接成功
fmt.Println("connection success")
然后在这个已经通畅的连接里，进行发送和接收信息的任务。conn.Write([]byte(words))是发送信息；conn.Read(buffer)是接收信息。如果接收发生错误，就记录错误：
Log(conn.RemoteAddr().String(), "waiting server back msg error: ", err)
并且中断进程。
如果没有发生错误，酒吧接收到的信息在日志中记录。
Log(conn.RemoteAddr().String(), "receive server back msg: ", string(buffer[:n]))
客户端代码示例
package main
import (
"net"
"fmt"
"log"
"os"
)
//发送信息
func sender(conn net.Conn) {
words := "Hello Server!"
conn.Write([]byte(words))
fmt.Println("send over")
//接收服务端反馈
buffer := make([]byte, 2048)
n, err := conn.Read(buffer)
if err != nil {
Log(conn.RemoteAddr().String(), "waiting server back msg error: ", err)
return
}
Log(conn.RemoteAddr().String(), "receive server back msg: ", string(buffer[:n]))
}
//日志
func Log(v ...interface{}) {
log.Println(v...)
}
func main() {
server := "127.0.0.1:1024"
tcpAddr, err := net.ResolveTCPAddr("tcp4", server)
if err != nil {
fmt.Fprintf(os.Stderr, "Fatal error: %s", err.Error())
os.Exit(1)
}
conn, err := net.DialTCP("tcp", nil, tcpAddr)
if err != nil {
fmt.Fprintf(os.Stderr, "Fatal error: %s", err.Error())
os.Exit(1)
}
fmt.Println("connection success")
sender(conn)
}
以上为个人经验，希望能给大家一个参考，也希望大家多多支持。如有错误或未考虑完全的地方，望不吝赐教。
免责声明：本站文章均来自网站采集或用户投稿，网站不提供任何软件下载或自行开发的软件！ 如有用户或公司发现本站内容信息存在侵权行为，请邮件告知！ 858582#qq.com
《魔兽世界》大逃杀！60人新游玩模式《强袭风暴》3月21日上线
暴雪近日发布了《魔兽世界》10.2.6 更新内容，新游玩模式《强袭风暴》即将于3月21 日在亚服上线，届时玩家将前往阿拉希高地展开一场 60 人大逃杀对战。
艾泽拉斯的冒险者已经征服了艾泽拉斯的大地及遥远的彼岸。他们在对抗世界上最致命的敌人时展现出过人的手腕，并且成功阻止终结宇宙等级的威胁。当他们在为即将于《魔兽世界》资料片《地心之战》中来袭的萨拉塔斯势力做战斗准备时，他们还需要在熟悉的阿拉希高地面对一个全新的敌人──那就是彼此。在《巨龙崛起》10.2.6 更新的《强袭风暴》中，玩家将会进入一个全新的海盗主题大逃杀式限时活动，其中包含极高的风险和史诗级的奖励。
《强袭风暴》不是普通的战场，作为一个独立于主游戏之外的活动，玩家可以用大逃杀的风格来体验《魔兽世界》，不分职业、不分装备（除了你在赛局中捡到的），光是技巧和战略的强弱之分就能决定出谁才是能坚持到最后的赢家。本次活动将会开放单人和双人模式，玩家在加入海盗主题的预赛大厅区域前，可以从强袭风暴角色画面新增好友。游玩游戏将可以累计名望轨迹，《巨龙崛起》和《魔兽世界：巫妖王之怒 经典版》的玩家都可以获得奖励。