关于Go语言在服务端做Restful接口和socket通信-低调大师

关于Go语言在服务端做Restful接口和socket通信

2017-11-12 615

请到我的个人博客看golang rest相关文章 http://xiaorui.cc

关于Go语言在服务端做Restful接口和socket通信

已经转到:

http://xiaorui.cc/2014/10/25/%E5%85%B3%E4%BA%8Ego%E8%AF%AD%E8%A8%80%E5%9C%A8%E6%9C%8D%E5%8A%A1%E7%AB%AF%E5%81%9Arestful%E6%8E%A5%E5%8F%A3%E5%92%8Csocket%E9%80%9A%E4%BF%A1/

下图即是REST的架构图：

当REST架构的约束条件作为一个整体应用时，将生成一个可以扩展到大量客户端的应用程序。它还降低了客户端和服务器之间的交互延迟。统一界面简化了整个系统架构，改进了子系统之间交互的可见性。REST简化了客户端和服务器的实现，而且对于使用REST开发的应用程序更加容易扩展。

其实说白了，就是根据不同的方法，来分类不同的任务~

 
  
    
      
      
        <span style=
        "font-size:16px;"
        >
        package 
        main<br data-filtered=
        "filtered"
        >
        import 
        (<br data-filtered=
        "filtered"
        >    
        "fmt"
        <br data-filtered=
        "filtered"
        >    
        "github.com/drone/routes"
        <br data-filtered=
        "filtered"
        >    
        "net/http"
        <br data-filtered=
        "filtered"
        >)<br data-filtered=
        "filtered"
        >func getuser(w http.ResponseWriter, r *http.Request) {<br data-filtered=
        "filtered"
        >    params := r.URL.Query()<br data-filtered=
        "filtered"
        >    uid := params.Get(
        ":uid"
        )<br data-filtered=
        "filtered"
        >    fmt.Fprintf(w, 
        "you are get user %s"
        , uid)<br data-filtered=
        "filtered"
        >}<br data-filtered=
        "filtered"
        >func modifyuser(w http.ResponseWriter, r *http.Request) {<br data-filtered=
        "filtered"
        >    params := r.URL.Query()<br data-filtered=
        "filtered"
        >    uid := params.Get(
        ":uid"
        )<br data-filtered=
        "filtered"
        >    fmt.Fprintf(w, 
        "you are modify user %s"
        , uid)<br data-filtered=
        "filtered"
        >}<br data-filtered=
        "filtered"
        >func deleteuser(w http.ResponseWriter, r *http.Request) {<br data-filtered=
        "filtered"
        >    params := r.URL.Query()<br data-filtered=
        "filtered"
        >    uid := params.Get(
        ":uid"
        )<br data-filtered=
        "filtered"
        >    fmt.Fprintf(w, 
        "you are delete user %s"
        , uid)<br data-filtered=
        "filtered"
        >}<br data-filtered=
        "filtered"
        >func adduser(w http.ResponseWriter, r *http.Request) {<br data-filtered=
        "filtered"
        >    params := r.URL.Query()<br data-filtered=
        "filtered"
        >    uid := params.Get(
        ":uid"
        )<br data-filtered=
        "filtered"
        >    fmt.Fprint(w, 
        "you are add user %s"
        , uid)<br data-filtered=
        "filtered"
        >    fmt.Printf(
        "you are add user %s"
        , uid)<br data-filtered=
        "filtered"
        >}<br data-filtered=
        "filtered"
        >
        //xiaorui.cc<br data-filtered="filtered">func main() {<br data-filtered="filtered">    mux := routes.New()<br data-filtered="filtered">    mux.Get("/user/:uid", getuser)<br data-filtered="filtered">    mux.Post("/user/:uid", modifyuser)<br data-filtered="filtered">    mux.Del("/user/:uid", deleteuser)<br data-filtered="filtered">    mux.Put("/user/:uid", adduser)<br data-filtered="filtered">    http.Handle("/", mux)<br data-filtered="filtered">    http.ListenAndServe(":8088", nil)<br data-filtered="filtered">}<br data-filtered="filtered">//xiaorui.cc<br data-filtered="filtered"></span> 
       
 
    

   
 

