springboot集成es

springboot集成es

Springboot集成es

1、引入依赖

<!--elasticsearch-->
<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-data-elasticsearch</artifactId>
</dependency>

2、增加es服务配置

# es服务地址
elasticsearch:host: 127.0.0.1# es服务端口port: 9350

3、实体

@Data
@ToString
@NoArgsConstructor
@AllArgsConstructor
@Document(indexName = "device_log")
@Setting(shards = 3)
@Builder
public class DeviceLog implements Serializable {@Idprivate String id;/*** 设备ID*/@Field(type = FieldType.Keyword)private String devId;/*** 设备名称*/@MultiField(mainField = @Field(type = FieldType.Text),otherFields = {@InnerField(suffix = "keyword", type = FieldType.Keyword)})private String deviceName;/*** 设备sn码*/@Field(type = FieldType.Keyword)private String deviceSn;/*** 设备所属产品名称*/@MultiField(mainField = @Field(type = FieldType.Text),otherFields = {@InnerField(suffix = "keyword", type = FieldType.Keyword)})private String productName;/*** 设备所属产品ID*/@Field(type = FieldType.Keyword)private String productUuid;/*** 产品功能点ID的标识符   如 功能点id为101的标识符为event*/@Field(type = FieldType.Keyword)private String deviceDpId;/*** 日志等级定义:* 提示-TIPS* 次要-SECONDARY* 重要-IMPORTANT* 紧急-URGENT*/@MultiField(mainField = @Field(type = FieldType.Text),otherFields = {@InnerField(suffix = "keyword", type = FieldType.Keyword)})private String logLevel;/*** 日志事件类型定义：* 设备上线-DEVICE_ONLINE* 设备下线-DEVICE_OFFLINE* 数据上报-DEVICE_DATA_REPORT* 事件上报-DEVICE_EVENT_REPORT* 设备重置-DEVICE_RESET* 设备激活-DEVICE_ACTIVATION* 固件升级-DEVICE_FIRMWARE_UPGRADE* 设备重启-DEVICE_RESTART_UPGRADE* 设备心跳-DEVICE_HEARTBEAT**/@MultiField(mainField = @Field(type = FieldType.Text),otherFields = {@InnerField(suffix = "keyword", type = FieldType.Keyword)})private String eventType;/*** 事件名称*/@MultiField(mainField = @Field(type = FieldType.Text),otherFields = {@InnerField(suffix = "keyword", type = FieldType.Keyword)})private String eventName;/*** 事件详情*/@MultiField(mainField = @Field(type = FieldType.Text),otherFields = {@InnerField(suffix = "keyword", type = FieldType.Keyword)})private String eventDetail;/***  来源*/@MultiField(mainField = @Field(type = FieldType.Text),otherFields = {@InnerField(suffix = "keyword", type = FieldType.Keyword)})private String source;/*** 来源详情*/@MultiField(mainField = @Field(type = FieldType.Text),otherFields = {@InnerField(suffix = "keyword", type = FieldType.Keyword)})private String sourceDetail;/*** 记录时间*/@Field(type = FieldType.Date)private Date recordTime;/*** 记录时间戳  9位（精确到秒）*/@Field(type = FieldType.Long)private Long recordTimestamp;

4、实现service
service:

public interface DeviceLogService {/*** 保存日志* @param deviceLog 日志信息*/void saveDeviceLog(DeviceLog deviceLog);/*** 保存日志与转换时间戳* @param deviceLog*/void saveDeviceLogAndChangeDateType(DeviceLog deviceLog);/*** 通用设备日志查询* @return 日志信息*/SearchHits<DeviceLog> commonDeviceLogQuery(DeviceLogQueryDTO deviceLogQueryDTO);
}

实现类：

@Service
@Slf4j
public class DeviceLogServiceImpl  implements DeviceLogService {@Autowiredprivate DeviceLogRepository deviceLogRepository;@Autowiredprivate ElasticsearchOperations elasticsearchOperations;@Overridepublic void saveDeviceLog(DeviceLog deviceLog) {log.info("deviceLog::"&#String());deviceLogRepository.save(deviceLog);}@Overridepublic void saveDeviceLogAndChangeDateType(DeviceLog deviceLog) {if (RecordTimestamp() == null){deviceLog.setRecordTimestamp(System.currentTimeMillis()/1000);}deviceLog.setRecordTime(new RecordTimestamp()*1000));deviceLogRepository.save(deviceLog);}@Overridepublic SearchHits<DeviceLog> commonDeviceLogQuery(DeviceLogQueryDTO deviceLogQueryDTO) {NativeSearchQueryBuilder nativeSearchQueryBuilder = new NativeSearchQueryBuilder();BoolQueryBuilder boolQueryBuilder = QueryBuilders.boolQuery();checkParamAndDataInput(deviceLogQueryDTO, boolQueryBuilder,nativeSearchQueryBuilder);Query query = nativeSearchQueryBuilder.withSorts(SortBuilders.FieldName(DeviceLog::getRecordTime)).order(SortOrder.DESC)).build();SearchHits<DeviceLog> deviceLogPage = elasticsearchOperations.search(query, DeviceLog.class);return deviceLogPage;}/*** 检查请求参数与填充查询条件数据*/private void checkParamAndDataInput(DeviceLogQueryDTO deviceLogQueryDTO, BoolQueryBuilder boolQueryBuilder, NativeSearchQueryBuilder nativeSearchQueryBuilder){if (StringUtils.DevId())){nativeSearchQueryBuilder.withFilter(boolQueryBuilder.FieldName(DeviceLog::getDevId),DevId())));}if (StringUtils.DeviceDpId())){nativeSearchQueryBuilder.withFilter(boolQueryBuilder.FieldName(DeviceLog::getDeviceDpId),DeviceDpId())));}if (StringUtils.DeviceName())){nativeSearchQueryBuilder.withFilter(boolQueryBuilder.FieldName(DeviceLog::getDeviceName)+ Constants.CHINESE_QUERY_KEYWORD_DeviceName())));}if (StringUtils.DeviceSn())){nativeSearchQueryBuilder.withFilter(boolQueryBuilder.FieldName(DeviceLog::getDeviceSn),DeviceSn())));}if (StringUtils.ProductName())){nativeSearchQueryBuilder.withFilter(boolQueryBuilder.FieldName(DeviceLog::getProductName)+ Constants.CHINESE_QUERY_KEYWORD_ProductName())));}if (StringUtils.ProductUuid())){nativeSearchQueryBuilder.withFilter(boolQueryBuilder.FieldName(DeviceLog::getProductUuid),ProductUuid())));}if (StringUtils.LogLevel())){String desc = LogLevel(), CommonLogEnum.TIPS_Classification());if (desc != null){nativeSearchQueryBuilder.withFilter(boolQueryBuilder.FieldName(DeviceLog::getLogLevel)+ Constants.CHINESE_QUERY_KEYWORD_SUFFIX,desc)));}}if (StringUtils.EventType())){String desc = EventType(), CommonLogEnum.DEVICE_ONLINE_Classification());if (desc != null){nativeSearchQueryBuilder.withFilter(boolQueryBuilder.FieldName(DeviceLog::getEventType)+ Constants.CHINESE_QUERY_KEYWORD_SUFFIX,desc)));}}if (StringUtils.EventName())){nativeSearchQueryBuilder.withFilter(boolQueryBuilder.FieldName(DeviceLog::getEventName)+ Constants.CHINESE_QUERY_KEYWORD_EventName())));}if (StringUtils.EventDetail())){nativeSearchQueryBuilder.withFilter(boolQueryBuilder.FieldName(DeviceLog::getEventDetail)+ Constants.CHINESE_QUERY_KEYWORD_EventDetail())));}if (StringUtils.Source())){String desc = Source(), CommonLogEnum.DEVICE_Classification());if (desc != null){nativeSearchQueryBuilder.withFilter(boolQueryBuilder.FieldName(DeviceLog::getSource)+ Constants.CHINESE_QUERY_KEYWORD_SUFFIX,desc)));}}if (StringUtils.SourceDetail())){nativeSearchQueryBuilder.withFilter(boolQueryBuilder.FieldName(DeviceLog::getSourceDetail),SourceDetail())));}if (StartTime() != null && EndTime() != null){nativeSearchQueryBuilder.withFilter(boolQueryBuilder.must(QueryBuilders.FieldName(DeviceLog::getRecordTimestamp)).StartTime()).EndTime())));}if (PageFlag()!=null && PageFlag().equals(true)){if (PageNum() != null && PageSize() !=null ){nativeSearchQueryBuilder.withPageable(PageRequest.PageNum().intValue(), PageSize().intValue()));}}}
}