当前位置: 首页 > news >正文

【Go系列】Go语言的网络服务

承上启下

        我们既然知道了Go语言的语法,也了解到了Go语言如何协同工作机制。那么对于这样一款天生支持高并发的语言,它的用武之地自然而然的就是网络服务了。我们今天学学如何使用网络服务。

开始学习

Go语言使用网络服务

在Go语言中,使用网络服务通常涉及到netnet/http标准库。以下是一些基本概念和步骤:

1. HTTP客户端

使用Go语言发送HTTP请求非常简单,以下是如何使用net/http包创建HTTP客户端的步骤:

发送GET请求

package mainimport ("fmt""io/ioutil""net/http"
)func main() {resp, err := http.Get("http://example.com/")if err != nil {panic(err)}defer resp.Body.Close()body, err := ioutil.ReadAll(resp.Body)if err != nil {panic(err)}fmt.Println(string(body))
}

发送POST请求

package mainimport ("bytes""fmt""io/ioutil""net/http"
)func main() {data := []byte(`{"key1":"value1", "key2":"value2"}`)resp, err := http.Post("http://example.com/", "application/json", bytes.NewBuffer(data))if err != nil {panic(err)}defer resp.Body.Close()body, err := ioutil.ReadAll(resp.Body)if err != nil {panic(err)}fmt.Println(string(body))
}
2. 自定义HTTP客户端

你可以创建一个自定义的HTTP客户端,以设置超时、代理和其他选项。

client := &http.Client{Timeout: time.Second * 10,
}req, err := http.NewRequest("GET", "http://example.com/", nil)
if err != nil {panic(err)
}resp, err := client.Do(req)
// 处理响应

实现RESTful API

RESTful API是一种流行的网络服务架构风格,它使用标准的HTTP方法来执行操作。以下是使用Go语言实现RESTful API的步骤:

1. 设置HTTP服务器
package mainimport ("fmt""log""net/http"
)func helloHandler(w http.ResponseWriter, r *http.Request) {fmt.Fprintf(w, "Hello, world!")
}func main() {http.HandleFunc("/", helloHandler)fmt.Println("Starting server at port 8080")if err := http.ListenAndServe(":8080", nil); err != nil {log.Fatal(err)}
}
2. 定义资源

在RESTful API中,每个资源都应该对应一个URL。以下是一个简单的用户资源示例:

type User struct {ID   int    `json:"id"`Name string `json:"name"`
}
3. 实现HTTP方法

为资源实现GET、POST、PUT、DELETE等HTTP方法。

GET方法

func getUserHandler(w http.ResponseWriter, r *http.Request) {// 假设我们有一个函数来获取用户user := getUserFromDB(1)w.Header().Set("Content-Type", "application/json")json.NewEncoder(w).Encode(user)
}

POST方法

func createUserHandler(w http.ResponseWriter, r *http.Request) {var user Usererr := json.NewDecoder(r.Body).Decode(&user)if err != nil {http.Error(w, err.Error(), http.StatusBadRequest)return}// 假设我们有一个函数来创建用户createdUser := createUserInDB(user)w.Header().Set("Content-Type", "application/json")json.NewEncoder(w).Encode(createdUser)
}
4. 路由

使用gorilla/mux或其他路由库来处理更复杂的路由需求。

r := mux.NewRouter()
r.HandleFunc("/users/{id}", getUserHandler).Methods("GET")
r.HandleFunc("/users", createUserHandler).Methods("POST")
http.ListenAndServe(":8080", r)
5. 错误处理

在API中正确处理错误非常重要。

if err != nil {http.Error(w, err.Error(), http.StatusInternalServerError)return
}
6. 中间件

使用中间件来处理跨域请求、日志记录、身份验证等。

r.Use(loggingMiddleware)

通过以上步骤,你可以使用Go语言构建一个健壮的RESTful API。Go语言的简洁性和强大的标准库使得它成为开发网络服务的理想选择。希望这些知识能帮助你更好地理解和实现Go语言的网络服务。

GO的IO多路复用

在Go语言中,"IO多路复用"通常指的是在网络编程中使用的一种技术,它允许单个网络连接处理多个数据流。这通常是通过使用TCP协议的端口多路复用来实现的,而不是直接在IP层进行多路复用。Go语言通过其net包提供了这种能力,使得可以轻松地实现多路复用。

以下是关于Go中实现IP多路复用的一些关键点:

1. net

Go的net包提供了TCP、UDP、IP、ICMP等网络协议的实现。要实现IP多路复用,我们通常关注的是TCP连接。