结果：

接着咱们再说下 go的socket 。

客户端的情况

服务端的情况：

server.go

 
  
    
      
      
        <span style=
        "font-size:16px;"
        >
        package 
        main<br data-filtered=
        "filtered"
        >
        import 
        (<br data-filtered=
        "filtered"
        >    
        "fmt"
        <br data-filtered=
        "filtered"
        >    
        "net"
        <br data-filtered=
        "filtered"
        >    
        "os"
        <br data-filtered=
        "filtered"
        >)<br data-filtered=
        "filtered"
        >func main() {<br data-filtered=
        "filtered"
        >    
        var 
        (<br data-filtered=
        "filtered"
        >        host   = 
        "127.0.0.1"
        <br data-filtered=
        "filtered"
        >        port   = 
        "8080"
        <br data-filtered=
        "filtered"
        >        remote = host + 
        ":" 
        + port<br data-filtered=
        "filtered"
        >        data   = make([]byte, 
        1024
        )<br data-filtered=
        "filtered"
        >    )<br data-filtered=
        "filtered"
        >    fmt.Println(
        "Initiating server... (Ctrl-C to stop)"
        )<br data-filtered=
        "filtered"
        >    lis, err := net.Listen(
        "tcp"
        , remote)<br data-filtered=
        "filtered"
        >    defer lis.Close()<br data-filtered=
        "filtered"
        >    
        if 
        err != nil {<br data-filtered=
        "filtered"
        >        fmt.Println(
        "Error when listen: "
        , remote)<br data-filtered=
        "filtered"
        >        os.Exit(-
        1
        )<br data-filtered=
        "filtered"
        >    }<br data-filtered=
        "filtered"
        >    
        for 
        {<br data-filtered=
        "filtered"
        >        
        var 
        res string<br data-filtered=
        "filtered"
        >        conn, err := lis.Accept()<br data-filtered=
        "filtered"
        >        
        if 
        err != nil {<br data-filtered=
        "filtered"
        >            fmt.Println(
        "Error accepting client: "
        , err.Error())<br data-filtered=
        "filtered"
        >            os.Exit(
        0
        )<br data-filtered=
        "filtered"
        >        }<br data-filtered=
        "filtered"
        >        go func(con net.Conn) {<br data-filtered=
        "filtered"
        >            fmt.Println(
        "New connection: "
        , con.RemoteAddr())<br data-filtered=
        "filtered"
        >            
        for 
        {<br data-filtered=
        "filtered"
        >                length, err := con.Read(data)<br data-filtered=
        "filtered"
        >                
        if 
        err != nil {<br data-filtered=
        "filtered"
        >                    fmt.Printf(
        "Client %v quit.\n"
        , con.RemoteAddr())<br data-filtered=
        "filtered"
        >                    con.Close()<br data-filtered=
        "filtered"
        >                    
        return
        <br data-filtered=
        "filtered"
        >                }<br data-filtered=
        "filtered"
        >                res = string(data[
        0
        :length])<br data-filtered=
        "filtered"
        >                fmt.Printf(
        "%s said: %s\n"
        , con.RemoteAddr(), res)<br data-filtered=
        "filtered"
        >                res = 
        "You said:" 
        + res<br data-filtered=
        "filtered"
        >                con.Write([]byte(res))<br data-filtered=
        "filtered"
        >            }<br data-filtered=
        "filtered"
        >        }(conn)<br data-filtered=
        "filtered"
        >    }<br data-filtered=
        "filtered"
        >}<br data-filtered=
        "filtered"
        ></span> 
       
 
    

   
 

