前往小程序,Get更优阅读体验!
立即前往
首页
学习
活动
专区
圈层
工具
发布
首页
学习
活动
专区
圈层
工具
MCP广场
社区首页 >专栏 >单元测试(Spring)

单元测试(Spring)

作者头像
YGingko
发布于 2017-12-28 05:53:36
发布于 2017-12-28 05:53:36
4.8K00
代码可运行
举报
文章被收录于专栏:海说海说
运行总次数:0
代码可运行

单元测试是指对软件中的最小可测试单元进行的检查和验证,是软件开发过程中要进行的最低级别的测试活动,软件的独立单元将在与程序的其他部分相隔离的情况下进行测试。

单元测试好处:提高代码质量(实现功能、逻辑严密)、减少调试时间、隔离测试。

前期准备

单元测试工具类很多,一般选择流行的Junit和Mockito进行测试演示。如果进行普通组合测试可不用Mockito,隔离测试则需用到Mockito。

首先,引入相关Jar包 --- Junit 和 org.mockito。如果是使用Maven工程,则需在pom.xml文件中引入依赖。参考样式如下:

代码语言:javascript
代码运行次数:0
运行
AI代码解释
复制
 1     <dependencies>
 2         <dependency>
 3             <groupId>junit</groupId>
 4             <artifactId>junit</artifactId>
 5             <version>4.12</version>
 6             <scope>test</scope>
 7         </dependency>
 8         <dependency>
 9             <groupId>org.mockito</groupId>
10             <artifactId>mockito-core</artifactId>
11             <version>1.10.19</version>
12             <scope>test</scope>
13         </dependency>
14         
15         ………………
16 
17     </dependencies>

其次,建立测试类。可通过JUnit工具生成测试类(可设置生成的测试类位置),也可手动创建。一般情况,建议一个java类对应一个测试类,但如果需针对一个方法进行多方面测试,则可针对一个类中一个方法创建一个测试类。例如:测试找不到控制器,404测试、验证请求参数绑定、验证请求参数验证失败、JSON请求、响应异常处理等等。

普通测试

普通测试是将整个大的模块整体一起测试。如目标测试Controller层,但Control层依赖Service层,而Service层又依赖DAO层,则我们对Controller进行普通测试时,便连同Serice层和DAO层也一起测试了。

常规步骤:(1)参数赋值  (2)写出期望值  (3)获取实际值  (4)断言 --- 比较期望值与实际值是否相同

示例:(Controller)

代码语言:javascript
代码运行次数:0
运行
AI代码解释
复制
 1 import org.junit.Assert;
 2 import org.junit.Before;
 3 import org.junit.Test;
 4 import org.junit.runner.RunWith;
 5 import org.springframework.beans.factory.annotation.Autowired;
 6 import org.springframework.test.context.ContextConfiguration;
 7 import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
 8 import org.springframework.test.context.transaction.TransactionConfiguration;
 9 import org.springframework.test.context.web.WebAppConfiguration;