2. net.Listenernet.Conn

  • net.Listener接口定义了用于监听网络连接的方法。
  • net.Conn接口定义了用于处理网络连接的方法。

3. Accept函数

net.ListenerAccept方法用于接收新的连接。在多路复用场景中,这个方法会在一个循环中被调用,以便不断地接收新的连接。

4. Goroutines

Go的并发模型通过goroutines实现,这使得为每个新连接启动一个goroutine变得非常简单。这样,即使是一个单一的监听器也可以同时处理多个连接。

以下是一个简单的TCP服务器示例,展示了如何在Go中使用多路复用来处理多个客户端连接:

package mainimport ("fmt""net""os"
)func handleConnection(c net.Conn) {// 处理连接defer c.Close()buffer := make([]byte, 1024)for {n, err := c.Read(buffer)if err != nil {fmt.Println("Error reading:", err.Error())return}fmt.Println("Received message:", string(buffer[:n]))_, err = c.Write([]byte("Message received"))if err != nil {fmt.Println("Error writing:", err.Error())return}}
}func main() {// 监听TCP端口listener, err := net.Listen("tcp", ":8080")if err != nil {fmt.Println("Error listening:", err.Error())os.Exit(1)}defer listener.Close()fmt.Println("Listening on 0.0.0.0:8080")for {// 接受新的连接conn, err := listener.Accept()if err != nil {fmt.Println("Error accepting:", err.Error())continue}// 为每个连接启动一个新的goroutinego handleConnection(conn)}
}

在这个例子中,服务器监听8080端口,并为每个接受的连接启动一个新的goroutine。这样,即使服务器正在处理一个连接,它也可以接受新的连接,这就是所谓的多路复用。

5. 注意事项

  • 当使用多路复用时,需要小心资源管理,因为每个连接都会消耗内存和其他系统资源。
  • 应当合理地限制goroutine的数量,避免过多的goroutine导致系统资源耗尽。
  • 考虑使用连接池或者负载均衡来进一步优化资源使用。

通过这种方式,Go语言使得网络编程中的多路复用变得简单高效,非常适合构建高性能的网络服务器。

相关文章:

【Go系列】Go语言的网络服务

承上启下 我们既然知道了Go语言的语法,也了解到了Go语言如何协同工作机制。那么对于这样一款天生支持高并发的语言,它的用武之地自然而然的就是网络服务了。我们今天学学如何使用网络服务。 开始学习 Go语言使用网络服务 在Go语言中,使用网…...

CS110L(Rust)

1.Rust 语法总结 数值类型 有符号整数: i8, i16, i32, i64无符号整数: u8, u16, u32, u64 变量声明 声明变量: let i 0; // 类型推断let n: i32 1; // 显式类型声明 可变变量: let mut n 0; n n 1; 字符串 注意,let s: str "Hello world";…...

免费恢复软件有哪些?电脑免费使用的 5 大数据恢复软件

您是否在发现需要的文件时不小心删除了回收站中的文件?您一定对误操作感到后悔。文件永远消失了吗?还有机会找回它们吗?当然有!您可以查看这篇文章,挑选 5 款功能强大的免费数据恢复软件,用于 Windows 和 M…...

Flink History Server配置

目录 问题复现 History Server配置 HADOOP_CLASSPATH配置 History Server配置 问题修复 启动flink集群 启动Histroty Server 问题复现 在bigdata111上执行如下命令开启socket: nc -lk 9999 如图: 在bigdata111上执行如下命令运行flink应用程序 …...

ASPICE过程改进原则:确保汽车软件开发的卓越性能

"在汽车行业中,软件已经成为驱动创新和增强产品功能的核心要素。然而,随着软件复杂性的增加,确保软件质量、可靠性和性能成为了一项严峻的挑战。ASPICE标准的引入,为汽车软件开发提供了一套全面的过程改进框架,以…...

HDU1005——Number Sequence,HDU1006——Tick and Tick,HDU1007——Quoit Design

目录 HDU1005——Number Sequence 题目描述 超时代码 代码思路 正确代码 代码思路 HDU1006——Tick and Tick 题目描述 运行代码 代码思路 HDU1007——Quoit Design 题目描述 运行代码 代码思路 HDU1005——Number Sequence 题目描述 Problem - 1005 超时代码…...

uniapp form表单校验

