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

请到我的个人博客看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的架构图:

164501711.png


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

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


165521917.png


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


结果:

164646894.jpg


接着咱们再说下 go的socket 。

客户端的情况

164847759.jpg


服务端的情况:

164930482.jpg


server.go

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


client.go


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


Go的并发模式


package main
import (
       "fmt"
       "runtime"
)
func say(s string) {
       for i := 0; i < 5; i++ {
               runtime.Gosched()
               fmt.Println(s)
       }
}
func main() {
       go say("world")
       say("end")
}


结果:

165326909.jpg


本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/402370.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

Linux 系统应用编程——文件I/O

Linux操作系统是基于文件概念的。文件是以字符序列构成的信息载体。根据这一点&#xff0c;可以把I/O设备当做文件来处理&#xff0c;因此&#xff0c;在磁盘上的普通文件进行交互所用的统一系统调用可以直接用于I/O设备。这样大大简化了系统对于不同设备的处理&#xff0c;提高…

Socket模型详解

Socket模型详解 Winsock 的I/O操作&#xff1a;1、两种I/O模式 阻塞模式&#xff1a;执行I/O操作完成前会一直进行等待&#xff0c;不会将控制权交给程序。套接字默认为阻塞模式。可以通过多线程技术进行处理。 非阻塞模式&#xff1a;执行I/O操作时&#xff0c;Winsock函数会…

UVa 11136 - Hoax or what

题目大意&#xff1a;超市进行促销活动&#xff0c;顾客可以把账单放到一个箱子里&#xff0c;每天超市会从箱子中抽出最高消费者和最低消费者&#xff0c;最高消费者可以得到&#xff08;最高消费-最低消费&#xff09;的金钱。询问超市在n天的促销活动结束后应支付多少钱。 找…

静态库和动态库的分析

在Linux操作系统中&#xff0c;普遍使用ELF格式作为可执行程序或者程序生成过程中的中间格式。ELF&#xff08;Executable and Linking Format&#xff0c;可执行连接格式&#xff09;。 ELF文件格式包括三种主要的类型&#xff1a;可执行文件、可重定向文件、共享库&#xff1…

Linux替换命令

:s/^.*$/\L&/100 &#xff03;&#xff03;将100行内的小写转换成大写 vi/vim 中可以使用 :s 命令来替换字符串。 :s/vivian/sky/ 替换当前行第一个 vivian 为 sky :s/vivian/sky/g 替换当前行所有 vivian 为 sky :n,$s/vivian/sky/ 替换第 n 行开始到最后一行中每一行的第…

bash中时间、日期操作

From: Linux 使用 date 計算時間(昨天、明天) 偶尔要算算时间&#xff0c;转载一下&#xff0c;不用再去man了 昨天 (前一天) date –date’1 days ago’ “%Y-%m-%d”date -d ’1 days ago’ “%Y-%m-%d”date -d yesterday “%Y-%m-%d” 明天 (後一天) date –date’1 days…

如何用Chrome浏览器下载网页音乐视频

打开网页&#xff0c;先让要下载的视频播放&#xff0c;右键单击选择审查元素&#xff08;F12&#xff09;&#xff0c;选择上方的Network选项&#xff0c;按F5刷新&#xff0c;这个时候我们可以看到框架中Size下的不少文件数据数字正在变大&#xff0c;按size降序排列。点击表…

Linux 系统应用编程——标准I/O

标准I/O的由来 标准I/O指的是ANSI C 中定义的用于I/O操作的一系列函数。 只要操作系统安装了C库&#xff0c;标准I/O函数就可以调用。换句话说&#xff0c;如果程序中使用的是标准I/O函数&#xff0c;那么源代码不需要任何修改就可以在其他操作系统下编译运行&#xff0c;具有更…

GitLab五种权限

From: https://blog.csdn.net/chenguanghan123/article/details/100523824

Winfrom实现圆角设计