10 import org.springframework.test.web.servlet.MockMvc;
11 import org.springframework.test.web.servlet.MvcResult;
12 import org.springframework.test.web.servlet.request.MockMvcRequestBuilders;
13 import org.springframework.test.web.servlet.result.MockMvcResultHandlers;
14 import org.springframework.test.web.servlet.result.MockMvcResultMatchers;
15 import org.springframework.test.web.servlet.setup.MockMvcBuilders;
16 import org.springframework.web.context.WebApplicationContext;
17 
18 @WebAppConfiguration
19 @ContextConfiguration({
20         "classpath*:applicationContext-*.xml",
21         "classpath*:springmvc-*.xml"})
22 @RunWith(SpringJUnit4ClassRunner.class)
23 @TransactionConfiguration(transactionManager="transactionManager", defaultRollback=true)
24 public class ControllerTest {
25 
26     @Autowired
27     protected WebApplicationContext wac;
28 
29     @Autowired
30     private ToTestController controller;        //需要测试的Controller
31 
32     private MockMvc mockMvc;
33 
34     private String url = "The URL to Controller";
35     private String param1, param2, param3;
36 
37     private String expected = "huang";
38 
39     @Before
40     public void setup() {
41         mockMvc = MockMvcBuilders.webAppContextSetup(wac).build();             //整个mvc环境
42         //mockMvc = MockMvcBuilders.standaloneSetup(controller).build();        加载局部mvc环境、两种方式都可以
43     }
44 
45     @Test
46     public void testController() throws Exception {
47         MvcResult result = mockMvc.perform(MockMvcRequestBuilders.post(url)        //传入的URL,进入对应的Controller        MockMvcRequestBuilders.get(url)
48                             .param("param1", param1)                        //URL中携带的参数     key-value
49                             .param("param2", param2)
50                             .param("param3", param3))
51                             .andExpect(MockMvcResultMatchers.view().name("user/view"))
52                             .andExpect(MockMvcResultMatchers.model().attributeExists("user"))
53                             .andDo(MockMvcResultHandlers.print())
54                             .andReturn();
55 
56         Assert.assertNotNull(result.getModelAndView().getModel().get("user"));
57         Assert.assertEquals(expected, result.getModelAndView().getModel().get("user"));
58     }
59 }

@WebAppConfiguration:测试环境使用,表示测试环境使用的ApplicationContext是WebApplicationContext类型的。@WebAppConfiguration(value = "src/main/webapp") 中value指定web应用的根;

@ContextConfiguration:指定Spring配置文件或者配置类的位置;

@RunWith(SpringJUnit4ClassRunner.class):启动Spring对测试类的支持;

@TransactionConfiguration(transactionManager="transactionManager", defaultRollback=true):启用自动的事务管理,事务回滚;

@Autowired:自动织入 Spring 的 bean 用来测试;

@Before:每个方法测试前调用。一般用于public void setup() { mockMvc=MockMvcBuilders.standaloneSetup(wac).build();}前面;

@Test:测试方法,表明这是一个测试方法。在Junit中将会自动被执行。

MockMvc:在setUp(){}方法中,通过MockMvcBuilders.webAppContextSetup(wac).build()创建一个MockMvc进行测试;

mockMvc.perform():执行一个请求;

MockMvcRequestBuilders.post(url).param("param1", param1):构造一个请求,请求可传带参数;

ResultActions.andExpect():添加执行完成后的断言,ResultMatcher验证规则,验证控制器执行完成后结果是否正确;

ResultActions.andDo():添加一个结果处理器,表示要对结果做点什么事情,比如此处使用MockMvcResultHandlers.print()输出整个响应结果信息;

ResultActions.andReturn():表示执行完成后返回相应的结果;

Assert.  :通过静态方法执行断言,判断测试结果与预期是否相同。

示例:(Service、DAO)

代码语言:javascript
代码运行次数:0
运行
AI代码解释
复制
 1 import org.junit.Assert;
 2 import org.junit.Test;
 3 import org.junit.runner.RunWith;
 4 import org.springframework.beans.factory.annotation.Autowired;
 5 import org.springframework.test.context.ContextConfiguration;
 6 import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
 7 import org.springframework.test.context.transaction.TransactionConfiguration;
 8 import org.springframework.test.context.web.WebAppConfiguration;
 9 
10 
11 @WebAppConfiguration
12 @ContextConfiguration({
13         "classpath*:applicationContext-*.xml",
14         "classpath*:springmvc-*.xml"})
15 @RunWith(SpringJUnit4ClassRunner.class)
16 @TransactionConfiguration(transactionManager="transactionManager", defaultRollback=true)
17 public class ServiceTest {
18 
19 
20     @Autowired
21     private ToTestService service;        //需要测试的service
22 
23     private String expected = "huang";
24 
25     @Test
26     public void testService() throws Exception {
27         Student student = new Student("name", "sex", "school");         //创建测试方法的传入参数
28         boolean result = service.add(student);              //需要测试的service中的add方法
29         Assert.assertTrue(result);
30     }
31 }

对于Service、DAO仅仅是测试用,则需要加上事务回滚