client.go

 
  
    
      
      
        <span style=
        "font-size:16px;"
        >
        package 
        main<br data-filtered=
        "filtered"
        >
        import 
        (<br data-filtered=
        "filtered"
        >    
        "fmt"
        <br data-filtered=
        "filtered"
        >    
        "net"
        <br data-filtered=
        "filtered"
        >    
        "os"
        <br data-filtered=
        "filtered"
        >)<br data-filtered=
        "filtered"
        >
        var 
        str string<br data-filtered=
        "filtered"
        >
        var 
        msg = make([]byte, 
        1024
        )<br data-filtered=
        "filtered"
        >func main() {<br data-filtered=
        "filtered"
        >    
        var 
        (<br data-filtered=
        "filtered"
        >        host   = 
        "127.0.0.1"
        <br data-filtered=
        "filtered"
        >        port   = 
        "8080"
        <br data-filtered=
        "filtered"
        >        remote = host + 
        ":" 
        + port<br data-filtered=
        "filtered"
        >    )<br data-filtered=
        "filtered"
        >    con, err := net.Dial(
        "tcp"
        , remote)<br data-filtered=
        "filtered"
        >    defer con.Close()<br data-filtered=
        "filtered"
        >    
        if 
        err != nil {<br data-filtered=
        "filtered"
        >        fmt.Println(
        "Server not found."
        )<br data-filtered=
        "filtered"
        >        os.Exit(-
        1
        )<br data-filtered=
        "filtered"
        >    }<br data-filtered=
        "filtered"
        >    fmt.Println(
        "Connection OK."
        )<br data-filtered=
        "filtered"
        >    
        for 
        {<br data-filtered=
        "filtered"
        >        fmt.Printf(
        "Enter a sentence:"
        )<br data-filtered=
        "filtered"
        >        fmt.Scanf(
        "%s\n"
        , &str)<br data-filtered=
        "filtered"
        >        
        if 
        str == 
        "quit" 
        {<br data-filtered=
        "filtered"
        >            fmt.Println(
        "Communication terminated."
        )<br data-filtered=
        "filtered"
        >            os.Exit(
        1
        )<br data-filtered=
        "filtered"
        >        }<br data-filtered=
        "filtered"
        >        
        in
        , err := con.Write([]byte(str))<br data-filtered=
        "filtered"
        >        
        if 
        err != nil {<br data-filtered=
        "filtered"
        >            fmt.Printf(
        "Error when send to server: %d\n"
        , 
        in
        )<br data-filtered=
        "filtered"
        >            os.Exit(
        0
        )<br data-filtered=
        "filtered"
        >        }<br data-filtered=
        "filtered"
        >        length, err := con.Read(msg)<br data-filtered=
        "filtered"
        >        
        if 
        err != nil {<br data-filtered=
        "filtered"
        >            fmt.Printf(
        "Error when read from server.\n"
        )<br data-filtered=
        "filtered"
        >            os.Exit(
        0
        )<br data-filtered=
        "filtered"
        >        }<br data-filtered=
        "filtered"
        >        str = string(msg[
        0
        :length])<br data-filtered=
        "filtered"
        >        fmt.Println(str)<br data-filtered=
        "filtered"
        >    }<br data-filtered=
        "filtered"
        >}<br data-filtered=
        "filtered"
        ></span> 
       
 
    

   
 

Go的并发模式

 
  
    
      
      
        <span style=
        "font-size:16px;"
        >
        package 
        main<br data-filtered=
        "filtered"
        >
        import 
        (<br data-filtered=
        "filtered"
        >        
        "fmt"
        <br data-filtered=
        "filtered"
        >        
        "runtime"
        <br data-filtered=
        "filtered"
        >)<br data-filtered=
        "filtered"
        >func say(s string) {<br data-filtered=
        "filtered"
        >        
        for 
        i := 
        0
        ; i < 
        5
        ; i++ {<br data-filtered=
        "filtered"
        >                runtime.Gosched()<br data-filtered=
        "filtered"
        >                fmt.Println(s)<br data-filtered=
        "filtered"
        >        }<br data-filtered=
        "filtered"
        >}<br data-filtered=
        "filtered"
        >func main() {<br data-filtered=
        "filtered"
        >        go say(
        "world"
        )<br data-filtered=
        "filtered"
        >        say(
        "end"
        )<br data-filtered=
        "filtered"
        >}<br data-filtered=
        "filtered"
        ></span> 
       
 
    

   
 

结果：

本文转自 rfyiamcool 51CTO博客，原文链接：http://blog.51cto.com/rfyiamcool/1286372，如需转载请自行联系原作者

微信关注我们

原文链接：https://yq.aliyun.com/articles/402655

转载内容版权归作者及来源网站所有！

