spark restful_Spark入门:也可以用Java创建轻量级的RESTful应用程序

spark restful

最近,我一直在使用Spark (一种Java的Web框架,与Apache Spark 相关)编写RESTful服务。 当我们计划写这篇文章时,我已经做好了不可避免的接口,样板代码和深层层次结构的Java风格的准备。 令我惊讶的是,对于局限于Java的开发人员来说,还有一个替代世界。

在本文中,我们将了解如何使用JSON传输数据来为博客构建RESTful应用程序。 我们会看到:

  • 如何在Spark中创建一个简单的Hello World
  • 如何指定请求中期望的JSON对象的布局
  • 如何发送帖子请求以创建新帖子
  • 如何发送获取请求以检索帖子列表

我们不会看到如何在数据库中插入此数据。 我们只将列表保留在内存中(在我的实际服务中,我一直在使用sql2o )。

一些依赖

我们将使用Maven,因此我将首先创建一个新的pom.xml并添加一些内容。 基本上:

  • 火花
  • 杰克逊
  • Lombok
  • 番石榴
  • Easymock(仅在测试中使用,本文中未介绍)
  • 格森
<dependencies><dependency><groupId>junit</groupId><artifactId>junit</artifactId><version>4.12</version><scope>test</scope></dependency><dependency><groupId>com.sparkjava</groupId><artifactId>spark-core</artifactId><version>2.1</version></dependency><dependency><groupId>com.fasterxml.jackson.core</groupId><artifactId>jackson-core</artifactId><version>2.5.1</version></dependency><dependency><groupId>com.fasterxml.jackson.core</groupId><artifactId>jackson-databind</artifactId><version>2.5.1</version></dependency><dependency><groupId>org.projectlombok</groupId><artifactId>lombok</artifactId><version>1.16.2</version><scope>provided</scope></dependency><dependency><groupId>org.sql2o</groupId><artifactId>sql2o</artifactId><version>1.5.4</version></dependency><dependency><groupId>org.postgresql</groupId><artifactId>postgresql</artifactId><version>9.4-1201-jdbc41</version></dependency><dependency><groupId>com.google.guava</groupId><artifactId>guava</artifactId><version>18.0</version></dependency><dependency><groupId>org.easymock</groupId><artifactId>easymock</artifactId><version>3.3.1</version><scope>test</scope></dependency><dependency><groupId>com.google.code.gson</groupId><artifactId>gson</artifactId><version>2.3.1</version><scope>test</scope></dependency></dependencies><build><plugins><plugin><groupId>org.apache.maven.plugins</groupId><artifactId>maven-compiler-plugin</artifactId><version>3.2</version><configuration><source>1.8</source><target>1.8</target></configuration></plugin><plugin><groupId>org.codehaus.mojo</groupId><artifactId>exec-maven-plugin</artifactId><version>1.2.1</version><configuration><mainClass>me.tomassetti.BlogService</mainClass><arguments></arguments></configuration></plugin></plugins></build>

火花你好世界

你有这一切吗? 酷,那我们就写一些代码吧。

package me.tomassetti;import static spark.Spark.get;
import static spark.Spark.post;
import spark.Request;
import spark.Response;
import spark.Route;public class BlogService 
{public static void main( String[] args) {get("/posts", (req, res) -> {return "Hello Sparkingly World!";});}
}

现在,我们可以使用以下命令运行它:

mvn compile && mvn exec:java

让我们打开浏览器并访问localhost http:// localhost:4567 / posts 。 在这里我们要做一个简单的获取。 对于执行帖子,您可能需要在浏览器中使用Postman插件或只运行curl 。 一切为您服务。

使用Jackson和Lombok进行很棒的描述性交换对象

在一个典型的RESTful应用程序中,我们希望接收带有json对象的POST请求作为有效负载的一部分。 我们的工作将是检查代码是否为格式正确的JSON,是否与预期的结构相对应,值是否在有效范围内,等等。无聊且重复。 我们可以用不同的方式做到这一点。 最基本的一种是使用gson :