代码语言:javascript
代码运行次数:0
运行
AI代码解释
复制
1 @TransactionConfiguration(transactionManager="transactionManager", defaultRollback=true)

对Service、DAO的测试相对于Controller来说要简单很多,大部分内容都在Controller里面讲过,不同的地方就是Controller是使用mockMvc对象来模拟Controler的被测方法,而在Service的单元测试中则是直接调用Service的方法。

针对DAO层测试方法和Service层测试方法类似。

示例:(Service、DAO)参数化测试

参数化测试主要是用于测试分支语句,多个参数覆盖if…else等判断语句中的分支,使测试更全面。

代码语言:javascript
代码运行次数:0
运行
AI代码解释
复制
 1 import org.junit.Assert;
 2 import org.junit.Before;
 3 import org.junit.Test;
 4 import org.junit.runner.RunWith;
 5 import org.junit.runners.Parameterized;
 6 import org.springframework.test.context.ContextConfiguration;
 7 import org.springframework.test.context.transaction.TransactionConfiguration;
 8 import org.springframework.test.context.web.WebAppConfiguration;
 9 
10 import java.util.Arrays;
11 import java.util.Collection;
12 
13 @WebAppConfiguration
14 @ContextConfiguration({
15         "classpath*:applicationContext-*.xml",
16         "classpath*:springmvc-*.xml"})
17 @RunWith(Parameterized.class)
18 @TransactionConfiguration(transactionManager="transactionManager", defaultRollback=true)
19 public class ServiceParamTest {
20 
21     private ToTestService service;        //需要测试的service
22 
23     private int input;          //为测试类声明变量,存放测试所用数据
24     private boolean expected;       //为测试类声明变量,存放期望值
25 
26     @Before
27     public void setUp() throws Exception {
28         service = new ToTestService();
29     }
30 
31     //构造函数
32     public ServiceParamTest(int input, boolean expected) {
33         this.input = input;
34         this.expected = expected;
35     }
36 
37     //为测试类声明一个注解@Parameters,返回值为Collection的公共静态方法,并初始化所有需要测试的参数对
38     @Parameterized.Parameters
39     public static Collection prepareData() {
40         Object[][] objects = new Object[][]{{-1, true}, {0, true}, {1, true}};
41         return Arrays.asList(objects);
42     }
43 
44     //编写测试方法,使用定义的变量作为参数进行测试
45     @Test
46     public void testServiceParam() throws Exception {
47         boolean result = service.excute(input);              //需要测试的service中的excute()方法
48         Assert.assertEquals(expected, result);
49     }
50 }

参数化测试五个步骤:

(1)为准备使用参数化测试的测试类指定特殊的运行器org.junit.runners.Parameterized;

(2)为测试类声明几个变量,分别用于存放期望值和测试所用数据;

(3)为测试类声明一个带有参数的公共构造函数,并在其中为第二个环节中声明的几个变量赋值;

(4)为测试类声明一个使用注解org.junit.runners.Parameterized.Parameters修饰的,返回值为 java.util.Collection的公共静态方法,并在此方法中初始化所有需要测试的参数对;

(5)编写测试方法,使用定义的变量作为参数进行测试。

隔离测试

除了普通的整体测试之外,我们经常要用到的隔离测试,也即是防止多类之间依赖的测试。例如当测试Controller层时,Controller层依赖Service层,而Service层又依赖于DAO层。这时,可以利用Mockito来进行隔离,单独测试Controller。

主要思想是利用Mockito --- 模拟。(需导入import org.mockito.Mockito;)

常规用法

模拟对象

代码语言:javascript
代码运行次数:0
运行
AI代码解释
复制
1         LinkedList mockedList = Mockito.mock(LinkedList.class);         //模拟LinkedList对象
2         System.out.println(mockedList.get(1));                          //返回值为null,没有对方法调用的返回值做模拟

模拟方法调用的返回值

代码语言:javascript
代码运行次数:0
运行
AI代码解释
复制
1         Mockito.when(mockedList.get(0)).thenReturn("first");
2         System.out.println(mockedList.get(0));

模拟方法调用的参数匹配