低调大师中文资讯倾力打造互联网数据资讯、行业资源、电子商务、移动互联网、网络营销平台。持续更新报道IT业界、互联网、市场资讯、驱动更新,是最及时权威的产业资讯及硬件资讯报道平台。

LVS负载均衡集群架构介绍

为什么需要使用负载均衡呢？这是一个必较重要的问题实际生产环境中某单台服务器已不能负载日常用访问压力时，就需要使用负载均衡，把用户的请求数据分担到（尽可能平均分配）后端所有功能同等的集群的节点上,同样也是为了解决单台服务器故障问题，从而提高用户的访问体验。 1、LVS的介绍 LVS（linux virtual server）LINUX虚拟服务器，是一个虚拟的服务器集群系统，可以在linux和unix系统中运行，1985年开发研究的项目http://www.linuxvirtualserver.org/zh/官方网站 IPVS(lvs)发展史在linux2.2内核时，IPVS就已经以内核补丁的形式出现从2.4。24版本以后IPVS已经成为linux内核官方标准内核的一部分 LVS工作原理 LVS负载均衡调度技术是在linux内核中实现的，我们使用配置LVS时，不是直接配置内核中的IPVS，而是通过IPVS的管理工具IPVSADM来管理配置，LVS集群负载均衡器接受所有入站客户端的请求，并根据算法来决定由哪个集群的节点来处理请求。 LVS相关术语介绍虚拟IP地址（VIP）用于向客户...

2017-11-12

622

一、应用程序 Android 会同一系列核心应用程序包一起发布，该应用程序包包括 email客户端，SMS 短消息程序，日历，地图，浏览器，联系人管理程序等。所有的应用程序都是使用JAVA 语言编写的。二、应用程序框架开发人员也可以完全访问核心应用程序所使用的API框架。该应用程序的架构设计简化了组件的重用；任何一个应用程序都可以发布它的功能块并且任何其它的应用程序都可以使用其所发布的功能块（不过得遵循框架的安全性限制）。同样，该应用程序重用机制也使用户可以方便的替换程序组件。隐藏在每个应用后面的是一系列的服务和系统, 其中包括；  丰富而又可扩展的视图（Views），可以用来构建应用程序，它包括列表（lists），网格（grids），文本框（text boxes），按钮（buttons），甚至可嵌入的web 浏览器。  内容提供器（Content Providers）使得应用程序可以访问另一个应用程序的数据（如联系人数据库），或者共享它们自己的数据  资源管理器（Resource Manager）提供非代码资源的访问，如本地字符串，图形，和布局文件（ layou...

2017-11-13

494

资源下载

更多资源

Mario

马里奥是站在游戏界顶峰的超人气多面角色。马里奥靠吃蘑菇成长，特征是大鼻子、头戴帽子、身穿背带裤，还留着胡子。与他的双胞胎兄弟路易基一起，长年担任任天堂的招牌角色。

腾讯云软件源

为解决软件依赖安装时官方源访问速度慢的问题，腾讯云为一些软件搭建了缓存服务。您可以通过使用腾讯云软件源站来提升依赖包的安装速度。为了方便用户自由搭建服务架构，目前腾讯云软件源站支持公网访问和内网访问。

Nacos

Nacos /nɑ:kəʊs/ 是 Dynamic Naming and Configuration Service 的首字母简称，一个易于构建 AI Agent 应用的动态服务发现、配置管理和AI智能体管理平台。Nacos 致力于帮助您发现、配置和管理微服务及AI智能体应用。Nacos 提供了一组简单易用的特性集，帮助您快速实现动态服务发现、服务配置、服务元数据、流量管理。Nacos 帮助您更敏捷和容易地构建、交付和管理微服务平台。

Sublime Text

Sublime Text具有漂亮的用户界面和强大的功能，例如代码缩略图，Python的插件，代码段等。还可自定义键绑定，菜单和工具栏。Sublime Text 的主要功能包括：拼写检查，书签，完整的 Python API ， Goto 功能，即时项目切换，多选择，多窗口等等。Sublime Text 是一个跨平台的编辑器，同时支持Windows、Linux、Mac OS X等操作系统。