公司的一个老项目,又要重新上架,uniapp一套代码,打包生成iOS端发布到App Store,安卓端发布到腾讯应用宝、OPPO、小米、华为、vivo,安卓各大应用市场上架要求不一样,可真麻烦啊 光一个表单校验,…...

构建RSS订阅机器人:观察者模式的实践与创新

在信息爆炸的时代,如何高效地获取和处理信息成为了一个重要的问题。RSS订阅机器人作为一种自动化工具,能够帮助我们从海量信息中筛选出我们感兴趣的内容。 一、RSS 是什么?观察者模式又是什么? RSS订阅机器人是一种能够自动订阅…...

芯片基础 | `wire`类型引发的学习

在Verilog中,wire类型是一种用于连接模块内部或模块之间的信号的数据类型。wire类型用于表示硬件中的物理连线,它可以传输任何类型的值(如0、1、高阻态z等),但它在任何给定的时间点上只能有一个确定的值。 wire类型通…...

如何在AWS上构建Apache DolphinScheduler

引言 随着云计算技术的发展,Amazon Web Services (AWS) 作为一个开放的平台,一直在帮助开发者更好的在云上构建和使用开源软件,同时也与开源社区紧密合作,推动开源项目的发展。 本文主要探讨2024年值得关注的一些开源软件及其在…...

Quartus II 13.1添加新的FPGA器件库

最近需要用到Altera的一款MAX II 系列EPM240的FPGA芯片,所以需要给我的Quartus II 13.1添加新的器件库,在此记录一下过程。 1 下载所需的期间库 进入Inter官网,(Altera已经被Inter收购)https://www.intel.cn/content…...

【html】html的基础知识(面试重点)

一、如何理解HTML语义化 1、思考 A、在没有任何样式的前提下,将代码在浏览器打开,也能够结构清晰的展示出来。标题是标题、段落是段落、列表是列表。 B、便于搜索引擎优化。 2、参考答案 A、让人更容易读懂(增加代码可读性)。 B、…...

Java 网络编程(TCP编程 和 UDP编程)

1. Java 网络编程(TCP编程 和 UDP编程) 文章目录 1. Java 网络编程(TCP编程 和 UDP编程)2. 网络编程的概念3. IP 地址3.1 IP地址相关的:域名与DNS 4. 端口号(port)5. 通信协议5.1 通信协议相关的…...

STM32 | 看门狗+RTC源码解析

点击上方"蓝字"关注我们 作业 1、使用基本定时7,完成一个定时喂狗的程序 01、上节回顾 STM32 | 独立看门狗+RTC时间(第八天)02、定时器头文件 #ifndef __TIM_H#define __TIM_H​#include "stm32f4xx.h"​void Tim3_Init(void);void Tim7_Init(void);​…...

filebeat,kafka,clickhouse,ClickVisual搭建轻量级日志平台

springboot集成链路追踪 springboot版本 <parent><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-parent</artifactId><version>2.6.3</version><relativePath/> <!-- lookup parent from…...

Django实战项目之进销存数据分析报表——第一天:Anaconda 环境搭建

引言 Anaconda是一个流行的Python和R语言的发行版&#xff0c;它包含了大量预安装的数据科学、机器学习库和科学计算工具。使用Anaconda可以轻松地创建隔离的环境&#xff0c;每个环境都可以有自己的一套库和Python版本&#xff0c;非常适合多项目开发。本文将指导你如何安装A…...

Linux部署Prometheus+Grafana

【Linux】PrometheusGrafana 一、Prometheus&#xff08;普罗米修斯&#xff09;1、Prometheus简述2、Prometheus特点3、Prometheus生态组件4、Prometheus工作原理 二、部署Prometheus1、系统架构2、部署Prometheus3、修改配置文件4、配置系统启动文件 三、部署 Node Exporter …...

【视频讲解】神经网络、Lasso回归、线性回归、随机森林、ARIMA股票价格时间序列预测|附代码数据

全文链接&#xff1a;https://tecdat.cn/?p37019 分析师&#xff1a;Haopeng Li 随着我国股票市场规模的不断扩大、制度的不断完善&#xff0c;它在金融市场中也成为了越来越不可或缺的一部分。 【视频讲解】神经网络、Lasso回归、线性回归、随机森林、ARIMA股票价格时间序列…...

低代码前端框架Amis全面教程

什么是Amis&#xff1f; 1.1 Amis的基本概念 Amis是一个基于JSON配置的前端低代码框架&#xff0c;由百度开源。它允许开发者通过简单的JSON配置文件来生成复杂的后台管理页面&#xff0c;从而大大减少了前端开发的工作量。Amis的核心理念是通过配置而非编码来实现页面的构建…...