代码语言:javascript
代码运行次数:0
运行
AI代码解释
复制
1         Mockito.when(mockedList.get(Mockito.anyInt())).thenReturn("element");       // anyInt()匹配任何int参数,这意味着参数为任意值
2         System.out.println(mockedList.get(0));          // 此时打印是element

模拟方法调用抛出异常

代码语言:javascript
代码运行次数:0
运行
AI代码解释
复制
1         Mockito.when(mockedList.get(1)).thenThrow(new RuntimeException());
2         System.out.println(mockedList.get(1));
3 
4         Mockito.doThrow(new RuntimeException()).when(mockedList).clear();       //没有返回值类型的方法模拟抛出异常

示例:(Controller) -- 通过拦截器,测试Controller功能

代码语言:javascript
代码运行次数:0
运行
AI代码解释
复制
 1 import com.pytech.mplus.cm.entity.Account;
 2 import org.junit.Assert;
 3 import org.junit.Before;
 4 import org.junit.Test;
 5 import org.junit.runner.RunWith;
 6 import org.mockito.InjectMocks;
 7 import org.mockito.Mock;
 8 import org.mockito.Mockito;
 9 import org.mockito.MockitoAnnotations;
10 import org.springframework.beans.factory.annotation.Autowired;
11 import org.springframework.test.context.ContextConfiguration;
12 import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
13 import org.springframework.test.context.transaction.TransactionConfiguration;
14 import org.springframework.test.context.web.WebAppConfiguration;
15 import org.springframework.test.web.servlet.MockMvc;
16 import org.springframework.test.web.servlet.MvcResult;
17 import org.springframework.test.web.servlet.request.MockMvcRequestBuilders;
18 import org.springframework.test.web.servlet.result.MockMvcResultHandlers;
19 import org.springframework.test.web.servlet.result.MockMvcResultMatchers;
20 import org.springframework.test.web.servlet.setup.MockMvcBuilders;
21 import org.springframework.web.context.WebApplicationContext;
22 
23 
24 @WebAppConfiguration
25 @ContextConfiguration({
26         "classpath*:applicationContext-*.xml",
27         "classpath*:springmvc-*.xml"})
28 @RunWith(SpringJUnit4ClassRunner.class)
29 @TransactionConfiguration(transactionManager="transactionManager", defaultRollback=true)
30 public class ControllerMockitoTest {
31 
32     @Autowired
33     protected WebApplicationContext wac;
34 
35     @Mock
36     private UseService service;         //ToTestController中待测试方法依赖的service
37 
38     @InjectMocks
39     private ToTestController controller;        //需要测试的Controller
40 
41     private MockMvc mockMvc;
42 
43     private String url = "The URL to Controller";
44     private String param1, param2, param3;
45 
46     private String expected = "huang";
47 
48     @Before
49     public void setup() {
50         MockitoAnnotations.initMocks(this);     //使得打上Mock标签的对象被mock,依赖于Mock对象的类自动与Mock对象关联
51 
52         mockMvc = MockMvcBuilders.webAppContextSetup(wac).build();             //整个mvc环境
53         //mockMvc = MockMvcBuilders.standaloneSetup(controller).build();        加载局部mvc环境、两种方式都可以
54     }
55 
56     @Test
57     public void testControllerMockito() throws Exception {
58 
59         Account account = Mockito.mock(Account.class);
60         account.setAccessTime(new java.util.Date());
61         account.setUsername("huang");
62         account.setPhone("12312341234");
63 
64         Mockito.when(service.getAccountById(Mockito.anyInt())).thenReturn(account);
65 
66         MvcResult result = mockMvc.perform(MockMvcRequestBuilders.post(url)        //传入的URL,进入对应的Controller        MockMvcRequestBuilders.get(url)
67                 .param("param1", param1)                        //URL中携带的参数     key-value
68                 .param("param2", param2)
69                 .param("param3", param3))
70                 .andExpect(MockMvcResultMatchers.view().name("user/view"))
71                 .andExpect(MockMvcResultMatchers.model().attributeExists("user"))
72                 .andDo(MockMvcResultHandlers.print())
73                 .andReturn();
74 
75         Assert.assertNotNull(result.getModelAndView().getModel().get("user"));
76         Assert.assertEquals(expected, result.getModelAndView().getModel().get("user"));
77 
78         System.out.println(result.getModelAndView().getModel().get("user"));
79     }
80 }

