专栏首页InvQ的专栏基于rest风格对Neo4j进行调用访问之———httpClient

基于rest风格对Neo4j进行调用访问之———httpClient

1.什么是rest风格

不知道戳这里

2.什么是Neo4j

简单来说是一个图形数据库,是一种NOSQL型的。具体摸我

3.httpclient 访问

参考官网链接摸我。 代码如下:

package neo4j.action;



import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;

import neo4j.config.RestTemplateConfiguration;
import org.apache.commons.codec.binary.Base64;
import org.apache.commons.httpclient.HttpClient;
import org.apache.http.auth.AuthScope;
import org.apache.http.auth.UsernamePasswordCredentials;
import org.apache.http.client.CredentialsProvider;
import org.apache.http.client.methods.CloseableHttpResponse;
import org.apache.http.client.methods.HttpGet;
import org.apache.http.client.methods.HttpPost;
import org.apache.http.entity.StringEntity;
import org.apache.http.impl.client.BasicCredentialsProvider;
import org.apache.http.impl.client.CloseableHttpClient;
import org.apache.http.impl.client.HttpClients;
import org.apache.http.params.HttpParams;
import org.apache.http.util.EntityUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.http.*;
import org.springframework.http.client.ClientHttpRequestFactory;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.client.RestTemplate;

import javax.annotation.Resource;
import java.io.IOException;
import java.io.UnsupportedEncodingException;
import java.nio.charset.Charset;
import java.util.*;


@RestController
@RequestMapping("/neo4j/data")
public class NeoController {
    private static final Logger log = LoggerFactory.getLogger(NeoController.class);

    @RequestMapping(value = "/getData", method = RequestMethod.POST)
    public String getHello() {
        //建立连接
        log.info("getData接口调用开始时间:"+new Date());// 接口调用开始时间
        String url = "http://localhost:7474/db/data/transaction/commit";
        CredentialsProvider credsProvider = new BasicCredentialsProvider();
        credsProvider.setCredentials( new AuthScope("ip or host", port),
                new UsernamePasswordCredentials("username", "password"));
        CloseableHttpClient httpClient = HttpClients.custom().setDefaultCredentialsProvider(credsProvider).build();

        //参数准备以及封装请求
        StringEntity s = new StringEntity("{\n" +
                "  \"statements\" : [ {\n" +
                "    \"statement\" : \"MATCH (n) RETURN n LIMIT 25\"\n" +
                "  } ]\n" +
                "}","UTF-8");
        s.setContentEncoding("UTF-8");
        s.setContentType("application/json");//发送json数据需要设置contentType


        HttpPost httppost = new HttpPost(url);
        httppost.setEntity(s);
        httppost.addHeader("Content-Type", "application/json");
        httppost.addHeader("charset", "UTF-8");
        CloseableHttpResponse response = null;

        //获取结果
        String respString = "";
        try {
            response = httpClient.execute(httppost);
             respString = EntityUtils.toString(response.getEntity());
            log.info(respString);
        } catch (IOException e) {
            e.printStackTrace();
        }finally {
            try {
                if (response != null) {
                    response.close();
                }
            } catch (IOException e) {
                e.printStackTrace();
            }
        }



        return respString;
    }
}

4,通过postman模拟点击结果返回

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

我来说两句

0 条评论
登录 后参与评论

相关文章

  • spring boot + mybatis 访问 neo4j

    之前有通过rest的风格去访问,但是每次需要访问时候将statement一并加入header中去数据库执行,方式简单、且思路清晰,但是不便于形成模板调用,固采用...

    MickyInvQ
  • springmvc 文件下载 VS resteasy 文件上传下载

    浏览器输入: http://localhost:8080/evaluate/downloadPathExportTemplate

    MickyInvQ
  • springBoot 入门(五)—— 使用 纯注解方式 的springboot+ mybatis+junit4 整合

    MickyInvQ
  • httpclient模拟post请求json封装表单数据

    以下代码包括最基本的GET、POST、JSON参数的POST方式的请求。(相当于POSTMAN中使用raw编写的参数)

    I Tech You_我教你
  • Java自动化测试(HttpClient 13)

    HttpClient 是Apache Jakarta Common 下的子项目,可以用来提供高效的、最新的、功能丰富的支持 HTTP 协议的客户端编程工具包,并...

    zx钟
  • Hadoop(十)Hadoop IO之数据完整性

    前言   上一篇我分享了Hadoop的压缩和编解码器,在我们开发的过程中其实是经常会用到的,所以一定要去掌握。这一篇给大家介绍的是Hadoop的数据完整性!  ...

    用户1195962
  • Hadoop(十)Hadoop IO之数据完整性

      上一篇我分享了Hadoop的压缩和编解码器,在我们开发的过程中其实是经常会用到的,所以一定要去掌握。这一篇给大家介绍的是Hadoop的数据完整性!

    大道七哥
  • HttpClient使用总结

    根据业务量级决定使用同步调用或异步调用:异步回调方式的并发性非常高,缺点是代码可读性一般,在开发中,我会首先选择同步实现,在遇到性能问题后再考虑优化为异步回调方...

    阿杜
  • 如何使用Pig集成分词器来统计新闻词频?

    我是攻城师
  • Cause: com.mysql.jdbc.exceptions.jdbc4.MySQLIntegrityConstraintViolationException

    所以删除最后那条自己刚刚添加的数据,因为这条数据没有和购物车表中数据有外键约束,所以删除并不会报错

扫码关注云+社区

领取腾讯云代金券