Windows 如何安装和卸载 OneDrive?具体方法总结

卸载 OneDrive 有人想问 OneDrive 可以卸载吗&#xff1f;如果你不使用当然可以卸载&#xff0c;下面是安装和卸载 OneDrive 中的卸载应用具体操作步骤&#xff1a; 卸载 OneDrive 我们可以从设置面板中的应用选项进行卸载&#xff0c;打开设置面板之后选择应用&#xff0c;然…...

龙虎榜——20250610

上证指数放量收阴线&#xff0c;个股多数下跌&#xff0c;盘中受消息影响大幅波动。 深证指数放量收阴线形成顶分型&#xff0c;指数短线有调整的需求&#xff0c;大概需要一两天。 2025年6月10日龙虎榜行业方向分析 1. 金融科技 代表标的&#xff1a;御银股份、雄帝科技 驱动…...

地震勘探——干扰波识别、井中地震时距曲线特点

目录 干扰波识别反射波地震勘探的干扰波 井中地震时距曲线特点 干扰波识别 有效波&#xff1a;可以用来解决所提出的地质任务的波&#xff1b;干扰波&#xff1a;所有妨碍辨认、追踪有效波的其他波。 地震勘探中&#xff0c;有效波和干扰波是相对的。例如&#xff0c;在反射波…...

从WWDC看苹果产品发展的规律

WWDC 是苹果公司一年一度面向全球开发者的盛会&#xff0c;其主题演讲展现了苹果在产品设计、技术路线、用户体验和生态系统构建上的核心理念与演进脉络。我们借助 ChatGPT Deep Research 工具&#xff0c;对过去十年 WWDC 主题演讲内容进行了系统化分析&#xff0c;形成了这份…...

使用van-uploader 的UI组件,结合vue2如何实现图片上传组件的封装

以下是基于 vant-ui&#xff08;适配 Vue2 版本 &#xff09;实现截图中照片上传预览、删除功能&#xff0c;并封装成可复用组件的完整代码&#xff0c;包含样式和逻辑实现&#xff0c;可直接在 Vue2 项目中使用&#xff1a; 1. 封装的图片上传组件 ImageUploader.vue <te…...

C++中string流知识详解和示例

一、概览与类体系 C 提供三种基于内存字符串的流&#xff0c;定义在 <sstream> 中&#xff1a; std::istringstream&#xff1a;输入流&#xff0c;从已有字符串中读取并解析。std::ostringstream&#xff1a;输出流&#xff0c;向内部缓冲区写入内容&#xff0c;最终取…...

实现弹窗随键盘上移居中

实现弹窗随键盘上移的核心思路 在Android中&#xff0c;可以通过监听键盘的显示和隐藏事件&#xff0c;动态调整弹窗的位置。关键点在于获取键盘高度&#xff0c;并计算剩余屏幕空间以重新定位弹窗。 // 在Activity或Fragment中设置键盘监听 val rootView findViewById<V…...

如何在最短时间内提升打ctf(web)的水平?

刚刚刷完2遍 bugku 的 web 题&#xff0c;前来答题。 每个人对刷题理解是不同&#xff0c;有的人是看了writeup就等于刷了&#xff0c;有的人是收藏了writeup就等于刷了&#xff0c;有的人是跟着writeup做了一遍就等于刷了&#xff0c;还有的人是独立思考做了一遍就等于刷了。…...

算法笔记2

1.字符串拼接最好用StringBuilder&#xff0c;不用String 2.创建List<>类型的数组并创建内存 List arr[] new ArrayList[26]; Arrays.setAll(arr, i -> new ArrayList<>()); 3.去掉首尾空格...

React---day11

14.4 react-redux第三方库 提供connect、thunk之类的函数 以获取一个banner数据为例子 store&#xff1a; 我们在使用异步的时候理应是要使用中间件的&#xff0c;但是configureStore 已经自动集成了 redux-thunk&#xff0c;注意action里面要返回函数 import { configureS…...

手机平板能效生态设计指令EU 2023/1670标准解读

手机平板能效生态设计指令EU 2023/1670标准解读 以下是针对欧盟《手机和平板电脑生态设计法规》(EU) 2023/1670 的核心解读&#xff0c;综合法规核心要求、最新修正及企业合规要点&#xff1a; 一、法规背景与目标 生效与强制时间 发布于2023年8月31日&#xff08;OJ公报&…...