当前位置: 首页 > 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;然…...

如何在看板中体现优先级变化

在看板中有效体现优先级变化的关键措施包括&#xff1a;采用颜色或标签标识优先级、设置任务排序规则、使用独立的优先级列或泳道、结合自动化规则同步优先级变化、建立定期的优先级审查流程。其中&#xff0c;设置任务排序规则尤其重要&#xff0c;因为它让看板视觉上直观地体…...

Python爬虫实战:研究feedparser库相关技术

1. 引言 1.1 研究背景与意义 在当今信息爆炸的时代,互联网上存在着海量的信息资源。RSS(Really Simple Syndication)作为一种标准化的信息聚合技术,被广泛用于网站内容的发布和订阅。通过 RSS,用户可以方便地获取网站更新的内容,而无需频繁访问各个网站。 然而,互联网…...

C++ 基础特性深度解析

目录 引言 一、命名空间&#xff08;namespace&#xff09; C 中的命名空间​ 与 C 语言的对比​ 二、缺省参数​ C 中的缺省参数​ 与 C 语言的对比​ 三、引用&#xff08;reference&#xff09;​ C 中的引用​ 与 C 语言的对比​ 四、inline&#xff08;内联函数…...

python爬虫:Newspaper3k 的详细使用(好用的新闻网站文章抓取和解析的Python库)

更多内容请见: 爬虫和逆向教程-专栏介绍和目录 文章目录 一、Newspaper3k 概述1.1 Newspaper3k 介绍1.2 主要功能1.3 典型应用场景1.4 安装二、基本用法2.2 提取单篇文章的内容2.2 处理多篇文档三、高级选项3.1 自定义配置3.2 分析文章情感四、实战案例4.1 构建新闻摘要聚合器…...

音视频——I2S 协议详解

I2S 协议详解 I2S (Inter-IC Sound) 协议是一种串行总线协议&#xff0c;专门用于在数字音频设备之间传输数字音频数据。它由飞利浦&#xff08;Philips&#xff09;公司开发&#xff0c;以其简单、高效和广泛的兼容性而闻名。 1. 信号线 I2S 协议通常使用三根或四根信号线&a…...

C#中的CLR属性、依赖属性与附加属性

CLR属性的主要特征 封装性&#xff1a; 隐藏字段的实现细节 提供对字段的受控访问 访问控制&#xff1a; 可单独设置get/set访问器的可见性 可创建只读或只写属性 计算属性&#xff1a; 可以在getter中执行计算逻辑 不需要直接对应一个字段 验证逻辑&#xff1a; 可以…...

C# 表达式和运算符(求值顺序)

求值顺序 表达式可以由许多嵌套的子表达式构成。子表达式的求值顺序可以使表达式的最终值发生 变化。 例如&#xff0c;已知表达式3*52&#xff0c;依照子表达式的求值顺序&#xff0c;有两种可能的结果&#xff0c;如图9-3所示。 如果乘法先执行&#xff0c;结果是17。如果5…...

go 里面的指针

指针 在 Go 中&#xff0c;指针&#xff08;pointer&#xff09;是一个变量的内存地址&#xff0c;就像 C 语言那样&#xff1a; a : 10 p : &a // p 是一个指向 a 的指针 fmt.Println(*p) // 输出 10&#xff0c;通过指针解引用• &a 表示获取变量 a 的地址 p 表示…...

学习一下用鸿蒙​​DevEco Studio HarmonyOS5实现百度地图

在鸿蒙&#xff08;HarmonyOS5&#xff09;中集成百度地图&#xff0c;可以通过以下步骤和技术方案实现。结合鸿蒙的分布式能力和百度地图的API&#xff0c;可以构建跨设备的定位、导航和地图展示功能。 ​​1. 鸿蒙环境准备​​ ​​开发工具​​&#xff1a;下载安装 ​​De…...

JavaScript 标签加载

目录 JavaScript 标签加载script 标签的 async 和 defer 属性&#xff0c;分别代表什么&#xff0c;有什么区别1. 普通 script 标签2. async 属性3. defer 属性4. type"module"5. 各种加载方式的对比6. 使用建议 JavaScript 标签加载 script 标签的 async 和 defer …...