簡單使用MongDB-GEO

win安裝mongodb

MongDB版本 3.6.12下載地址

• 建立mongo.conf配置文件，內容以下

dbpath=D:\mongo\data
logpath=D:\mongo\log\mongo.log
logappend=true
journal=true
quiet=true
port=27017
複製代碼

• 啓動MongDb

D:\programs\mongodb-win32-x86_64-2008plus-ssl-3.6.12\bin>mongod.exe --config D:\mongo\config\mongo.conf
複製代碼

JPA添加數據和使用GEO索引查詢中心點附近數據

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-data-mongodb</artifactId>
</dependency>
<dependency>
    <groupId>org.mongodb</groupId>
    <artifactId>mongo-java-driver</artifactId>
    <version>3.4.3</version>
</dependency>
複製代碼

##mongo配置
spring:
 data:
 mongodb:
 host: 127.0.0.1
 port: 27017
 database: test
複製代碼

實體類

import lombok.Data;
import org.springframework.data.annotation.Id;
import org.springframework.data.mongodb.core.index.GeoSpatialIndexType;
import org.springframework.data.mongodb.core.index.GeoSpatialIndexed;
import org.springframework.data.mongodb.core.index.Indexed;
import org.springframework.data.mongodb.core.mapping.Document;

@Data
@Document(collection = "bikes")
public class Bike {
    @Id
    private String id;
    private int status;
    @Indexed
    private long bikeNo;
    // 空間球面索引
    @GeoSpatialIndexed(type = GeoSpatialIndexType.GEO_2DSPHERE)
    private double[] location;
}
複製代碼

import com.niubike.niubike.entity.Bike;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.geo.GeoResult;
import org.springframework.data.geo.GeoResults;
import org.springframework.data.geo.Metrics;
import org.springframework.data.mongodb.core.MongoTemplate;
import org.springframework.data.mongodb.core.query.Criteria;
import org.springframework.data.mongodb.core.query.NearQuery;
import org.springframework.data.mongodb.core.query.Query;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RestController;

import java.util.List;

@RestController
public class BikeController {

    @Autowired
    private MongoTemplate mongoTemplate;

    @PostMapping("/addBike")
    public String save(@RequestBody Bike bike) {
        bike.setBikeNo(System.currentTimeMillis());
        bike.setStatus(0);
        mongoTemplate.insert(bike);
        return "1";
    }

    /** * 根據當前經緯度查找附近單車 * @return */
    @PostMapping("/findNearBike")
    public List<GeoResult<Bike>> findNearBike(double longitude, double latitude) {
        NearQuery nearQuery = NearQuery
                .near(longitude, latitude)
                .maxDistance(0.2, Metrics.KILOMETERS)
                .query(new Query(Criteria.where("status").is(0)).limit(20));
        GeoResults<Bike> geoResults = mongoTemplate.geoNear(nearQuery, Bike.class);
        return geoResults.getContent();
    }
}
複製代碼

效果

查詢附近單車數據代碼對於高版本的MongoDB不適用。