Golang 微服务实例求解

本贴最后更新于 2156 天前,其中的信息可能已经东海扬尘

最近在看微服务,了解到一个微服务应用是多个后台服务组合起来的应用,这些个后台服务有自己的接口,自己的处理器,自己的数据库等。
概念看了很多,也有那么一丝丝理解,跟着一篇文档敲了一次代码,感觉下来还是一个单体应用,丝毫没有看到微服务的影子呀。。
代码如下:

`package main`
`import ( `
`"encoding/json"`
`"fmt"`
`"log"`
`"net/http"`
`"goji.io"`
`"goji.io/pat"`
`"gopkg.in/mgo.v2"`
`"gopkg.in/mgo.v2/bson"`
`)`
`func ErrorWithJSON(w http.ResponseWriter, message string, code` `int``) { `
`w.Header().Set(``"Content-Type"``,` `"application/json; charset=utf-8"``)`
`w.WriteHeader(code)`
`fmt.Fprintf(w,` `"{message: %q}"``, message)`
`}`

`func ResponseWithJSON(w http.ResponseWriter, json []byte, code` `int``) { `
`w.Header().Set(``"Content-Type"``,` `"application/json; charset=utf-8"``)`
`w.WriteHeader(code)`
`w.Write(json)`
`}`

`type Book` `struct` `{ `
`ISBN    string   `json:``"isbn"
`Title   string   `json:``"title"
`Authors []string `json:``"authors"
`Price   string   `json:``"price"
`}`

`func main() { `
`session, err := mgo.Dial(``"localhost"``)`
`if` `err != nil {`
`panic(err)`
`}`
`defer session.Close()`
`session.SetMode(mgo.Monotonic,` `true``)`
`ensureIndex(session)`
`mux := goji.NewMux()`
`mux.HandleFunc(pat.Get(``"/books"``), allBooks(session))`
`mux.HandleFunc(pat.Post(``"/books"``), addBook(session))`
`mux.HandleFunc(pat.Get(``"/books/:isbn"``), bookByISBN(session))`
`mux.HandleFunc(pat.Put(``"/books/:isbn"``), updateBook(session))`
`mux.HandleFunc(pat.Delete(``"/books/:isbn"``), deleteBook(session))`
`http.ListenAndServe(``"localhost:8080"``, mux)`
`}`

`func ensureIndex(s *mgo.Session) { `
`session := s.Copy()`
`defer session.Close()`
`c := session.DB(``"store"``).C(``"books"``)`
`index := mgo.Index{`
`Key:        []string{``"isbn"``},`
`Unique:` `true``,`
`DropDups:` `true``,`
`Background:` `true``,`
`Sparse:` `true``,`
`}`
`err := c.EnsureIndex(index)`
`if``err != nil {`
`panic(err)`
`}`

`}`

`func allBooks(s *mgo.Session) func(w http.ResponseWriter, r *http.Request) { `
`return` `func(w http.ResponseWriter, r *http.Request) {`
`session := s.Copy()`
`defer session.Close()`
`c := session.DB(``"store"``).C(``"books"``)`
`var books []Book`
`err := c.Find(bson.M{}).All(&books)`
`if` `err != nil {`
`ErrorWithJSON(w,` `"Database error"``, http.StatusInternalServerError)`
`log``.Println(``"Failed get all books: "``, err)`
`return`
`}`
`respBody, err := json.MarshalIndent(books,` `""``,` `"  "``)`
`if` `err != nil {`
`log``.Fatal(err)`
`}`
`ResponseWithJSON(w, respBody, http.StatusOK)`
`}`
`}`

`func addBook(s *mgo.Session) func(w http.ResponseWriter, r *http.Request) { `
`return` `func(w http.ResponseWriter, r *http.Request) {`
`session := s.Copy()`
`defer session.Close()`
`var book Book`
`decoder := json.NewDecoder(r.Body)`
`err := decoder.Decode(&book)`
`if` `err != nil {`
`ErrorWithJSON(w,` `"Incorrect body"``, http.StatusBadRequest)`
`return`
`}`
`c := session.DB(``"store"``).C(``"books"``)`
`err = c.Insert(book)`
`if` `err != nil {`
`if` `mgo.IsDup(err) {`
`ErrorWithJSON(w,` `"Book with this ISBN already exists"``, http.StatusBadRequest)`
`return`
`}`
`ErrorWithJSON(w,` `"Database error"``, http.StatusInternalServerError)`
`log``.Println(``"Failed insert book: "``, err)`
`return`
`}`
`w.Header().Set(``"Content-Type"``,` `"application/json"``)`
`w.Header().Set(``"Location"``, r.URL.Path+``"/"``+book.ISBN)`
`w.WriteHeader(http.StatusCreated)`
`}`
`}`