主要代码 public partial class Form1 : Form { public Form1() { InitializeComponent(); } private void Form1_Paint(object sender, PaintEventArgs e) { Type(this, 25, 0.1); } private void…

Linux 系统应用编程——进程基础

一、Linux下多任务机制的介绍 Linux有一特性是多任务&#xff0c;多任务处理是指用户可以在同一时间内运行多个应用程序&#xff0c;每个正在执行的应用程序被称为一个任务。 多任务操作系统使用某种调度(shedule)策略&#xff08;由内核来执行&#xff09;支持多个任务并发执行…

[正则] - 学习过程1

1. 判断是否以xxxx开头: 以数字. 开头&#xff0c;如“2. ” if re.match(^\d\. , content):return <h3>%s</h3> %(content) 2. 将内容中以[ dsfda789 df ] 的内容替换成tpl index 0 input {w: 60 # input宽度 }def replaceValue(matched):global i…

【Python文件处理】递归批处理文件夹子目录内所有txt数据

因为有个需求&#xff0c;需要处理文件夹内所有txt文件&#xff0c;将txt里面的数据筛选&#xff0c;重新存储。 虽然手工可以做&#xff0c;但想到了python一直主张的是自动化测试&#xff0c;就想试着写一个自动化处理数据的程序。 一.分析数据格式 需要处理的数据是txt格式存…

Windows Azure 之服务总线中继服务

Windows Azure的服务总线允许在Web服务内部与外部之间做成一个公共的连接点&#xff0c;在无需更改企业防火墙或者其他安全配置的情况下连接内部和外部的服务 而使用Azure云服务的时候由于缩放的原因通过IP来制定连接也是不科学的&#xff0c;而中继服务则可以充当很好的公共连…

C#对char[]的处理

先来看一段简单的C#代码&#xff1a; private void button3_Click(object sender, EventArgs e){char[] a new char[6] { h, e, L, O, \0, \0 }; // 少赋值一个元素都会报错string b new string(a);string result String.Format("b {0}, b.Length {1}",…

Centos7 关闭防火墙(Firewalld ),使用防火墙(iptables)

1、直接关闭防火墙 systemctl stop firewalld.service&#xff1b; #停止firewall systemctl disable firewalld.service&#xff1b; #禁止firewall开机启动 2、安装并启动 iptables service&#xff0c;以及设置开机自启 yum -y install iptables-services&#xff1b;#安装i…

【qt】QT 的信号与槽机制

QT 是一个跨平台的 C GUI 应用构架&#xff0c;它提供了丰富的窗口部件集&#xff0c;具有面向对象、易于扩展、真正的组件编程等特点&#xff0c;更为引人注目的是目前 Linux 上最为流行的 KDE 桌面环境就是建立在 QT 库的基础之上。 QT 支持下列平台&#xff1a;MS/WINDOWS-9…

C# String 前面不足位数补零的方法

using System; using System.Collections.Generic; using System.Linq;namespace ConsoleApp1 {class Program{static void Main(string[] args){//var a 5;var a 24;// 整数前面补N个0以保存对齐Console.WriteLine("{0:D4}", a);Console.WriteLine(a.ToString(&qu…

Linux 系统应用编程——进程间通信(上)

现在再Linux应用较多的进程间通信方式主要有以下几种&#xff1a; 1&#xff09;无名管道&#xff08;pipe&#xff09;及有名管道&#xff08;fifo&#xff09;&#xff1a;无名管道可用于具有亲缘关系进程间的通信&#xff1b;有名管道除具有管道相似的功能外&#xff0c;它还…

通过JDBK操作数据库

一、配置程序——让我们程序能找到数据库的驱动jar包1.把.jar文件复制到项目中去,整合的时候方便。2.在eclipse项目右击“构建路径”--“配置构建路径”--“库”--“添加外部jar”--找到数据库的驱动jar包--点击确定。会在左侧包资源管理器中出现“引用的库”&#xff0c;在里面…