这是在系统集成编程方面相对akka-http占优的一个亮点。protobuf格式数据可以很方便的转换成 json格式数据，支持对外部系统的的开放协议数据交换。...虽然gRPC基于http/2协议在网络通讯效率和模式上有了很大的提升，但近段时间对gRPC使用的调研主要还是冲着protobuf来的。...在http/1应用中对二进制文件的传输交换有诸多限制和不便，特别是效率方面的问题。在protobuf这种序列化模式中对任何类型的数据格式都一视同仁，可以很方便的实现图片等文件的上传下载。...对akka-http用户来说，akka-grpc具有很大吸引（相对其它gRPC开放工具），因为它是基于akka-http的，看看下面grpc服务端的接口： // Bind service handler...与scalaPB一样，akka-grpc也是通过编译IDL（.proto）文件用相应的插件（plugin）产生相关的scala类和服务函数代码。
一、Golang HTTP请求Json响应解析方法 在Golang Web编程中，json格式是常见的传输格式，那么json数据要怎么解析呢？...例如下面请求地址 http://api.open-notify.org/astros.json 响应数据如下： { "number": 3, "message": "success", "people...请求并解析json数据到结构体里的示例 package main import ( "encoding/json" "fmt" "io/ioutil" "log" "net/http" "...，无法正常解析了 原因 其实原因很简单，golang首字母大小写意味着改变了成员的访问权限，小写就变成私有的了，不同package是无法访问其他package的私有成员的，导致json.Marshal...打个比方，你如果把json.Marshal(hp) 这个方法的重新实现在main方法下面，struct中的成员变量就可以小写了。 注意 struct内的成员变量小写就只有当前包内可以访问。
", // Akka HTTP项目的标准依赖关系 "com.typesafe.akka" %% "akka-http-spray-json" % "10.0.11", // 用于JSON序列化和反序列化...Akka HTTP项目的标准依赖关系（通用于提供者和消费者），spry-json用于JSON序列化和反序列化，SL4J用于日志记录，scalatest和scalamock作为测试和模拟框架，以及Scala...同时考虑到所有HTTP元素必须匹配（方法，url，标题，正文和查询） 用于验证消费者契约的实际测试的定义： 此代码将针对以前的方案运行，虚拟服务器将响应 交互部分中定义的唯一HTTP请求（如果响应为deined...我们也可以尝试执行Pact test（MyLibraryClientPactSpec），但它会失败，因为它应该执行一个真正的HTTP调用，scala-pact框架将启动一个真实的HTTP服务器，接受和响应协议中描述的请求...)，确保模型类同时实现了apply和unapply，最简单的方法是定义模型类的案例类。
在上期讨论我们提到过这种转换其实是ROW->Json->ByteString或者反方向的转换，在Akka-http里称之为Marshalling和Unmarshalling。...Akka-http的Marshalling实现采用了type-class编程模式，需要为每一种类型与Json的转换在可视域内提供Marshaller[A,B]类型的隐式实例。...Akka-http默认的Json工具库是Spray-Json，着重case class，而且要提供JsonFormat?(case-class),其中?...代表case class的参数个数，用起来略显复杂。不过因为是Akka-http的配套库，在将来Akka-http的持续发展中具有一定的优势，所以我们还是用它来进行下面的示范。...但Akka-http的Marshalling-type-class是个非常复杂的系统。
HTTP协议、HTTP的请求报文和响应报文 HTTP协议 HTTP主要特点 HTTP的请求报文和响应报文 请求报文 请求行 请求消息头 空行 请求体 响应报文 响应状态行 响应消息头 空行 响应体 总结...HTTP协议就是用于规范客户端浏览器和服务器端以什么样的格式进行通信数据交互，作为应用层的面向对象的协议，HTTP由请求和响应构成，是一个标准的客户端服务器模型，也是一个无状态的协议。...HTTP的请求报文和响应报文 当我们打开一个网站，单击F12，进入Network窗口，单击默认头信息选项卡，可以看到格式化后的响应报文和请求报文。...响应报文 一个HTTP的响应报文由状态行、响应消息头、空行和响应体四部分组成。...响应状态行 响应状态行包括HTTP协议版本、成功或错误的整数代码（状态码）和对状态码进行描述的文本信息，以空格进行划分。 状态代码由3位数字组成，表示请求是否被理解或被满足。
前言 在 java 中，如何让一个类具有动态属性。这里将介绍一种技巧，可以使得你的类，具有良好的动态属性的能力。...普遍的做法是在类中申明一个 map 属性，把想要扩展的属性放入这个 map 中，这样就可以使得类具有动态属性的能力了。...一、普遍的 普遍的-类定义类中申明一个 map 属性，把想要扩展的属性放入这个 map 中，这样就可以使得类具有动态属性的能力了。...在【良好的】与【普遍的和较好的】实现方案相比较，我们增加了两个类 AttrOption 和 AttrOptions。本来一个 map 可以解决的事为什么要多增加两个类呢。...对组合的说明 我们增加了两个类 AttrOption 和 AttrOptions，本来一个 map 可以解决的事为什么要多增加两个类呢？
研究关于restapi的初衷是想搞一套通用的平台数据表维护http工具。前面谈过身份验证和使用权限、文件的上传下载，这次来到具体的数据库表维护。...通用的数据传输模式是：类->json->类，即序列化/反序列化。...akka-http提供了丰富的Marshaller来实现自动的数据转换，但在编译时要提供Marshaller的隐式实例implicit instance，所以用类参数是无法通过编译的。...只能手工进行类和json之间的转换。...E](json) } } 当然对于一些特别的数据库表，我们还是希望使用akka-http强大的功能，如streaming。
Akka-http网上交换数据转换代表把一个高级结构类型T的实例转换成简单的目标类型如MessageEntity，它代表http消息中的数据部分（entity-body），最后产生Json进行交换。...(request)把Akka-http提供的预设可转换类实例转换成相关的toResponseMarshallable类实例。...这个可网上传输的消息是通过Json、XML这样的数据描述语言来产生具体数据的。Akka-http通过akka-http-spray-json模块直接支持由Spray-Json实现的Json读写工具库。...[T] = Marshaller[T, MessageEntity] 既然Akka-http的Json实现方式是type-class模式的，那么我们就试试其它Json库的功能实现方式，如：Json4s。...同样提供了FromEntityUnMarshaller[A]和ToEntityMarshaller[A]这两类的隐式实例。
以Wireshark2.6.3版本为例，如下图所示，红框中的803是一次HTTP的GET请求包，绿框中的809、810两条记录都是响应包，究竟哪个是803的响应包呢？...此时已经找到了803对应的响应，可以继续打开HTTP层的数据查看响应信息的详情了； 通过Wireshark的识别结果 通过传输控制协议信息识别的方法略有些麻烦，需要打开所有记录逐个检查，Wireshark...已经做了更方便的方式： 展开803号记录的HTTP层，如下图所示，红框中的内容是可以点击的，双击后会立即打开响应记录809的内容： ?...查看响应数据时也有对应的请求包链接，双击链接可打开对应的请求数据包，如下图，以809号记录为例，在HTTP层中可以双击下图红框中的内容，直接打开803的内容： ?...Wireshark的标记 最后介绍的是最简单的方式，如下图，红框中的朝右的箭头是请求，蓝框中朝左的箭头代表这就是对应的响应： ?
Unmarshalling是Akka-http内把网上可传输格式的数据转变成程序高级结构话数据的过程，比如把Json数据转换成某个自定义类型的实例。...Unmarshalling对一个A类实例到B类实例的转换是通过Unmarshaller[A,B]来实现的： trait Unmarshaller[-A, B] extends akka.http.javadsl.unmarshalling.Unmarshaller...下面是一些Unmarshal的用例： import akka.actor._ import akka.stream._ import akka.http.scaladsl.unmarshalling.Unmarshal...下面就是本次讨论的示范源代码： Unmarshalling import akka.actor._ import akka.stream._ import akka.http.scaladsl.unmarshalling.Unmarshal...import akka.actor._ import akka.stream._ import akka.http.scaladsl.server.Directives._ import de.heikoseeberger.akkahttpjson4s.Json4sSupport
当我们把Akka-http作为数据库数据交换工具时，数据是以Source[ROW,_]形式存放在Entity里的。很多时候除数据之外我们可能需要进行一些附加的信息传递如对数据的具体处理方式等。...我们可以通过Akka-http的raw-header来实现附加自定义消息的传递，这项功能可以通过Akka-http提供的raw-header筛选功能来实现。...} Akka-http通过Credential类的Directive提供了authentication和authorization。...import akka._ import akka.http.scaladsl.common._ import spray.json.DefaultJsonProtocol import akka.http.scaladsl.marshallers.sprayjson.SprayJsonSupport...import akka.http.scaladsl.common.EntityStreamingSupport import akka.http.scaladsl.model._ import spray.json
上次对restapi开了个头，设计了一个包括了身份验证和使用权限的restful服务开发框架。这是一个通用框架，开发人员只要直接往里面加新功能就行了。...虽然这次的restapi是围绕着数据库表的CRUD操作设计的，但文件类数据在服务端与客户端之间的交换其实也很常用，特别是多媒体类如图片等文件类型。...那我们就试着设计一个文件交换服务功能然后看看能不能很方便的加入到restapi框架内。 akka-http是以akka-stream为核心的，使用了大量的akka-stream功能。...在上面这个例子里我们先设计了一个独立的包括文件交换服务功能的FileRoute类，然后直接把FileRoute.route贴在主菜单后面就完成了文件交换服务功能的添加。...% "jwt-core" % "3.0.1", "de.heikoseeberger" %% "akka-http-json4s" % "1.22.0", "org.json4s" %% "json4s-native
用户身份和令牌的传递是通过Http Header实现的，具体情况可参考RFC2617,RFC6750 简单来说：用户向服务器提交身份信息申请令牌，下面是一个HttpRequest样例： POST /token...得到令牌后每个使用网络资源的Request都必须在Authorization类Header里附带这个令牌，如： GET /resource HTTP/1.1 Host: server.example.com...下面我们写一段客户端代码来测试上面这个webserver的功能： import akka.actor._ import akka.stream._ import akka.http.scaladsl.Http...% "jwt-core" % "3.0.1", "de.heikoseeberger" %% "akka-http-json4s" % "1.22.0", "org.json4s" %% "json4s-native..." % "3.6.1", "com.typesafe.akka" %% "akka-http-spray-json" % "10.1.8", "com.typesafe.scala-logging
上篇我们讨论了Akka-http的文件交换。由于文件内容编码和传输线上数据表达型式皆为bytes，所以可以直接把文件内容存进HttpEntity中进行传递。...Akka-http自带的Json解决方案用的是Spray-Json，下面我们就用Spray-Json来实现转换： import akka.http.scaladsl.marshallers.sprayjson...从上面的讨论中我们对任意结构类型的一个实例进行序列化转换有了一定了解。这个类型的实例可以被是作为数据库的一条记录，通过上面讨论的方式在服务端和客户端进行交换。...这是因为SprayJsonSupport可以提供任意类T的Marshaller[T,MessageEntity]隐式实例。...下面是本次讨论的示范源代码： import akka.actor._ import akka.stream.scaladsl._ import akka.http.scaladsl.marshalling
我的解决方案是通过一个restapi服务作为两个系统的数据桥梁，这个restapi的最基本要求是： 1、支持任何操作系统前端：这个没什么问题，在http层上通过json交换数据 2、能读写mongodb...下面是SqlHttpServer.scala的代码： package com.datatech.rest.sql import akka.http.scaladsl.Http import akka.http.scaladsl.server.Directives...://mydemo.com/api/sql，服务包括get,post,put三类，参考这个SqlRoute： package com.datatech.rest.sql import akka.http.scaladsl.server.Directives...这个函数返回Source[R,Any]，下面我们好好谈谈这个R：R是读的结果，通常是某个类或model，比如读取Person记录返回一组Person类的实例。这里有一种强类型的感觉。...实际上，http线上数据交换本身就不可能是强类型的，因为经过了json转换。对于json转换来说，只要求字段名称、字段类型对称就行了。至于从什么类型转换成了另一个什么类型都没问题。
在有关CQRS系列博客里，我以akka-http作为系统集成工具的一种，零星地针对实际需要对http通信进行了介绍。...CRUD部分要尽量做成通用的generic，框架型的，能用一套标准的方法对任何数据表进行操作。 akka-http是一套http程序开发工具。...在这篇讨论里先搭一个restapi的基本框架，包括客户端身份验证和使用权限。主要是示范如何达到通用框架的目的。...身份验证和使用权限也应该是一套标准的东西，但身份验证方法可能有所不同，特别是用户身份验证可能是通过独立的身份验证服务器实现的，对不同的验证机制应该有针对性的定制函数。...% "jwt-core" % "3.0.1", "de.heikoseeberger" %% "akka-http-json4s" % "1.22.0", "org.json4s" %% "json4s-native
HTTP请求格式 1.首行：【方法(GET) / URL / 版本号(例如HTTP/1.1) ——这三部分用空格分隔开】 2.协议头（header）：【若干个键值对之间用“: ”(冒号空格)来分割】...3.空行：【header的结束标志】 4.正文：body HTTP响应格式 1.首行：【版本号 / 状态码 / 描述信息 ——这三部分用空格分隔开】 2.协议头（header）：【若干个键值对之间用...“: ”(冒号空格)来分割】 3.空行：【header的结束标志】 4.正文：body 常见的HTTP方法 方法 理解 （这只是最初的理想定义情况在现在的应用中已经没有这么严格了，具体怎么定义还是看程序员的喜好...UNLINE 断开联系关系 GET和POST的区别 对于GET和POST的区别各路大佬众说纷纭，但我认为他们之间的最大区别就是： GET把数据放到URL中 POST把数据放到body中 除此之外...，随着现在的发展，GET和POST之间并没有特别严格的界定，完全可以交换过来放，这样理论上是可行的
Akka-http的客户端连接模式除Connection-Level和Host-Level之外还有一种非常便利的模式：Request-Level-Api。..._ => sys.terminate()} 下面是本次讨论的示范源代码： 服务端代码： import akka.actor._ import akka.stream._ import akka.http.scaladsl.Http...import akka.http.scaladsl.server.Directives._ import de.heikoseeberger.akkahttpjson4s.Json4sSupport...._ import akka.http.scaladsl.Http import akka.http.scaladsl.model._ import scala.util._ import de.heikoseeberger.akkahttpjson4s.Json4sSupport...import akka.http.scaladsl.common._ trait JsonCodec extends Json4sSupport { import org.json4s.DefaultFormats
所以，Akka-http的核心功能应该是数据交换的实现了：应该能通过某种公开的数据格式和传输标准比较方便的实现包括异类系统之间通过网上进行的数据交换。覆盖包括：数据编码、发送和数据接收、解析全过程。...Akka-http提供了许多网上传输标准数据的概括模型以及数据类型转换方法，可以使编程人员很方便的构建网上往来的Request和Response。...Akka-http是基于Akka-stream开发的：不但它的工作流程可以用Akka-stream来表达，它还支持stream化的数据传输。...我们知道：Akka-stream提供了功能强大的FileIO和Data-Streaming，可以用Stream-Source代表文件或数据库数据源。...Akka-http的stream类型数据内容是以Source[T,_]类型表示的。
akka.actor._ import akka.stream._ import akka.http.scaladsl.Http import akka.http.scaladsl.server.Directives...._ import akka.stream._ import akka.http.scaladsl.Http import akka.http.scaladsl.model.headers._ import...scala.concurrent._ import akka.http.scaladsl.model._ import pdi.jwt._ import org.json4s._ import org.json4s.jackson.JsonMethods...% "jwt-core" % "3.0.1", "de.heikoseeberger" %% "akka-http-json4s" % "1.22.0", "org.json4s" %% "json4s-native..." % "3.6.1", "com.typesafe.akka" %% "akka-http-spray-json" % "10.1.8", "com.typesafe.scala-logging
领取专属 10元无门槛券
手把手带您无忧上云
云服务器
ICP备案
对象存储
腾讯会议
云直播
