集成我采用了目前比较流行的框架 Spring boot,方便简单快捷。
Spring boot采用了目前最新的1.4.2的版本。搭建步骤如下:
首先pom.xml配置:
设置打包类型:首选打包为war <packaging>war</packaging> 。
依赖说明:
<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>1.4.2.RELEASE</version>
</parent>
<properties>
<java.version>1.8</java.version>
</properties>
1.spring-boot-starter-parent
包含了大量配置好的依赖管理,1.4.2为boot的版本号。
2.Spring默认使用jdk1.6,如果你想使用jdk1.8,你需要在pom.xml
的属性里面添加java.version。
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-neo4j</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
<scope>test</scope>
</dependency>
1.通过spring-boot-starter-web 支持以 REST 方式暴露接口,该包集成了spring-mvc、spring-web、spring-boot-starter-tomcat,对外提供REST API。
2.开始还以为需要自己去建一个neo4j的配置文件加载配置,后面一看没想到他提供了集成neo4j的支持,方便了不少,只需添加spring-boot-starter-data-neo4j官方支持的neo4j依赖包。
3.添加单元测试依赖:spring-boot-starter-test。
完整配置如下:
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<groupId>kop-instance-data</groupId>
<artifactId>kop-instance-data</artifactId>
<version>1.0-SNAPSHOT</version>
<packaging>war</packaging>
<properties>
<java.version>1.8</java.version>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
<neo4j.version>3.0.1</neo4j.version>
</properties>
<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>1.4.2.RELEASE</version>
</parent>
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-rest</artifactId>
</dependency>
<dependency>
<groupId>com.voodoodyne.jackson.jsog</groupId>
<artifactId>jackson-jsog</artifactId>
<version>1.1</version>
<scope>compile</scope>
</dependency>
<!-- end::dependencies[] -->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-neo4j</artifactId>
</dependency>
<!-- Test Dependencies -->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
<scope>test</scope>
</dependency>
<dependency>
<groupId>com.google.code.gson</groupId>
<artifactId>gson</artifactId>
<version>2.3.1</version>
</dependency>
</dependencies>
<build>
<plugins>
<plugin>
<artifactId>maven-compiler-plugin</artifactId>
</plugin>
<plugin>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
<configuration>
<jvmArguments>-Dfile.encoding=UTF-8</jvmArguments>
</configuration>
<executions>
<execution>
<goals>
<goal>repackage</goal>
</goals>
</execution>
</executions>
</plugin>
</plugins>
</build>
<repositories>
<repository>
<id>spring-milestones</id>
<url>http://repo.spring.io/libs-snapshot</url>
<snapshots>
<enabled>true</enabled>
</snapshots>
</repository>
</repositories>
<pluginRepositories>
<pluginRepository>
<id>spring-milestones</id>
<url>http://repo.spring.io/libs-snapshot</url>
<snapshots>
<enabled>true</enabled>
</snapshots>
</pluginRepository>
</pluginRepositories>
</project>
pom.xml配置完成后 建一个包 在包里创建一个启动类:
@SpringBootApplication
public class ServerApplication extends SpringBootServletInitializer implements CommandLineRunner {
@Override
protected SpringApplicationBuilder configure(SpringApplicationBuilder application) {
return application.sources(ServerApplication.class);
}
public static void main(String[] args) throws IOException {
SpringApplication.run(ServerApplication.class, args);
}
@Override
public void run(String... strings) throws Exception {
System.out.println("初始化。。。。。。。。。。。。");
}
}
集成 SpringBootServletInitializer 作用在于使用将程序达成war包在 tomcat启动应用,实现 CommandLineRunner 作用在于服务启动后 需要做一些初始化的事情。
@SpringBootApplication 该注解可以替代 @Configuration,@EnableAutoConfiguration,@ComponentScan三个注解 简化配置。
** 需要注意的是:
ServerApplication类一定要放包在最外层(最外层的意思是放在其他有需要注入的类的包的外层),因为spring boot默认的扫描注解是平级开始从上而下的方式,如果放在里面,会导致其他类不能正常注入。**
resources目录下建立默认的配置文件application.properties 添加属性
server.port=8080 tomcat启动后的端口号
spring.data.neo4j.username=neo4j 数据库账号
spring.data.neo4j.password=neo4j 数据库密码
spring.data.neo4j.uri=http://localhost:7474 数据库uri地址
数据库安装文件直接到官网下载安装即可
官方下载地址:https://neo4j.com/
该默认文件的其他更多配置 可参数该博主的文章:http://blog.csdn.net/yuchao2015/article/details/52588407
写好配置文件后 基础配置就算差不多完成了,下面编写测试(注释:我所建的测试类 全部都在ServerApplication类所在包的下面):
domain类:
@NodeEntity
public class Task {
@GraphId
private Long id;
private String taskName;
public Long getId() {
return id;
}
public void setId(Long id) {
this.id = id;
}
public String getTaskName() {
return taskName;
}
public void setTaskName(String taskName) {
this.taskName = taskName;
}
}
repositories类:
@Repository
public interface TaskRepository extends GraphRepository<Task> {
Task findByTaskName(@Param("taskName") String taskName);
@Query("MATCH (t:Task) WHERE t.taskName =~ ('(?i).*'+{taskName}+'.*') RETURN t")
Collection<Task> findByNameContaining(@Param("taskName") String taskName);
}
TaskRepository 继承GraphRepository类,实现增删查改,实现自己两个接口,第一个接口通过名字查询任务,spring data neo4j 支持方法命名约定查询 findBy{task的属性名},类似于jpa的方式,findBy后面的属性名一定要domain类里存在,否则会报错。
Controller类:
@RestController
@RequestMapping("/task")
public class TaskController {
@Autowired
TaskRepository taskRepository;
@RequestMapping(value = "", method = RequestMethod.POST, consumes = "application/json")
@Transactional
public Task saveTask(@RequestBody Task taskInfo) {
Task task = taskRepository.save(taskInfo);
return task;
}
@RequestMapping(value = "/{name}", method = RequestMethod.GET)
public Task create(@PathVariable String name) {
Task task = taskRepository.findByTaskName(name);
return task;
}
}
返回task的时候 不会返回id和空值属性,如果需要返回完整信息,需要自己建一个dto,包装一下再返回 。
单元测试方法:
@RunWith(SpringRunner.class)
@SpringBootTest(classes = ServerApplication.class, webEnvironment = SpringBootTest.WebEnvironment.RANDOM_PORT)
public class TaskTest {
@LocalServerPort
private int port;
private URL base;
private Gson gson = new Gson();
@Autowired
private TestRestTemplate restTemplate;
@Before
public void setUp() throws Exception {
this.base = new URL("http://localhost:" + port + "/");
}
@Test
public void findByTaskName() {
ResponseEntity<Task> test = this.restTemplate.getForEntity(
this.base.toString() + "/测试任务", Task.class);
System.out.println(gson.toJson(test.getBody()));
}
@Test
public void saveTask() {
Task task = new Task();
task.setTaskName("测试任务");
ResponseEntity<Task> test = this.restTemplate.postForEntity(
this.base.toString() + "/task",task, Task.class);
System.out.println(gson.toJson(test.getBody()));
}
}
一切准备就绪 开始测试吧! 先运行saveTask 增加一个task节点,然后查看数据库
数据已存在于数据库,大功告成。