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

news2025/5/25 9:20:08

目录

  • 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 main

import (
	"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 main

import (
	"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 string
	for { // 循环输入，给服务端发送消息
		// 从终端读取用户输入，并发送给服务器
		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 int
	Num2 int
}
type Res struct {
	Num int
}

func (s Server) Add(req Req, res *Res) error {
	res.Num = req.Num1 + req.Num2
	return 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 int
	Num2 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 Res
	client.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 main

import (
	"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 int
	Num2 int
}
type Res struct {
	Num int
}

func (s Server) Add(req Req, res *Res) error {
	res.Num = req.Num1 + req.Num2
	return 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 main

import (
	"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 string
	for { // 循环输入，给服务端发送消息
		// 从终端读取用户输入，并发送给服务器
		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 int
	Num2 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 Res
	client.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.coloradmin.cn/o/926637.html

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈，一经查实，立即删除！

相关文章

FPGA应用于图像处理

FPGA应用于图像处理

FPGA应用于图像处理 FPGA（Field-Programmable Gate Array）直译过来就是现场可编程门阵列。是一种可以编程的逻辑器件，具有高度的灵活性，可以根据具体需求就像编程来实现不同的功能。 FPGA器件属于专用的集成电流中的一种半定制电…
阅读更多...
Kotlin的Lambda闭包语法

Kotlin的Lambda闭包语法

Lambda 表达式是一种在现代编程语言中常见的特性，它可以用来创建匿名函数或代码块，使得将函数作为参数传递、简化代码以及实现函数式编程范式变得更加便捷。Lambda 表达式在函数式编程语言中得到广泛应用，也在诸如 Java 8 和 Kotlin 等主流编…
阅读更多...
centos安装MySQL 解压版完整教程（按步骤傻瓜式安装

centos安装MySQL 解压版完整教程（按步骤傻瓜式安装

一、卸载系统自带的 Mariadb 查看： rpm -qa|grep mariadb 卸载： rpm -e --nodeps mariadb-libs-5.5.68-1.el7.x86_64 二、卸载 etc 目录下的 my.cnf 文件 rm -rf /etc/my.cnf 三、检查MySQL是否存在 有则先删除 #卸载mysql服务以及删除所有mysql目录 #没…
阅读更多...
Java集合案例：斗地主游戏开发

Java集合案例：斗地主游戏开发

斗地主游戏的开发业务需求分析业务：共有54张牌点数：“3”,“4”,“5”,“6”,“7”,“8”,“9”,“10”,“J”,“Q”,“K”,“A”,“2”花色：“♠”,“❤”,“♣”,“♦”大小王：“👲”,“🃏” *点数分别要…
阅读更多...
【⑭MySQL | 数据类型(二)】字符串 | 二进制类型

【⑭MySQL | 数据类型(二)】字符串 | 二进制类型

前言 ✨欢迎来到小K的MySQL专栏，本节将为大家带来MySQL字符串 | 二进制类型类型的分享✨ 目录 前言5 字符串类型6 二进制类型总结 5 字符串类型 字符串类型用来存储字符串数据，还可以存储图片和声音的二进制数据。字符串可以区分或者不区分大小写的串比…
阅读更多...
java八股文面试[java基础]——如何实现不可变的类

java八股文面试[java基础]——如何实现不可变的类

知识来源： 【23版面试突击】如何实现不可变的类？_哔哩哔哩_bilibili 【2023年面试】怎样声明一个类不会被继承，什么场景下会用_哔哩哔哩_bilibili
阅读更多...
cnpm安装时总是报错

cnpm安装时总是报错

使用npm下载cnpm安装时总是报错 解决办法： 1、执行：npm config get proxy npm config get https-proxy 如果返回值不为null，继续执行： （这一步很重要，一定要保证两个命令的返回值都为null,话说回来&#xf…
阅读更多...
TypeScript三种特殊类型

TypeScript三种特殊类型

1.any类型 说明：any类型代表着可以赋值任意类型 let nickname:any"王二"nickname15nicknametruenicknameundefinednicknamenullnickname{}2.unknown类型 说明：类似any类型；只是不能赋值到其它类型上；除了any和known。…
阅读更多...
java八股文面试[java基础]——字节码

java八股文面试[java基础]——字节码

字节码技术应用 字节码技术的应用场景包括但不限于AOP，动态生成代码，接下来讲一下字节码技术相关的第三方类库，第三方框架的讲解是为了帮助大家了解字节码技术的应用方向，文档并没有对框架机制进行详细分析，有兴趣的可…
阅读更多...
使用Aircrack-ng进行无线网络破解

使用Aircrack-ng进行无线网络破解

Aircrack-ng是一款流行的无线网络渗透测试工具，主要用于密码破解和网络分析。但是，请注意，仅在有合法授权的情况下使用这些工具。 以下是一个使用Aircrack-ng进行无线网络破解的示例，以及一些步骤和注意事项： 步骤&a…
阅读更多...
2023年京东睡眠经济市场数据分析（京东商品数据）

2023年京东睡眠经济市场数据分析（京东商品数据）

如今，伴随快节奏的生活，越来越多的人饱受睡眠问题的影响。同时，伴随现代化的发展，睡眠障碍群体或许会达到新的体量，而日趋增加的失眠人群自然而然低催生了助眠产品的增长。随着人们对健康睡眠重视的程度不断提高&#…
阅读更多...
Dubbo 开发入门

Dubbo 开发入门

一、通过模板生成项目脚手架 Dubbo Initializer 可用来快速生成 Java 项目脚手架，帮助简化微服务项目搭建、基本配置、组件依赖管理等。 Initializer 仍在持续更新中，更多 Dubbo Feature 的支持将会陆续发布。 选择 Dubbo 版本 Initializer 将使用 dub…
阅读更多...
05:TIM定时器功能------输入捕获功能

05:TIM定时器功能------输入捕获功能

目录 1:简历 2:频率测量 3:主从触发模式 4:结构 A:输入捕获功能测频率 1:连接图 2:函数介绍 3:测周法 4 输入捕获模式基本结构 5:步骤 6:代码 B :PWMI模式测频率占空比 1: 连接图 2:PWMI模式的结构 3:函数介绍 4:步骤 5:代码 1:简历 IC（Input Capture…
阅读更多...
JDBC概述

JDBC概述

JDBC概述 核心JDBC组件 JDBC驱动程序连接声明结果集 常见JDBC用例 查询数据库查询数据库元数据更新数据库执行事务 JDBC组件交互图 JDBC API由以下核心部分组成： JDBC驱动程序连接声明结果集 有四个基本的JDBC用例，大多数JDBC工作都围绕这些用例发展…
阅读更多...
微信小程序——van-field中的left-icon属性自定义

微信小程序——van-field中的left-icon属性自定义

✅作者简介：2022年博客新星 第八。热爱国学的Java后端开发者，修心和技术同步精进。 🍎个人主页：Java Fans的博客 🍊个人信条：不迁怒，不贰过。小知识，大智慧。 💞当前专栏…
阅读更多...
Spring 学习源码的基础 核心原理与核心概念

Spring 学习源码的基础 核心原理与核心概念

文章目录 核心原理AnnotationConfigApplicationContextIoC 容器加载流程Spring 中如何创建一个对象Bean 的创建过程 (生命周期)单例 原型推断构造方法依赖注入AOP 动态代理判断是否需要 AOP 的大致流程CGLib 做 AOP 的大致流程事务事务代理对象执行方法的流程事务注解排至失效的…
阅读更多...
Docker安装并配置Node-Exporter

Docker安装并配置Node-Exporter

Linux下安装Docker请参考：Linux安装Docker Node-Exporter简介 Exporter是Prometheus的指标数据收集组件。它负责从目标Jobs收集数据，并把收集到的数据转换为Prometheus支持的时序数据格式。 和传统的指标数据收集组件不同的是，他只负责收集…
阅读更多...
Linux的Man Page知识记录

Linux的Man Page知识记录

Man（short for manual） Page是Unix和Linux操作系统中的一个重要文档，提供命令、函数、系统调用等的详细介绍和使用说明。它是以纯文本的形式出现，通常在终端（terminal）中使用man命令访问。Man Page按照章节…
阅读更多...
语言、习俗与成功：海外网红营销的文化敏感性

语言、习俗与成功：海外网红营销的文化敏感性

随着全球互联网的普及和社交媒体的兴起，海外网红营销正成为越来越多品牌和企业的选择。然而，要在海外市场取得成功，单纯的翻译内容和机械式的推广已经远远不够，文化敏感性成为海外网红营销的关键。本文Nox聚星将深入探讨语言、习俗…
阅读更多...
什么是Spring框架？Spring有什么优势?Spring核心模块有哪些？

什么是Spring框架？Spring有什么优势?Spring核心模块有哪些？

简介 Spring 是一个以 IoC 和 AOP 为基础的Java EE轻量级开源框架，其目的是用于简化 Java 企业级应用的开发难度和开发周期。 广义上的 Spring 泛指以 Spring Framework 为核心的 Spring 技术栈。例如 Spring Framework、Spring MVC、SpringBoot、Spring Cloud、Spr…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023