【Java转Go】快速上手学习笔记（六）之网络编程篇一

目录

  • TCP
    • 一个简单案例
      • server.go 服务端
      • client.go 客户端
  • HTTP
      • server.go 服务端
      • client.go 客户端
  • RPC
    • 一个很简单的示例
      • server.go 服务端
      • client.go 客户端
  • WebSocket
      • server.go 服务端
      • client.go 客户端
  • 完整代码
    • server.go 服务端
    • client.go 客户端

go往期文章笔记：

【Java转Go】快速上手学习笔记（一）之环境安装篇

【Java转Go】快速上手学习笔记（二）之基础篇一

【Java转Go】快速上手学习笔记（三）之基础篇二

【Java转Go】快速上手学习笔记（四）之基础篇三

【Java转Go】快速上手学习笔记（五）之Gorm篇


这篇记的是网络编程相关的笔记。

TCP

开启服务端，监听连接的请求。示意图：
在这里插入图片描述

服务端：启动后，监听连接过来的客户端，每连接过来一个客户端，开启一个协程去和客户端进行交互（一个协程代表一个客户端）

客户端：根据服务端的IP和端口号去访问服务端，连接成功后可以向服务端发送消息。

连接的时候通过IP和端口号去连接，但是和客户端进行交流的是协程。

一个简单案例

创建两个文件夹，一个是server、一个是client，然后两个文件夹里面分别创建 server.go、client.go 文件，如下图：

在这里插入图片描述

server.go 服务端