JsonParser parser = new JsonParser();
JsonElement responseData = parser.parse(response);
if (!responseData.isJsonObject()){// send an error like: "Hey, you did not pass an Object!
}
JsonObject obj = responseData.getAsJsonObject();
if (!obj.hasField("title")){// send an error like: "Hey, we were expecting a field name title!
}
JsonElement titleAsElem = obj.get("title");
if (!titleAsElem.isString()){// send an error like: "Hey, title is not an string!
}
// etc, etc, etc

我们可能不想这样做。

指定我们期望的结构的更具声明性的方法是创建特定的类。

class NewPostPayload {private String title;private List<String> categories;private String content;public String getTitle() { ... }public void setTitle(String title) { ... }public List<String> getCategories() { ... }public void setCategories(List<String> categories){ ... }public String getContent() { ... }public void setContent(String content) { ... }
}

然后我们可以使用Jackson:

try {ObjectMapper mapper = new ObjectMapper();NewPostPayload newPost = mapper.readValue(request.body(), NewPostPayload.class);
} catch (JsonParseException e){// Hey, you did not send a valid request!
}

这样,杰克逊会自动为我们检查有效载荷是否具有预期的结构。 我们可能想验证是否遵守其他约束。 例如,我们可能要检查标题是否为空,并且至少指定了一个类别。 我们可以创建一个仅用于验证的接口:

interface Validable {boolean isValid();
}class NewPostPayload implements Validable {private String title;private List<String> categories;private String content;public String getTitle() { ... }public void setTitle(String title) { ... }public List<String> getCategories() { ... }public void setCategories(List<String> categories){ ... }public String getContent() { ... }public void setContent(String content) { ... }public boolean isValid() {return title != null && !title.isEmpty() && !categories.isEmpty();}
}

仍然有很多无聊的getter和setter方法。 它们的信息量不是很大,只会污染代码。 我们可以使用Lombok摆脱它们。 Lombok是一个注释处理器,可以为您添加重复方法(getter,setter,equals,hashCode等)。 您可以将其视为编译器的插件,该插件可查找注释(例如@Data )并基于注释生成方法。 如果将其添加到依赖项中,maven会很好,但是您的IDE无法为Lombok添加的方法自动完成。 您可能要安装插件。 对于Intellij Idea,我使用的是Lombok插件版本0.9.1,它的效果很好。

现在,您可以将类NewPostPayload修改为:

@Data
class NewPostPayload {private String title;private List<String> categories;private String content;public boolean isValid() {return title != null && !title.isEmpty() && !categories.isEmpty();}
}

好多了,是吗?

一个完整的例子

我们基本上需要做两件事:

  1. 插入新帖子
  2. 检索整个帖子列表

第一个操作应实现为POST(具有副作用),而第二个操作应实现为GET。 它们都对posts集合进行操作,因此我们将使用端点/ posts

让我们从插入帖子开始。 首先我们要解析

// insert a post (using HTTP post method)post("/posts", (request, response) -> {try {ObjectMapper mapper = new ObjectMapper();NewPostPayload creation = mapper.readValue(request.body(), NewPostPayload.class);if (!creation.isValid()) {response.status(HTTP_BAD_REQUEST);return "";}int id = model.createPost(creation.getTitle(), creation.getContent(), creation.getCategories());response.status(200);response.type("application/json");return id;} catch (JsonParseException jpe) {response.status(HTTP_BAD_REQUEST);return "";}});

然后查看如何检索所有帖子:

// get all post (using HTTP get method)get("/posts", (request, response) -> {response.status(200);response.type("application/json");return dataToJson(model.getAllPosts());});

最后的代码是:

package me.tomassetti;import static spark.Spark.get;
import static spark.Spark.post;import com.fasterxml.jackson.core.JsonParseException;
import com.fasterxml.jackson.databind.ObjectMapper;
import com.fasterxml.jackson.databind.SerializationFeature;
import lombok.Data;
import spark.Request;
import spark.Response;
import spark.Route;import java.io.IOException;
import java.io.StringWriter;
import java.util.HashMap;
import java.util.LinkedList;
import java.util.List;
import java.util.Map;
import java.util.stream.Collector;
import java.util.stream.Collectors;public class BlogService 
{private static final int HTTP_BAD_REQUEST = 400;interface Validable {boolean isValid();}@Datastatic class NewPostPayload {private String title;private List<String> categories = new LinkedList<>();private String content;public boolean isValid() {return title != null && !title.isEmpty() && !categories.isEmpty();}}// In a real application you may want to use a DB, for this example we just store the posts in memorypublic static class Model {private int nextId = 1;private Map<Integer, Post> posts = new HashMap<>();@Dataclass Post {private int id;private String title;private List<String> categories;private String content;}public int createPost(String title, String content, List<String> categories){int id = nextId++;Post post = new Post();post.setId(id);post.setTitle(title);post.setContent(content);post.setCategories(categories);posts.put(id, post);return id;}public List<Post> getAllPosts(){return posts.keySet().stream().sorted().map((id) -> posts.get(id)).collect(Collectors.toList());}}public static String dataToJson(Object data) {try {ObjectMapper mapper = new ObjectMapper();mapper.enable(SerializationFeature.INDENT_OUTPUT);StringWriter sw = new StringWriter();mapper.writeValue(sw, data);return sw.toString();} catch (IOException e){throw new RuntimeException("IOException from a StringWriter?");}}public static void main( String[] args) {Model model = new Model();// insert a post (using HTTP post method)post("/posts", (request, response) -> {try {ObjectMapper mapper = new ObjectMapper();NewPostPayload creation = mapper.readValue(request.body(), NewPostPayload.class);if (!creation.isValid()) {response.status(HTTP_BAD_REQUEST);return "";}int id = model.createPost(creation.getTitle(), creation.getContent(), creation.getCategories());response.status(200);response.type("application/json");return id;} catch (JsonParseException jpe) {response.status(HTTP_BAD_REQUEST);return "";}});// get all post (using HTTP get method)get("/posts", (request, response) -> {response.status(200);response.type("application/json");return dataToJson(model.getAllPosts());});}
}

使用PostMan尝试应用程序

如果您更喜欢命令行,则可能要改用curl。 我喜欢不必转义JSON和使用基本的编辑器,因此可以使用PostMan(Chrome插件)。

让我们插入一个帖子。 我们将所有字段指定为插入请求主体中的Json对象的一部分。 我们获取创建的帖子的ID。

Screen-Shot-2015-03-30-at-17.25.22

然后,我们可以获得帖子列表。 在这种情况下,我们使用GET(请求中没有正文),并获取所有帖子的数据(仅是我们在上面插入的帖子)。

Screen-Shot-2015-03-30-at-17.30.33

结论

我不得不说,我对该项目感到非常惊讶。 我已经准备好了变得更糟:这是一种需要基本逻辑和大量管道的应用程序。 我发现Python,Clojure和Ruby在解决这类问题上都做得很好,而当我用Java编写简单的Web应用程序时,逻辑就被样板代码淹没了。 好吧,事情可能会有所不同。 Spark,Lombok,Jackson和Java 8的结合确实很诱人。 我非常感谢这些软件的作者,他们确实在改善Java开发人员的生活。 我认为这也是一个教训:出色的框架通常可以使事情比我们想象的要好得多。

编辑:我从reddit的好人那里收到了一个改进示例的建议。 谢谢! 请保持良好的建议来!

翻译自: https://www.javacodegeeks.com/2015/08/getting-started-with-spark-it-is-possible-to-create-lightweight-restful-application-also-in-java.html

spark restful

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

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

相关文章

C++的get()函数与getline()函数使用详解

点击蓝字关注我们来源自网络&#xff0c;侵删一.C的get()函数使用详解1.C get()函数get()函数是cin输入流对象的成员函数&#xff0c;它有3种形式&#xff1a;无参数的&#xff1b;有一个参数的&#xff1b;有3个参数的。1) 无参数的其调用形式为cin.get()用来从指定的输入流中…