要做到隔离,就得模拟其依赖部分。当测试方法需调用依赖方法时便返回模拟值,从而达到隔离测试的目的。

示例:(Controller) -- 直接绕过系统拦截器,测试Controller功能

代码语言:javascript
代码运行次数:0
运行
AI代码解释
复制
 1 import org.junit.Assert;
 2 import org.junit.Before;
 3 import org.junit.Test;
 4 import org.mockito.InjectMocks;
 5 import org.mockito.Mock;
 6 import org.mockito.Mockito;
 7 import org.mockito.MockitoAnnotations;
 8 import org.springframework.mock.web.MockHttpServletRequest;
 9 import org.springframework.mock.web.MockHttpServletResponse;
10 import org.springframework.mock.web.MockHttpSession;
11 import org.springframework.test.context.transaction.TransactionConfiguration;
12 import org.springframework.test.web.servlet.MockMvc;
13 import org.springframework.ui.Model;
14 import org.springframework.web.bind.annotation.RequestParam;
15 import org.springframework.web.servlet.ModelAndView;
16 
17 @TransactionConfiguration(transactionManager="transactionManager", defaultRollback=true)
18 public class ToTestController_toTestFunction_Test {
19 
20     @Mock
21     private UsedService usedService;
22 
23     @InjectMocks
24     private ToTestController controller;
25 
26     private MockHttpServletRequest request;
27     private MockHttpServletResponse response;
28     private MockHttpSession session;
29     private ModelAndView modelAndView;
30     private Model model;
31 
32     @Before
33     public void setUp() {
34 
35         MockitoAnnotations.initMocks(this);
36 
37         request = new MockHttpServletRequest();
38         response = new MockHttpServletResponse();
39         session = new MockHttpSession();
40     }
41 
42     @Test
43     public void ParamsError() throws Exception {
44         session.setAttribute("name1", "value1");
45         session.setAttribute("name1", "value1");
46         request.setSession(session);
47 
48         Info info = new Info();
49 
50         Mockito.when(usedService.getMerchantInfo(Mockito.anyString())).thenReturn(info);
51         
52         String result = controller.getStatuss(request, response, model);
53         Assert.assertEquals("expected value", result);
54 
55         System.out.println(model.toString());
56     }
57 }

示例:(Service)

代码语言:javascript
代码运行次数:0
运行
AI代码解释
复制
 1 import org.junit.Assert;
 2 import org.junit.Before;
 3 import org.junit.Test;
 4 import org.junit.runner.RunWith;
 5 import org.mockito.InjectMocks;
 6 import org.mockito.Mock;
 7 import org.mockito.Mockito;
 8 import org.mockito.MockitoAnnotations;
 9 import org.springframework.test.context.ContextConfiguration;
10 import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
11 import org.springframework.test.context.transaction.TransactionConfiguration;
12 import org.springframework.test.context.web.WebAppConfiguration;
13 
14 @WebAppConfiguration
15 @ContextConfiguration({
16         "classpath*:applicationContext-*.xml",
17         "classpath*:springmvc-*.xml"})
18 @RunWith(SpringJUnit4ClassRunner.class)
19 @TransactionConfiguration(transactionManager="transactionManager", defaultRollback=true)
20 public class ServiceMockitoTest {
21 
22     @Mock
23     private UserDao userDao;
24 
25     @InjectMocks
26     private ToTestService service;
27 
28     @Before
29     public void setUp() {
30         MockitoAnnotations.initMocks(this);
31     }
32 
33     @Test
34     public void testService() throws Exception {
35         User user = Mockito.mock(User.class);
36         user.setName("huang");
37         user.setEmail("The email");
38         user.setSex("male");
39         Mockito.when(userDao.findByEmail(Mockito.anyString())).thenReturn(user);
40         //Mockito.when(userDao.findByEmail(Mockito.anyString())).thenReturn(null);
41 
42         Mockito.when(userDao.add(Mockito.any(User.class))).thenReturn(true);
43 
44         User u = service.getUserByEmail("The email");
45         System.out.println(u.toString);
46 
47         Assert.assertTrue(service.add(user));
48     }
49 }