`func bookByISBN(s *mgo.Session) func(w http.ResponseWriter, r *http.Request) { `
`return` `func(w http.ResponseWriter, r *http.Request) {`
`session := s.Copy()`
`defer session.Close()`
`isbn := pat.Param(r,` `"isbn"``)`
`c := session.DB(``"store"``).C(``"books"``)`
`var book Book`
`err := c.Find(bson.M{``"isbn"``: isbn}).One(&book)`
`if` `err != nil {`
`ErrorWithJSON(w,` `"Database error"``, http.StatusInternalServerError)`
`log``.Println(``"Failed find book: "``, err)`
`return`
`}`
`if` `book.ISBN ==` `""` `{`
`ErrorWithJSON(w,` `"Book not found"``, http.StatusNotFound)`
`return`
`}`
`respBody, err := json.MarshalIndent(book,` `""``,` `"  "``)`
`if` `err != nil {`
`log``.Fatal(err)`
`}`
`ResponseWithJSON(w, respBody, http.StatusOK)`
`}`
`}`

`func updateBook(s *mgo.Session) func(w http.ResponseWriter, r *http.Request) { `
`return` `func(w http.ResponseWriter, r *http.Request) {`
`session := s.Copy()`
`defer session.Close()`
`isbn := pat.Param(r,` `"isbn"``)`
`var book Book`
`decoder := json.NewDecoder(r.Body)`
`err := decoder.Decode(&book)`
`if` `err != nil {`
`ErrorWithJSON(w,` `"Incorrect body"``, http.StatusBadRequest)`
`return`
`}`
`c := session.DB(``"store"``).C(``"books"``)`
`err = c.Update(bson.M{``"isbn"``: isbn}, &book)`
`if` `err != nil {`
`switch` `err {`
`default``:`
`ErrorWithJSON(w,` `"Database error"``, http.StatusInternalServerError)`
`log``.Println(``"Failed update book: "``, err)`
`return`
`case` `mgo.ErrNotFound:`
`ErrorWithJSON(w,` `"Book not found"``, http.StatusNotFound)`
`return`
`}`
`}`
`w.WriteHeader(http.StatusNoContent)`
`}`
`}`

`func deleteBook(s *mgo.Session) func(w http.ResponseWriter, r *http.Request) { `
`return` `func(w http.ResponseWriter, r *http.Request) {`
`session := s.Copy()`
`defer session.Close()`
`isbn := pat.Param(r,` `"isbn"``)`
`c := session.DB(``"store"``).C(``"books"``)`
`err := c.Remove(bson.M{``"isbn"``: isbn})`
`if` `err != nil {`
`switch` `err {`
`default``:`
`ErrorWithJSON(w,` `"Database error"``, http.StatusInternalServerError)`
`log``.Println(``"Failed delete book: "``, err)`
`return`
`case` `mgo.ErrNotFound:`
`ErrorWithJSON(w,` `"Book not found"``, http.StatusNotFound)`
`return`
`}`
`}`
`w.WriteHeader(http.StatusNoContent)`
`}`
`}`

希望各位大佬给点入门指导或者建议,最好有代码 demo,可以便于理解,我是越看越模糊了。

  • golang

    Go 语言是 Google 推出的一种全新的编程语言,可以在不损失应用程序性能的情况下降低代码的复杂性。谷歌首席软件工程师罗布派克(Rob Pike)说:我们之所以开发 Go,是因为过去 10 多年间软件开发的难度令人沮丧。Go 是谷歌 2009 发布的第二款编程语言。

    492 引用 • 1383 回帖 • 375 关注
  • 微服务

    微服务架构是一种架构模式,它提倡将单一应用划分成一组小的服务。服务之间互相协调,互相配合,为用户提供最终价值。每个服务运行在独立的进程中。服务于服务之间才用轻量级的通信机制互相沟通。每个服务都围绕着具体业务构建,能够被独立的部署。

    96 引用 • 155 回帖
  • Q&A

    提问之前请先看《提问的智慧》,好的问题比好的答案更有价值。

    6554 引用 • 29428 回帖 • 246 关注
  • RESTful

    一种软件架构设计风格而不是标准,提供了一组设计原则和约束条件,主要用于客户端和服务器交互类的软件。基于这个风格设计的软件可以更简洁,更有层次,更易于实现缓存等机制。

    30 引用 • 114 回帖 • 1 关注