package mainimport ("fmt""io""net"
)// tcp处理客户端发送过来的信息
func tcpHandler(conn net.Conn) {defer conn.Close()for {var buf []byte = make([]byte, 1024)// 等待客户端通过conn发送信息，如果客户端没有wrtie[发送]，那么协程就阻塞在这里n, err := conn.Read(buf)if err == io.EOF {fmt.Println(conn.RemoteAddr().String() + " 退出连接")break}// 客户端发送的内容显示到服务器的终端fmt.Print(string(buf[:n]))}
}func main() {TCP服务端()
}func TCP服务端() {fmt.Println("服务器开始监听")listen, err := net.Listen("tcp", "0.0.0.0:8888")if err != nil {fmt.Println(err)return}defer listen.Close()for { // 循环等待客户端来连接conn, err := listen.Accept()if err != nil {fmt.Println(err)} else {fmt.Printf("客户端 %v 连接成功\n", conn.RemoteAddr().String())}// 这里开启协程go tcpHandler(conn)}
}

client.go 客户端

package mainimport ("fmt""net"
)func main() {TCP客户端()
}func TCP客户端() {conn, err := net.Dial("tcp", "127.0.0.1:8888")if err != nil {fmt.Println(err)return}defer conn.Close()fmt.Println(conn.RemoteAddr().String(), "连接成功")var s stringfor { // 循环输入，给服务端发送消息// 从终端读取用户输入，并发送给服务器fmt.Scanln(&s)if s == "exit" {fmt.Println(conn.RemoteAddr().String(), "退出连接")break}conn.Write([]byte(s + "\r\n")) // 发送给服务端}
}

写好之后，我们先启动服务端，然后再启动客户端。在客户端里面输入消息发送给服务端，服务端接收后要将消息显示出来。

在这里插入图片描述
在这里插入图片描述

客户端输入 exit 时，退出程序，关闭了连接，服务端也显示这个客户端已经退出了连接。
在这里插入图片描述
在这里插入图片描述

HTTP

server.go 服务端

// http处理请求
func httpHandler(res http.ResponseWriter, req *http.Request) {switch req.Method {case "GET":fmt.Println("这里是get请求")res.Write([]byte("这里是get请求"))case "POST":defer req.Body.Close()// 1、 请求类型是aplication/x-www-form-urlencode时解析form数据//req.ParseForm()//fmt.Println(req.PostForm) //打印form数数据//fmt.Println(req.PostForm.Get("username"), req.PostForm.Get("password"))// 2、请求类型是application/json时从req.Body读取数据b, err := io.ReadAll(req.Body)if err != nil {fmt.Println("获取请求数据错误", err)return}fmt.Println(string(b))result := `{"code":0,"message":"ok","data":{}}` // 请求成功，返回数据res.Write([]byte(result))}
}func main() {HTTP服务端()
}func HTTP服务端() {http.HandleFunc("/index", httpHandler) // 回调函数fmt.Println("http://localhost:8080")http.ListenAndServe(":8080", nil) // 绑定服务
}

client.go 客户端

func main() {HTTP客户端()
}func HTTP客户端() {data := `{"username":"符华","password":"123456"}`//resp, err := http.Get("http://localhost:8080/index")resp, err := http.Post("http://localhost:8080/index", "application/json", strings.NewReader(data))//resp, err := http.PostForm("http://localhost:8080/index", url.Values{"username": {"符华"}, "password": {"123456"}})if err != nil {fmt.Println("请求错误", err)return}defer resp.Body.Close()b, err := io.ReadAll(resp.Body)if err != nil {fmt.Println("获取返回数据错误", err)return}fmt.Println(string(b))
}

RPC

一个很简单的示例

server.go 服务端

import ("net""net/http""net/rpc"
)type Server struct{}
type Req struct {Num1 intNum2 int
}
type Res struct {Num int
}func (s Server) Add(req Req, res *Res) error {res.Num = req.Num1 + req.Num2return nil
}func RPC服务端() {// 注册rpc服务rpc.Register(new(Server))rpc.HandleHTTP()listen, err := net.Listen("tcp", ":8080")if err != nil {fmt.Println(err)return}http.Serve(listen, nil)
}func main() {RPC服务端()
}

client.go 客户端

import ("fmt""net""net/rpc"
)type Req struct {Num1 intNum2 int
}
type Res struct {Num int
}func RPC客户端() {req := Req{1, 2}client, err := rpc.DialHTTP("tcp", ":8080")if err != nil {fmt.Println(err)return}var res Resclient.Call("Server.Add", req, &res)fmt.Println(res)
}func main() {RPC客户端()
}

WebSocket

websocket是socket连接和http协议的结合体，可以实现网页和服务端的长连接。

要使用websocket我们要先去下载依赖

go get github.com/gorilla/websocket

server.go 服务端

// websocke 连接的升级器。升级器是一个http.HandlerFunc，它将HTTP连接升级为WebSocket连接
var UP = websocket.Upgrader{ReadBufferSize:  1024,WriteBufferSize: 1024,
}
var conns []*websocket.Conn // 客户端连接切片，存储所有的客户端连接// websocket处理请求
func websocketHandler(res http.ResponseWriter, req *http.Request) {conn, err := UP.Upgrade(res, req, nil) // 服务升级if err != nil {fmt.Println(err)return}defer conn.Close()conns = append(conns, conn)for {// 消息类型，消息，错误t, p, err := conn.ReadMessage()if err != nil {break}for index := range conns {conns[index].WriteMessage(websocket.TextMessage, []byte(fmt.Sprintf("你说的是：%s吗？", string(p))))}fmt.Println(t, string(p))}fmt.Println("服务关闭")
}func websocket服务端() {http.HandleFunc("/", websocketHandler)http.ListenAndServe(":8080", nil)
}

client.go 客户端

// websocket 发送消息
func send(conn *websocket.Conn) {for {reader := bufio.NewReader(os.Stdin)l, _, _ := reader.ReadLine()conn.WriteMessage(websocket.TextMessage, l)}
}func websocket客户端() {dl := websocket.Dialer{}conn, _, err := dl.Dial("ws://127.0.0.1:8080", nil)if err != nil {fmt.Println(err)return}go send(conn)for {t, p, err := conn.ReadMessage()if err != nil {break}fmt.Println(t, string(p))}
}

完整代码

server.go 服务端

package mainimport ("fmt""github.com/gorilla/websocket""io""net""net/http""net/rpc"
)// tcp处理客户端发送过来的信息
func tcpHandler(conn net.Conn) {defer conn.Close()for {var buf []byte = make([]byte, 1024)// 等待客户端通过conn发送信息，如果客户端没有wrtie[发送]，那么协程就阻塞在这里n, err := conn.Read(buf)if err == io.EOF {fmt.Println(conn.RemoteAddr().String() + " 退出连接")break}// 客户端发送的内容显示到服务器的终端fmt.Print(string(buf[:n]))}
}// http处理请求
func httpHandler(res http.ResponseWriter, req *http.Request) {switch req.Method {case "GET":fmt.Println("这里是get请求")res.Write([]byte("这里是get请求"))case "POST":defer req.Body.Close()// 1、 请求类型是aplication/x-www-form-urlencode时解析form数据//req.ParseForm()//fmt.Println(req.PostForm) //打印form数数据//fmt.Println(req.PostForm.Get("username"), req.PostForm.Get("password"))// 2、请求类型是application/json时从req.Body读取数据b, err := io.ReadAll(req.Body)if err != nil {fmt.Println("获取请求数据错误", err)return}fmt.Println(string(b))result := `{"code":0,"message":"ok","data":{}}` // 请求成功，返回数据res.Write([]byte(result))}
}// RPC
type Server struct{}
type Req struct {Num1 intNum2 int
}
type Res struct {Num int
}func (s Server) Add(req Req, res *Res) error {res.Num = req.Num1 + req.Num2return nil
}// websocke 连接的升级器。升级器是一个http.HandlerFunc，它将HTTP连接升级为WebSocket连接
var UP = websocket.Upgrader{ReadBufferSize:  1024,WriteBufferSize: 1024,
}
var conns []*websocket.Conn // 客户端连接切片，存储所有的客户端连接// websocket处理请求
func websocketHandler(res http.ResponseWriter, req *http.Request) {conn, err := UP.Upgrade(res, req, nil) // 服务升级if err != nil {fmt.Println(err)return}defer conn.Close()conns = append(conns, conn)for {// 消息类型，消息，错误t, p, err := conn.ReadMessage()if err != nil {break}for index := range conns {conns[index].WriteMessage(websocket.TextMessage, []byte(fmt.Sprintf("你说的是：%s吗？", string(p))))}fmt.Println(t, string(p))}fmt.Println("服务关闭")
}func main() {//TCP服务端()//HTTP服务端()//RPC服务端()websocket服务端()
}func TCP服务端() {fmt.Println("服务器开始监听")listen, err := net.Listen("tcp", "0.0.0.0:8080")if err != nil {fmt.Println(err)return}defer listen.Close()for { // 循环等待客户端来连接conn, err := listen.Accept()if err != nil {fmt.Println(err)} else {fmt.Printf("客户端 %v 连接成功\n", conn.RemoteAddr().String())}// 这里开启协程go tcpHandler(conn)}
}func HTTP服务端() {http.HandleFunc("/index", httpHandler) // 回调函数fmt.Println("http://localhost:8080")http.ListenAndServe(":8080", nil) // 绑定服务
}func RPC服务端() {// 注册rpc服务rpc.Register(new(Server))rpc.HandleHTTP()listen, err := net.Listen("tcp", ":8080")if err != nil {fmt.Println(err)return}http.Serve(listen, nil)
}func websocket服务端() {http.HandleFunc("/", websocketHandler)http.ListenAndServe(":8080", nil)
}

client.go 客户端

package mainimport ("bufio""fmt""github.com/gorilla/websocket""io""net""net/http""net/rpc""os""strings"
)func main() {//TCP客户端()//HTTP客户端()//RPC客户端()websocket客户端()
}func TCP客户端() {conn, err := net.Dial("tcp", "127.0.0.1:8080")if err != nil {fmt.Println(err)return}defer conn.Close()fmt.Println(conn.RemoteAddr().String(), "连接成功")var s stringfor { // 循环输入，给服务端发送消息// 从终端读取用户输入，并发送给服务器fmt.Scanln(&s)if s == "exit" {fmt.Println(conn.RemoteAddr().String(), "退出连接")break}conn.Write([]byte(s + "\r\n")) // 发送给服务端}
}func HTTP客户端() {data := `{"username":"符华","password":"123456"}`//resp, err := http.Get("http://localhost:8080/index")resp, err := http.Post("http://localhost:8080/index", "application/json", strings.NewReader(data))//resp, err := http.PostForm("http://localhost:8080/index", url.Values{"username": {"符华"}, "password": {"123456"}})if err != nil {fmt.Println("请求错误", err)return}defer resp.Body.Close()b, err := io.ReadAll(resp.Body)if err != nil {fmt.Println("获取返回数据错误", err)return}fmt.Println(string(b))
}// RPC
type Req struct {Num1 intNum2 int
}
type Res struct {Num int
}func RPC客户端() {req := Req{1, 2}client, err := rpc.DialHTTP("tcp", ":8080")if err != nil {fmt.Println(err)return}var res Resclient.Call("Server.Add", req, &res)fmt.Println(res)
}// websocket 发送消息
func send(conn *websocket.Conn) {for {reader := bufio.NewReader(os.Stdin)l, _, _ := reader.ReadLine()conn.WriteMessage(websocket.TextMessage, l)}
}func websocket客户端() {dl := websocket.Dialer{}conn, _, err := dl.Dial("ws://127.0.0.1:8080", nil)if err != nil {fmt.Println(err)return}go send(conn)for {t, p, err := conn.ReadMessage()if err != nil {break}fmt.Println(t, string(p))}
}

ok，以上就是本篇笔记的全部内容了，就是一些简单的使用示例，关于理论概念的东西我没有记，因为太多了，不知道要怎么整理才能说明白说清楚，反正就是这么用的。

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.hqwc.cn/news/82438.html

如若内容造成侵权/违法违规/事实不符，请联系编程知识网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

实现高效消息传递：使用RabbitMQ构建可复用的企业级消息系统

实现高效消息传递：使用RabbitMQ构建可复用的企业级消息系统

文章目录 前言1.安装erlang 语言2.安装rabbitMQ3. 内网穿透3.1 安装cpolar内网穿透(支持一键自动安装脚本)3.2 创建HTTP隧道 4. 公网远程连接5.固定公网TCP地址5.1 保留一个固定的公网TCP端口地址5.2 配置固定公网TCP端口地址 前言 RabbitMQ是一个在 AMQP(高级消息队列协议)基…
阅读更多...
Confluent kafka 异常退出rd_tmpabuf_alloc0: rd kafka topic info_new_with_rack

Confluent kafka 异常退出rd_tmpabuf_alloc0: rd kafka topic info_new_with_rack

rd_tmpabuf_alloc0: rd kafka topic info_new_with_rack 根据网上的例子，做了一个测试程序。 C# 操作Kafka_c# kafka_Riven Chen的博客-CSDN博客 但是执行下面一行时，弹出上面的异常，闪退。 consumer.Subscribe(queueName) 解决方案&…
阅读更多...
怎么把PDF转成Word？需要注意什么事项？

怎么把PDF转成Word？需要注意什么事项？

PDF是一种常见的文档格式，但是与Word文档不同，PDF文件通常不能直接编辑。如果您想编辑PDF文件中的文本，或者想将PDF文件转换为Word文档，下面我们就来看一看把PDF转成Word有哪些方法和注意事项。 PDF转Word工具 有许多将PDF转换为…
阅读更多...
睿趣科技：抖音开网店要怎么找货源

睿趣科技：抖音开网店要怎么找货源

在当今数字化的时代，电商平台的兴起为越来越多的人提供了开设网店的机会，而抖音作为一个充满活力的短视频平台，也为创业者提供了广阔的发展空间。然而，对于许多初次涉足电商领域的人来说，找到合适的货源却是一个重要的…
阅读更多...
uniapp接入广告的问题总结

uniapp接入广告的问题总结

Uniapp官方解决方案 uni-app 支持接入uni-ad广告联盟，开发者可实现一次开发，多端变现。 uni-ad 支持开屏、信息流、激励视频、视频流、悬浮红包、推送等丰富的广告形式； uni-ad 聚合了全网所有主流广告源，包括腾讯优量汇、字节…
阅读更多...
PySpark安装及WordCount实现（基于Ubuntu）

PySpark安装及WordCount实现（基于Ubuntu）

先盘点一下要安装哪些东西： VMwareubuntu 14.04（64位）Java环境（JDK 1.8）Hadoop 2.7.1Spark 2.4.0（Local模式）Pycharm （一）Ubuntu VMware 和 ubuntu 14.04（…
阅读更多...
vue直接使用高德api

vue直接使用高德api

第一步&#xff1a;在index.html 引入 <script src"https://webapi.amap.com/maps?v2.0&key你的key"></script>第二步&#xff1a;在你需要地图的时候 放入 <template><div style"width: 200px; height: 200px"><div id&q…
阅读更多...
Java可视化物联网智慧工地SaaS平台源码：人脸识别考勤

Java可视化物联网智慧工地SaaS平台源码：人脸识别考勤

基于微服务JavaSpring Cloud Vue UniApp MySql实现的智慧工地云平台源码 智慧工地是指利用云计算、大数据、物联网、移动互联网、人工智能等技术手段&#xff0c;为建筑施工现场提供智能硬件及物联网平台的解决方案&#xff0c;以实现建筑工地的实时化、可视化、多元化、智慧化…
阅读更多...
【2023钉钉杯复赛】A题 智能手机用户监测数据分析 Python代码分析

【2023钉钉杯复赛】A题 智能手机用户监测数据分析 Python代码分析

【2023钉钉杯复赛】A题 智能手机用户监测数据分析 Python代码分析 1 题目 一、问题背景 近年来&#xff0c;随着智能手机的产生&#xff0c;发展到爆炸式的普及增长&#xff0c;不仅推动了中 国智能手机市场的发展和扩大&#xff0c;还快速的促进手机软件的开发。近年中国智能…
阅读更多...
uni-app 打包生成签名Sha1

uni-app 打包生成签名Sha1

Android平台打包发布apk应用&#xff0c;需要使用数字证书&#xff08;.keystore文件&#xff09;进行签名&#xff0c;用于表明开发者身份。 可以使用JRE环境中的keytool命令生成。以下是windows平台生成证书的方法&#xff1a; 安装JRE环境&#xff08;推荐使用JRE8环境&am…
阅读更多...
UWB高精度人员定位系统源码，微服务+java+ spring boot+ vue+ mysql技术开发

UWB高精度人员定位系统源码，微服务+java+ spring boot+ vue+ mysql技术开发

工业物联网感知预警体系&#xff0c;大中小企业工业数字化转型需求的工业互联网平台 工厂人员定位系统是指能够对工厂中的人员、车辆、设备等进行定位&#xff0c;实现对人员和车辆的实时监控与调度的系统&#xff0c;是智慧工厂建设中必不可少的一环。由于工厂的工作环境比较…
阅读更多...
Vue实现父子组件相互传值

Vue实现父子组件相互传值

在Vue中&#xff0c;父组件可以通过以下几种方式获取子组件传递的值&#xff1a; 1.Props&#xff08;属性&#xff09;&#xff1a;父组件通过在子组件上定义属性&#xff08;props&#xff09;&#xff0c;将数据传递给子组件。子组件在使用props接收数据后&#xff0c;父组…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023