Maven运行指令

可以通过在命令行中输入指令来运行所有的测试用例,命令如下:

代码语言:javascript
代码运行次数:0
运行
AI代码解释
复制
mvn clean test

可以直接在命令行中输入动态指令来运行指定的测试用例,命令如下:

代码语言:javascript
代码运行次数:0
运行
AI代码解释
复制
mvn test -Dtest=ToTestClass

也可以使用通配符,也可以使用“,”指定多个测试类,如下所示:

代码语言:javascript
代码运行次数:0
运行
AI代码解释
复制
mvn test -Dtest=To*Class,ToTestClass2

指定测试方法: 使用#指定测试方法,使用*通配测试方法,使用+号指定一个类中的多个测试方法

代码语言:javascript
代码运行次数:0
运行
AI代码解释
复制
1 mvn test  -Dtest=ToTestClass#testABC,ToTestCl*s2 
2 mvn test  -Dtest=ToTestClass#testABC,ToTestClass2 
3 mvn test  -Dtest=ToTestClass#testABC+testEFG,ToTestClass2 

JUnit插件

一些常用的IDE工具都带有JUnit插件,如EclipseIntelliJ IDEA

Eclipse:选中要运行的类(或光标放在要运行的测试方法上) --> 点击右键 --> Run as --> JUnit 即可运行。

IDEA:选中要运行的类(或光标放在要运行的测试方法上) --> 点击右键 --> Run。

本文参与 腾讯云自媒体同步曝光计划,分享自作者个人站点/博客。
原始发表:2015-12-08 ,如有侵权请联系 cloudcommunity@tencent.com 删除

本文分享自 作者个人站点/博客 前往查看

如有侵权,请联系 cloudcommunity@tencent.com 删除。

本文参与 腾讯云自媒体同步曝光计划  ,欢迎热爱写作的你一起参与!

评论
登录后参与评论
暂无评论
推荐阅读
FunDA(1)- Query Result Row:强类型Query结果行
本文讨论了如何使用Slick和Playwright库来自动化Web浏览和操作。作者首先介绍了Slick库,它是一个基于Scala的强大的库,用于处理大数据。然后,作者介绍了Playwright库,这是一个用于浏览器自动化和爬虫的库。作者使用Playwright库来自动化Web浏览和操作,包括导航、表单提交和JavaScript交互。此外,作者还讨论了如何利用Playwright库与Slick库进行集成,以实现更高效的数据处理和分析。
用户1150956
2018/01/05
9550
浅谈Slick(2)- Slick101:第一个动手尝试的项目
   看完Slick官方网站上关于Slick3.1.1技术文档后决定开始动手建一个项目来尝试一下Slick功能的具体使用方法。我把这个过程中的一些了解和想法记录下来和大家一起分享。首先我用Intell
用户1150956
2018/01/05
1.7K1
FunDA(2)- Streaming Data Operation:流式数据操作
   在上一集的讨论里我们介绍并实现了强类型返回结果行。使用强类型主要的目的是当我们把后端数据库SQL批次操作搬到内存里转变成数据流式按行操作时能更方便、准确、高效地选定数据字段。在上集讨论示范里我们
用户1150956
2018/01/05
1.4K0
浅谈Slick(1)- 基本功能描述
   Slick (Scala language-integrated connection kit)是scala的一个FRM(Functional Relational Mapper),即函数式的关
用户1150956
2018/01/05
8480
FunDA(15)- 示范:任务并行运算 - user task parallel execution
用户1150956
2018/01/05
6260
FunDA(13)- 示范:用户自定义操作函数 - user defined tasks
   FunDA是一种函数式的编程工具,它所产生的程序是由许多功能单一的细小函数组合而成,这些函数就是用户自定义操作函数了。我们在前面曾经提过FunDA的运作原理模拟了数据流管道。流元素在管道流动的过