相关帖子

欢迎来到这里!

我们正在构建一个小众社区,大家在这里相互信任,以平等 • 自由 • 奔放的价值观进行分享交流。最终,希望大家能够找到与自己志同道合的伙伴,共同成长。

注册 关于
请输入回帖内容 ...
  • james

    估计你单个应用是体现不出来的,我们这里是有一个中心的服务注册中心,服务会注册 IP 端口等这些信息,然后各个服务通过服务名,接口到注册中心查服务信息,发送请求给各个服务。不是各个服务直接通信,中间通过一个代理来做。

    1 回复
  • 其他回帖
  • james

    要先把微服务框架写好,提供好 SDK。你新加一个服务,就只要调用 SDK 的时候给出服务名,本机 IP,端口。SDK 里面去做服务注册,心跳注册。
    服务调用也使用统一好的 SDK,调用的时候给出服务名,接口名,参数。SDK 厘米做服务查询,发现,发送请求,解析请求等。
    这样新加服务,及调用服务完全屏蔽调微服务层,扩展就很简单了。调用也简单,你都不用写 httpclient 就能请求获取相应。先把相应 SDK 封装好,就会好很多。

  • auuunnya
    作者

    那么如果要在加一个服务,例如:注册,在这个代码上应该怎么做扩展,代理我也看了一般的话就是用的中间代理 apigetway,这个代理是不是就是一个一个的路由?

    1 回复