电脑所有程序里有不一样颜色_12个好玩的电脑屏保,让你成为别人眼中最靓的仔。...

Hello 大家好&#xff0c;这里是工具狂人。作为一个靠打字(哦不&#xff0c;搬砖)为生的新媒体小编&#xff0c;每天多数时候都是对着电脑屏幕&#xff0c;中途有时会拿起手机回复消息、查看短信、刷起微博。刷手机的时间一长&#xff0c;眼前的电脑会自动打开系统的屏保程序&a…

java8 函数式编程_如何使用Java 8函数式编程生成字母序列

java8 函数式编程我偶然发现了用户“ mip”一个有趣的堆栈溢出问题 。 问题是&#xff1a; 我正在寻找一种生成字母序列的方法&#xff1a; A, B, C, ..., Z, AA, AB, AC, ..., ZZ.可以很快将其识别为Excel电子表格的标题&#xff0c;它确实做到了&#xff1a; 到目前为止&a…

C++判断变量/对象/枚举类型的简单方式

点击蓝字关注我们来源于网络&#xff0c;侵删1.关键点<typeinfo>使用typeid()操作符所需包含的头文件。typeid()获取变量类型信息的操作符&#xff0c;其返回值类型为std::typeinfo。我们可使用typeid(n) typeid(int)的方式来判断变量n是否为类型int。注&#xff1a;可以…

C++ 空指针和野指针

点击蓝字关注我们来源于网络&#xff0c;侵删1.空指针指针变量指向内存中编号为0的空间为空指针。空指针指向的内存空间是不可以访问的 。代码&#xff1a;#include<iostream> using namespace std; int main() {int a 10;int * p &a;cout << p << end…

sap abap开发从入门到精通_SAP开发-ABAP数据字典(锁)

企业级软件或开发框架&#xff0c;必然支持后台高并发&#xff0c;即支持多人同时访问数据库。SAP作为资深企业管理软件&#xff0c;自然也不例外&#xff0c;ABAP可以很方便的开发出支持高并发的程序&#xff0c;要实现高并发&#xff0c;正确使用锁对象是其中一个重要环节&am…

(acm)C++加速输入的几种方法

点击蓝字关注我们来源于网络&#xff0c;侵删1.CIO流的同步和绑定在C中&#xff0c;cin和cout的速度其实不并不慢&#xff0c;C中的流的IO速度相当的快&#xff0c;其速度与初始设定的缓存区大小和硬盘的IO速度有关。但在C中&#xff0c;为了兼容C的IO(scanf和printf)&#xff…

服务器编写_编写下载服务器。 第六部分:描述您发送的内容(内容类型等)...

服务器编写就HTTP而言&#xff0c;客户端下载的只是一堆字节。 但是&#xff0c;客户真的很想知道如何解释这些字节。 它是图像吗&#xff1f; 还是ZIP文件&#xff1f; 本系列的最后一部分描述了如何向客户端提示她下载的内容。 设置 内容类型描述了返回的资源的MIME类型 。 …

C语言与C++的区别终于有人说清楚了!

点击蓝字关注我们来源于网络&#xff0c;侵删1、前言在很大程度上&#xff0c;C是C的超集&#xff0c;这意味着一个有效的C程序也是一个有效的C程序。C和C的主要区别是&#xff0c;C支持许多附加特性。但是&#xff0c;C中有许多规则与C稍有不同。这些不同使得C程序作为C程序编…

postgresql两个列模糊比较_数据分析之SQL优化系列(二)---PostgreSQL 的索引

参考《PostgreSQL11.2-中文手册》下面这个链接&#xff0c;讲的通俗易懂&#xff0c;可以看看。数据分析师不得不知道的SQL优化 - 鑫获 - 博客园​www.cnblogs.com索引是提高数据库性能的常用途径。比起没有索引&#xff0c;使用索引可以让数据库服务器更快找到并获取特定行。但…

高达 36 斤的 C/C++ 编译器?