用户1150956
2018/01/05
1.3K0
浅谈Slick(3)- Slick201:从fp角度了解Slick
  我在上期讨论里已经成功的创建了一个简单的Slick项目,然后又尝试使用了一些最基本的功能。Slick是一个FRM(Functional Relational Mapper),是为fp编程提供的sc
用户1150956
2018/01/05
2.9K0
浅谈Slick(4)- Slick301:我的Slick开发项目设置
  前面几篇介绍里尝试了一些Slick的功能和使用方式,看来基本可以满足用scala语言进行数据库操作编程的要求,而且有些代码可以通过函数式编程模式来实现。我想,如果把Slick当作数据库操作编程主要
用户1150956
2018/01/05
2.4K0
FunDA(16)- 示范:整合并行运算 - total parallelism solution
该文对技术社区在流式处理方面进行了探讨。首先介绍了基于Apache Spark和Apache Flink的流式处理框架,然后描述了在技术社区中如何利用这些框架进行流式处理。同时,文章还介绍了一些流式处理的应用场景,包括实时数据分析、实时报表、实时ETL等。此外,文章还探讨了流式处理在技术社区中的应用价值,包括缩短开发周期、提高代码复用性、简化运维等方面。
用户1150956
2018/01/05
7880
FunDA(14)- 示范:并行运算,并行数据库读取 - parallel data loading
   FunDA的并行数据库读取功能是指在多个线程中同时对多个独立的数据源进行读取。这些独立的数据源可以是在不同服务器上的数据库表,又或者把一个数据库表分成几个独立部分形成的独立数据源。当然,并行读取
用户1150956
2018/01/05
7430
geotrellis使用(三十)使用geotrellis读取PostGIS空间数据
前言 最近事情很多,各种你想不到的事情——such as singing and dancing——再加上最近又研究docker上瘾,所以geotrellis看上去似乎没有关注,其实我一直在脑中思考着geotrellis。之前看geotrellis源码看到有关geotrellis.slick的相关部分,仅大概浏览了一番,知道是用于读取PostGIS数据库的,未做深入研究,又恰巧前几日有老外在gitter上问了如何读取PostGIS数据库,我当时回答他可以用传统的JDBC方式或者使用geotrellis.sl
魏守峰
2018/04/28
1.7K0
restapi(4)- rest-mongo : MongoDB数据库前端的httpserver
完成了一套标准的rest风格数据库CRUD操作httpserver后发现有许多不足。主要是为了追求“通用”两个字,想把所有服务接口做的更“范generic”些,结果反而限制了目标数据库的特点,最终产生了一套功能弱小的玩具。比如说吧:标准rest风格getbyId需要所有的数据表都具备id这个字段,有点傻。然后get返回的结果集又没有什么灵活的控制方法如返回数量、字段、排序等。特别对MongoDB这样的在查询操作方面接近关系式数据库的分布式数据库:上篇提到过,它的query能力强大,条件组合灵活,如果不能在网络服务api中体现出来就太可惜了。所以,这篇博文会讨论一套专门针对MongoDB的rest-server。我想达到的目的是:后台数据库是MongoDB,通过httpserver提供对MongoDB的CRUD操作,客户端通过http调用CRUD服务。后台开发对每一个数据库表单使用统一的标准增添一套新的CRUD服务。希望如此能够提高开发效率,减少代码出错机会。
用户1150956
2019/08/13
1.9K0
restapi(2)- generic restful CRUD:通用的restful风格数据库表维护工具
研究关于restapi的初衷是想搞一套通用的平台数据表维护http工具。前面谈过身份验证和使用权限、文件的上传下载,这次来到具体的数据库表维护。我们在这篇示范里设计一套通用的对平台每一个数据表的标准维护方式。http服务端数据表维护CRUD有几个标准的部分组成:Model,Repository,Route。我们先看看这几个类型的基类:
用户1150956
2019/07/25
7550
SDP(8):文本式数据库-MongoDB-Scala基本操作
  MongoDB是一种文本式数据库。与传统的关系式数据库最大不同是MongoDB没有标准的格式要求,即没有schema,合适高效处理当今由互联网+商业产生的多元多态数据。MongoDB也是一种分布式数据库,充分具备大数据处理能力和高可用性。MongoDB提供了scala终端驱动mongo-scala-driver,我们就介绍一下MongoDB数据库和通过scala来进行数据操作编程。    与关系数据库相似,MongoDB结构为Database->Collection->Document。Collec