推荐标签 标签

  • Logseq

    Logseq 是一个隐私优先、开源的知识库工具。

    Logseq is a joyful, open-source outliner that works on top of local plain-text Markdown and Org-mode files. Use it to write, organize and share your thoughts, keep your to-do list, and build your own digital garden.

    4 引用 • 55 回帖 • 10 关注
  • MyBatis

    MyBatis 本是 Apache 软件基金会 的一个开源项目 iBatis,2010 年这个项目由 Apache 软件基金会迁移到了 google code,并且改名为 MyBatis ,2013 年 11 月再次迁移到了 GitHub。

    170 引用 • 414 回帖 • 429 关注
  • 微信

    腾讯公司 2011 年 1 月 21 日推出的一款手机通讯软件。用户可以通过摇一摇、搜索号码、扫描二维码等添加好友和关注公众平台,同时可以将自己看到的精彩内容分享到微信朋友圈。

    129 引用 • 793 回帖 • 1 关注
  • VirtualBox

    VirtualBox 是一款开源虚拟机软件,最早由德国 Innotek 公司开发,由 Sun Microsystems 公司出品的软件,使用 Qt 编写,在 Sun 被 Oracle 收购后正式更名成 Oracle VM VirtualBox。

    10 引用 • 2 回帖 • 5 关注
  • Solidity

    Solidity 是一种智能合约高级语言,运行在 [以太坊] 虚拟机(EVM)之上。它的语法接近于 JavaScript,是一种面向对象的语言。

    3 引用 • 18 回帖 • 352 关注
  • 笔记

    好记性不如烂笔头。

    304 引用 • 777 回帖
  • 数据库

    据说 99% 的性能瓶颈都在数据库。

    330 引用 • 614 回帖
  • 30Seconds

    📙 前端知识精选集,包含 HTML、CSS、JavaScript、React、Node、安全等方面,每天仅需 30 秒。

    • 精选常见面试题,帮助您准备下一次面试
    • 精选常见交互,帮助您拥有简洁酷炫的站点
    • 精选有用的 React 片段,帮助你获取最佳实践
    • 精选常见代码集,帮助您提高打码效率
    • 整理前端界的最新资讯,邀您一同探索新世界
    488 引用 • 383 回帖 • 5 关注
  • Webswing

    Webswing 是一个能将任何 Swing 应用通过纯 HTML5 运行在浏览器中的 Web 服务器,详细介绍请看 将 Java Swing 应用变成 Web 应用

    1 引用 • 15 回帖 • 635 关注
  • Firefox

    Mozilla Firefox 中文俗称“火狐”(正式缩写为 Fx 或 fx,非正式缩写为 FF),是一个开源的网页浏览器,使用 Gecko 排版引擎,支持多种操作系统,如 Windows、OSX 及 Linux 等。

    7 引用 • 30 回帖 • 452 关注
  • Vue.js

    Vue.js(读音 /vju ː/,类似于 view)是一个构建数据驱动的 Web 界面库。Vue.js 的目标是通过尽可能简单的 API 实现响应的数据绑定和组合的视图组件。

    261 引用 • 662 回帖
  • Openfire

    Openfire 是开源的、基于可拓展通讯和表示协议 (XMPP)、采用 Java 编程语言开发的实时协作服务器。Openfire 的效率很高,单台服务器可支持上万并发用户。

    6 引用 • 7 回帖 • 89 关注
  • Vditor

    Vditor 是一款浏览器端的 Markdown 编辑器,支持所见即所得、即时渲染(类似 Typora)和分屏预览模式。它使用 TypeScript 实现,支持原生 JavaScript、Vue、React 和 Angular。

    313 引用 • 1667 回帖 • 1 关注
  • B3log

    B3log 是一个开源组织,名字来源于“Bulletin Board Blog”缩写,目标是将独立博客与论坛结合,形成一种新的网络社区体验,详细请看 B3log 构思。目前 B3log 已经开源了多款产品:SymSoloVditor思源笔记

    1083 引用 • 3461 回帖 • 286 关注
  • Laravel

    Laravel 是一套简洁、优雅的 PHP Web 开发框架。它采用 MVC 设计,是一款崇尚开发效率的全栈框架。

    19 引用 • 23 回帖 • 685 关注
  • Sym

    Sym 是一款用 Java 实现的现代化社区(论坛/BBS/社交网络/博客)系统平台。

    下一代的社区系统,为未来而构建

    523 引用 • 4581 回帖 • 690 关注
  • Sandbox

    如果帖子标签含有 Sandbox ,则该帖子会被视为“测试帖”,主要用于测试社区功能,排查 bug 等,该标签下内容不定期进行清理。

    370 引用 • 1215 回帖 • 582 关注
  • frp

    frp 是一个可用于内网穿透的高性能的反向代理应用,支持 TCP、UDP、 HTTP 和 HTTPS 协议。

    15 引用 • 7 回帖 • 10 关注
  • Hexo

    Hexo 是一款快速、简洁且高效的博客框架,使用 Node.js 编写。

    21 引用 • 140 回帖 • 28 关注
  • Markdown

    Markdown 是一种轻量级标记语言,用户可使用纯文本编辑器来排版文档,最终通过 Markdown 引擎将文档转换为所需格式(比如 HTML、PDF 等)。

    163 引用 • 1450 回帖
  • 知乎

    知乎是网络问答社区,连接各行各业的用户。用户分享着彼此的知识、经验和见解,为中文互联网源源不断地提供多种多样的信息。

    10 引用 • 66 回帖 • 1 关注
  • 设计模式

    设计模式(Design pattern)代表了最佳的实践,通常被有经验的面向对象的软件开发人员所采用。设计模式是软件开发人员在软件开发过程中面临的一般问题的解决方案。这些解决方案是众多软件开发人员经过相当长的一段时间的试验和错误总结出来的。

    198 引用 • 120 回帖
  • CloudFoundry

    Cloud Foundry 是 VMware 推出的业界第一个开源 PaaS 云平台,它支持多种框架、语言、运行时环境、云平台及应用服务,使开发人员能够在几秒钟内进行应用程序的部署和扩展,无需担心任何基础架构的问题。

    5 引用 • 18 回帖 • 153 关注
  • C++

    C++ 是在 C 语言的基础上开发的一种通用编程语言,应用广泛。C++ 支持多种编程范式,面向对象编程、泛型编程和过程化编程。

    106 引用 • 152 回帖
  • RIP

    愿逝者安息!

    8 引用 • 92 回帖 • 290 关注
  • 钉钉

    钉钉,专为中国企业打造的免费沟通协同多端平台, 阿里巴巴出品。

    15 引用 • 67 回帖 • 370 关注
  • Caddy

    Caddy 是一款默认自动启用 HTTPS 的 HTTP/2 Web 服务器。

    10 引用 • 54 回帖 • 126 关注