点击蓝字关注我们来源于网络&#xff0c;侵删前言软件有重量吗&#xff1f;有人说&#xff0c;现代的软件主要搭载在硬件之上&#xff0c;只有占用内存的大小&#xff1b;也有人说&#xff0c;软件都是在网络上下载下来的&#xff0c;哪有什么重量可言&#xff1b;还有人说&…

双屏全屏跳回到主屏_双屏笔记本了解下?剪视频不要太好使

[PConline 评测]每天一开始上班&#xff0c;我们就要开始跟各种电脑程序和窗口打交道&#xff0c;而当面对各种信息和数据的轰炸时&#xff0c;恨不得就要把ALTTAB两个键给磨烂了。↑每天至少要面对十多个窗口gif而今天&#xff0c;笔记本厂商也不再吝啬于给予用户更多更大的屏…

一例看懂C语言程序中的内聚和耦合

点击蓝字关注我们来源自网络&#xff0c;侵删一、原理篇&#xff08;清楚相关原理的读者&#xff0c;请直接看第二部分示例篇&#xff09;在软件工程中&#xff0c;模块的内聚和耦合是度量模块化质量的标准之一。内聚是指模块的功能强度的度量&#xff0c;即一个模块内部各个元…

openfire消息通知推送_APP消息推送功能之前端后台设计

APP消息推送功能之前端后台设计最近有不少小伙伴问APP消息推送功能&#xff0c;前端、后台如何设计的&#xff1f;消息系统的架构是什么样的&#xff1f;最近刚好做到后台消息推送这块&#xff0c;简单谈谈个人心得&#xff0c;欢迎拍砖。消息推送是让自己的用户获取信息最有效…

apache spark_Apache Spark:更改架构之前必须解决的5个陷阱

apache spark迁移到Apache Spark之前需要了解的5件事 似乎每个人都只是在谈论最热门的新技术&#xff0c;而忽略采用它的实际含义。 但这是自然的&#xff0c;对吧&#xff1f; 新功能和承诺胜过其他所有事物&#xff0c;而艰难的挑战和决​​定被抛在一边。 这次不行。 软件…

分步解析C++实现通讯录管理系统

点击蓝字关注我们来源于网络&#xff0c;侵删一、前言建议亲手写一遍代码&#xff0c;感受指针神奇的魅力&#xff1b;可以帮助你更好的巩固知识体系&#xff0c;熟悉指针&#xff0c;结构体与函数一起使用时的妙处完成通讯录管理系统所需知识体系结构体指针函数的封装指针与函…

如何用C++实现动态放烟花(附源码)

点击蓝字关注我们来源于网络&#xff0c;侵删一、前言C实现的放烟花程序用到了EGE图形库&#xff0c;没有的需要自行安装可调项&#xff1a;背景图和背景音乐、粒子模糊度、亮度以及上升速度的参数。实现的动态烟花非常好看&#xff0c;可以做给女朋友或者表白用&#xff0c;呵…

nginx哪个版本性能好_nginx性能为什么好

nginx在启动后&#xff0c;在unix系统中会以daemon的方式在后台运行&#xff0c;后台进程包含一个master进程和多个worker进程。我们也可以手动地关掉后台模式&#xff0c;让nginx在前台运行&#xff0c;并且通过配置让nginx取消master进程&#xff0c;从而可以使nginx以单进程…

metrics_FlexyPool如何支持Dropwizard Metrics包重命名

metrics介绍 FlexyPool严重依赖Dropwizard &#xff08;以前称为Codahale&#xff09;度量标准来监视连接池的使用情况 。 集成到Dropwizard中后&#xff0c;程序包名称必然会被重命名 。 因此&#xff0c;4.0.0版本将使用io.dropwizard.metrics软件包名称代替com.codahale.me…

用C++写一个http服务器/web服务器

点击蓝字关注我们来源于网络&#xff0c;侵删本篇文章不会涉及到很多复杂的概念&#xff0c;也没有写很难读懂的模板函数&#xff0c;代码简单可读&#xff0c;本篇文章送给每一个想自己用C写一个http服务器的小伙伴&#xff01;高手们、大佬们当然可以不用看的啦&#xff01;正…