用户1150956
2018/03/16
1.9K0
SDP(12): MongoDB-Engine - Streaming
   在akka-alpakka工具包里也提供了对MongoDB的stream-connector,能针对MongoDB数据库进行streaming操作。这个MongoDB-connector里包含了MongoSource,MongoFlow,MongoSink。我们只使用MongoSource,其它两个我们直接用mapAsyc来创造。下面是MongoSource的定义: object MongoSource { def apply(query: Observable[Document]): Sour
用户1150956
2018/04/02
1.4K0
SDP(5):ScalikeJDBC- JDBC-Engine:Streaming
  作为一种通用的数据库编程引擎,用Streaming来应对海量数据的处理是必备功能。同样,我们还是通过一种Context传递产生流的要求。因为StreamingContext比较简单,而且还涉及到数据抽取函数extractor的传递,所以我们分开来定义: case class JDBCQueryContext[M]( dbName: Symbol, statement: String,
用户1150956
2018/03/16
1.1K0
restapi(5)- rest-mongo 应用实例:分布式图片管理系统之一,rest 服务
最近有同事提起想把网页上的图片存在MongoDB里,我十分赞同。比起把图片以文件形式存放在硬盘子目录的方式,MongoDB有太多的优势。首先,MongoDB是分布式数据库,图片可以跨服务器存储。在一个集群环境里通过复制集、分片等技术可以提高图片读取速度、实现数据的高可用和安全性。再就是对大量的图片可用规范的记录管理方式来进行处理,甚至在一个大流量环境里还可以用集群节点负载平衡方式来助力图片的存取。
用户1150956
2019/09/29
8560
Akka(35): Http:Server side streaming
该文介绍了如何使用Akka HTTP和Slick在Scala中实现基于HTTP的流式数据传输。通过使用Akka HTTP和Slick,可以方便地处理HTTP请求和响应,以及从数据库中获取数据并将其传输到客户端。该文还介绍了如何使用Akka流式处理技术来实现HTTP服务,并处理响应数据。
用户1150956
2018/01/05
8510
FunDA(6)- Reactive Streams:Play with Iteratees、Enumerator and Enumeratees
    在上一节我们介绍了Iteratee。它的功能是消耗从一些数据源推送过来的数据元素,不同的数据消耗方式代表了不同功能的Iteratee。所谓的数据源就是我们这节要讨论的Enumerator。En
用户1150956
2018/01/05
6860
Scala 强大的精简语法(示例)
本文介绍了 Scala 的强大精简语法,通过示例展示了如何利用 Scala 的特性进行高效的开发。主要包括以下内容:首先介绍了 Scala 的特点和优势,然后通过具体的代码示例演示了如何使用 Scala 进行高效的开发,包括使用隐式转换、集合操作、并发编程等。最后通过一个具体的实例,展示了如何使用 Scala 实现一个淘宝商品信息的提取和入库。
田祥
2017/06/15
1.9K0
Scala 强大的精简语法(示例)
推荐阅读
相关推荐
FunDA(1)- Query Result Row:强类型Query结果行
更多 >
目录
  • 前期准备
  • 普通测试
    • 示例:(Controller)
    • 示例:(Service、DAO)
    • 示例:(Service、DAO)参数化测试
  • 隔离测试
    • 常规用法
      • 示例:(Controller) -- 通过拦截器,测试Controller功能
      • 示例:(Controller) -- 直接绕过系统拦截器,测试Controller功能
      • 示例:(Service)
  • Maven运行指令
  • JUnit插件
领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档