Golang 微服务实例求解

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

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

`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 发布的第二款编程语言。

    498 引用 • 1395 回帖 • 256 关注
  • 微服务

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

    96 引用 • 155 回帖
  • Q&A

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

    9407 引用 • 42862 回帖 • 110 关注
  • RESTful

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

    30 引用 • 114 回帖 • 7 关注

相关帖子

欢迎来到这里!

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

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

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

    1 回复
  • 其他回帖
  • auuunnya
    作者

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

    1 回复
  • james via macOS

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

推荐标签 标签

  • 爬虫

    网络爬虫(Spider、Crawler),是一种按照一定的规则,自动地抓取万维网信息的程序。

    106 引用 • 275 回帖
  • 七牛云

    七牛云是国内领先的企业级公有云服务商,致力于打造以数据为核心的场景化 PaaS 服务。围绕富媒体场景,七牛先后推出了对象存储,融合 CDN 加速,数据通用处理,内容反垃圾服务,以及直播云服务等。

    28 引用 • 226 回帖 • 135 关注
  • JetBrains

    JetBrains 是一家捷克的软件开发公司,该公司位于捷克的布拉格,并在俄国的圣彼得堡及美国麻州波士顿都设有办公室,该公司最为人所熟知的产品是 Java 编程语言开发撰写时所用的集成开发环境:IntelliJ IDEA

    18 引用 • 54 回帖
  • Openfire

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

    6 引用 • 7 回帖 • 99 关注
  • GAE

    Google App Engine(GAE)是 Google 管理的数据中心中用于 WEB 应用程序的开发和托管的平台。2008 年 4 月 发布第一个测试版本。目前支持 Python、Java 和 Go 开发部署。全球已有数十万的开发者在其上开发了众多的应用。

    14 引用 • 42 回帖 • 805 关注
  • Swagger

    Swagger 是一款非常流行的 API 开发工具,它遵循 OpenAPI Specification(这是一种通用的、和编程语言无关的 API 描述规范)。Swagger 贯穿整个 API 生命周期,如 API 的设计、编写文档、测试和部署。

    26 引用 • 35 回帖 • 2 关注
  • Log4j

    Log4j 是 Apache 开源的一款使用广泛的 Java 日志组件。

    20 引用 • 18 回帖 • 31 关注
  • 数据库

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

    345 引用 • 742 回帖 • 1 关注
  • jsDelivr

    jsDelivr 是一个开源的 CDN 服务,可为 npm 包、GitHub 仓库提供免费、快速并且可靠的全球 CDN 加速服务。

    5 引用 • 31 回帖 • 94 关注
  • Linux

    Linux 是一套免费使用和自由传播的类 Unix 操作系统,是一个基于 POSIX 和 Unix 的多用户、多任务、支持多线程和多 CPU 的操作系统。它能运行主要的 Unix 工具软件、应用程序和网络协议,并支持 32 位和 64 位硬件。Linux 继承了 Unix 以网络为核心的设计思想,是一个性能稳定的多用户网络操作系统。

    951 引用 • 943 回帖
  • IDEA

    IDEA 全称 IntelliJ IDEA,是一款 Java 语言开发的集成环境,在业界被公认为最好的 Java 开发工具之一。IDEA 是 JetBrains 公司的产品,这家公司总部位于捷克共和国的首都布拉格,开发人员以严谨著称的东欧程序员为主。

    181 引用 • 400 回帖
  • Chrome

    Chrome 又称 Google 浏览器,是一个由谷歌公司开发的网页浏览器。该浏览器是基于其他开源软件所编写,包括 WebKit,目标是提升稳定性、速度和安全性,并创造出简单且有效率的使用者界面。

    62 引用 • 289 回帖
  • 人工智能

    人工智能(Artificial Intelligence)是研究、开发用于模拟、延伸和扩展人的智能的理论、方法、技术及应用系统的一门技术科学。

    157 引用 • 290 回帖
  • Vue.js

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

    267 引用 • 666 回帖 • 1 关注
  • PWL

    组织简介

    用爱发电 (Programming With Love) 是一个以开源精神为核心的民间开源爱好者技术组织,“用爱发电”象征开源与贡献精神,加入组织,代表你将遵守组织的“个人开源爱好者”的各项条款。申请加入:用爱发电组织邀请帖
    用爱发电组织官网:https://programmingwithlove.stackoverflow.wiki/

    用爱发电组织的核心驱动力:

    • 遵守开源守则,体现开源&贡献精神:以分享为目的,拒绝非法牟利。
    • 自我保护:使用适当的 License 保护自己的原创作品。
    • 尊重他人:不以各种理由、各种漏洞进行未经允许的抄袭、散播、洩露;以礼相待,尊重所有对社区做出贡献的开发者;通过他人的分享习得知识,要留下足迹,表示感谢。
    • 热爱编程、热爱学习:加入组织,热爱编程是首当其要的。我们欢迎热爱讨论、分享、提问的朋友,也同样欢迎默默成就的朋友。
    • 倾听:正确并恳切对待、处理问题与建议,及时修复开源项目的 Bug ,及时与反馈者沟通。不抬杠、不无视、不辱骂。
    • 平视:不诋毁、轻视、嘲讽其他开发者,主动提出建议、施以帮助,以和谐为本。只要他人肯努力,你也可能会被昔日小看的人所超越,所以请保持谦虚。
    • 乐观且活跃:你的努力决定了你的高度。不要放弃,多年后回头俯瞰,才会发现自己已经成就往日所仰望的水平。积极地将项目开源,帮助他人学习、改进,自己也会获得相应的提升、成就与成就感。
    1 引用 • 487 回帖 • 2 关注
  • Firefox

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

    7 引用 • 30 回帖 • 391 关注
  • Pipe

    Pipe 是一款小而美的开源博客平台。Pipe 有着非常活跃的社区,可将文章作为帖子推送到社区,来自社区的回帖将作为博客评论进行联动(具体细节请浏览 B3log 构思 - 分布式社区网络)。

    这是一种全新的网络社区体验,让热爱记录和分享的你不再感到孤单!

    132 引用 • 1115 回帖 • 118 关注
  • Google

    Google(Google Inc.,NASDAQ:GOOG)是一家美国上市公司(公有股份公司),于 1998 年 9 月 7 日以私有股份公司的形式创立,设计并管理一个互联网搜索引擎。Google 公司的总部称作“Googleplex”,它位于加利福尼亚山景城。Google 目前被公认为是全球规模最大的搜索引擎,它提供了简单易用的免费服务。不作恶(Don't be evil)是谷歌公司的一项非正式的公司口号。

    49 引用 • 192 回帖
  • App

    App(应用程序,Application 的缩写)一般指手机软件。

    91 引用 • 384 回帖
  • CodeMirror
    1 引用 • 2 回帖 • 154 关注
  • 分享

    有什么新发现就分享给大家吧!

    247 引用 • 1794 回帖
  • DevOps

    DevOps(Development 和 Operations 的组合词)是一组过程、方法与系统的统称,用于促进开发(应用程序/软件工程)、技术运营和质量保障(QA)部门之间的沟通、协作与整合。

    57 引用 • 25 回帖 • 7 关注
  • OpenShift

    红帽提供的 PaaS 云,支持多种编程语言,为开发人员提供了更为灵活的框架、存储选择。

    14 引用 • 20 回帖 • 651 关注
  • WebComponents

    Web Components 是 W3C 定义的标准,它给了前端开发者扩展浏览器标签的能力,可以方便地定制可复用组件,更好的进行模块化开发,解放了前端开发者的生产力。

    1 引用 • 7 关注
  • 服务器

    服务器,也称伺服器,是提供计算服务的设备。由于服务器需要响应服务请求,并进行处理,因此一般来说服务器应具备承担服务并且保障服务的能力。

    125 引用 • 585 回帖
  • HBase

    HBase 是一个分布式的、面向列的开源数据库,该技术来源于 Fay Chang 所撰写的 Google 论文 “Bigtable:一个结构化数据的分布式存储系统”。就像 Bigtable 利用了 Google 文件系统所提供的分布式数据存储一样,HBase 在 Hadoop 之上提供了类似于 Bigtable 的能力。

    17 引用 • 6 回帖 • 60 关注
  • WebSocket

    WebSocket 是 HTML5 中定义的一种新协议,它实现了浏览器与服务器之间的全双工通信(full-duplex)。

    48 引用 • 206 回帖 • 297 关注