[go: up one dir, main page]

CN106162688B - A pseudo base station positioning method and system - Google Patents

A pseudo base station positioning method and system Download PDF

Info

Publication number
CN106162688B
CN106162688B CN201510151799.9A CN201510151799A CN106162688B CN 106162688 B CN106162688 B CN 106162688B CN 201510151799 A CN201510151799 A CN 201510151799A CN 106162688 B CN106162688 B CN 106162688B
Authority
CN
China
Prior art keywords
base station
pseudo
signaling data
platform
data
Prior art date
Legal status (The legal status is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the status listed.)
Active
Application number
CN201510151799.9A
Other languages
Chinese (zh)
Other versions
CN106162688A (en
Inventor
郭慈
樊炼
薛超
王卉
Current Assignee (The listed assignees may be inaccurate. Google has not performed a legal analysis and makes no representation or warranty as to the accuracy of the list.)
China Mobile Group Hubei Co Ltd
Original Assignee
China Mobile Group Hubei Co Ltd
Priority date (The priority date is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the date listed.)
Filing date
Publication date
Application filed by China Mobile Group Hubei Co Ltd filed Critical China Mobile Group Hubei Co Ltd
Priority to CN201510151799.9A priority Critical patent/CN106162688B/en
Publication of CN106162688A publication Critical patent/CN106162688A/en
Application granted granted Critical
Publication of CN106162688B publication Critical patent/CN106162688B/en
Active legal-status Critical Current
Anticipated expiration legal-status Critical

Links

Landscapes

  • Mobile Radio Communication Systems (AREA)

Abstract

本发明公开了一种伪基站定位方法,所述方法包括:按照指定时间切片获取信令数据;基于规则模型库对所述信令数据进行分布式处理;当分布式处理结果满足预设条件时,进行告警,并将分布式处理结果录入数据分析平台;所述数据分析平台根据所述分布式处理结果,并结合信令数据,进行多维度数据分析以统计伪基站出现规律;根据多维度数据分析结果,调节所述规则模型库的参数,以反向完善所述规则模型库。本发明还同时公开了一种伪基站定位系统。采用本发明技术方案,能准确实时的告警伪基站的相关信息。

The invention discloses a method for locating a pseudo-base station. The method includes: acquiring signaling data according to a specified time slice; performing distributed processing on the signaling data based on a rule model library; when the distributed processing results meet preset conditions , give an alarm, and enter the distributed processing results into the data analysis platform; the data analysis platform performs multi-dimensional data analysis based on the distributed processing results and in combination with signaling data to count the occurrence rules of pseudo base stations; according to the multi-dimensional data Analyzing the results, adjusting the parameters of the rule model library to reversely improve the rule model library. The invention also discloses a pseudo base station positioning system at the same time. By adopting the technical scheme of the invention, the related information of the false base station can be accurately and real-time alarmed.

Description

一种伪基站定位方法及系统A pseudo base station positioning method and system

技术领域technical field

本发明涉及通讯领域,尤其涉及一种伪基站定位方法及系统。The present invention relates to the communication field, in particular to a pseudo base station positioning method and system.

背景技术Background technique

近年来,伪基站事件频发,一些不法份子通过高科技仪器(如主机和笔记本电脑)构建短信群发器、短信发信机等平台,搜取以其为中心,一定半径范围内的手机卡信息。通过伪装成运营商的基站,冒用他人手机号码强行向用户手机发送诈骗、广告推销等短信息。伪基站的工作原理主要有以下两种:In recent years, incidents of false base stations have occurred frequently. Some criminals have used high-tech equipment (such as hosts and laptops) to build platforms such as SMS group senders and SMS senders to search for mobile phone card information within a certain radius around them. . By disguising as the operator's base station, fraudulently using other people's mobile phone numbers to forcibly send short messages such as fraud and advertising to the user's mobile phone. There are two main working principles of the pseudo base station:

1)传统型伪基站,功能上只能得到用户的国际移动用户识别码(IMSI,International Mobile Subscriber Identification Number),流程一般为:“伪基站小区重选->向伪基站发起位置更新->伪基站位置更新拒绝->手机重新进行现网小区重选->再次位置更新成功”,此过程至少需要3秒以上。1) The traditional pseudo-base station can only obtain the user's International Mobile Subscriber Identification Number (IMSI, International Mobile Subscriber Identification Number) functionally. The base station location update is rejected -> the mobile phone re-selects the live network cell -> the location update is successful again", this process takes at least 3 seconds.

2)新型伪基站,功能上能让用户驻留伪小区,下发短信,控制用户进出。流程一般为:“伪基站小区重选->向伪基站发起位置更新->伪基站位置更新接受->伪基站下发短信->伪基站变换位置区码(LAC,Location Area Code)->伪基站小区重选->向伪基站发起位置更新->伪基站位置更新拒绝->手机重新进行现网小区选择->再次位置更新成功”,此过程至少需要25秒以上。2) A new type of pseudo base station, functionally allowing users to stay in a pseudo cell, send short messages, and control user access. The process is generally: "Pseudo base station cell reselection -> initiate location update to pseudo base station -> pseudo base station location update acceptance -> pseudo base station send SMS -> pseudo base station change Location Area Code (LAC, Location Area Code) -> pseudo base station Base station cell reselection -> initiate location update to fake base station -> fake base station location update rejection -> mobile phone re-select live network cell -> location update is successful again", this process takes at least 25 seconds.

由于伪基站具有流动性、偶发性特征,并且基站同时入网的用户数据量巨大,传统的技术手段无法做到对伪基站的实时侦测、处置。最新型的伪基站具有成本低、功能强大、便携、低能耗等特点,使得伪基站流动性大大增强。一般是用户投诉的信息刚到不久,伪基站已经变换作案地点,传统的依赖客户投诉信息进行分析排查的手段,如告警和性能计数器,都是基于网元设备角度反映网络运行状况,无法反映每一个呼叫或事件的具体细节,即无法反映基于用户粒度的网络情况,特别在排查伪基站事件这种基于信令内容筛选统计会显得束手无策或流程繁琐。然而,现有的分析排查手段已经无法及时准确的提供有效可靠的伪基站信息给公安部门,刑侦抓捕工作变的异常艰难。Due to the fluidity and sporadic characteristics of pseudo base stations, and the huge amount of user data that the base stations simultaneously access to the network, traditional technical means cannot achieve real-time detection and disposal of pseudo base stations. The latest pseudo base station has the characteristics of low cost, powerful function, portability, and low energy consumption, which greatly enhances the mobility of the pseudo base station. Generally, the information about user complaints has just arrived, and the pseudo-base station has changed the location of the crime. The traditional means of analyzing and troubleshooting relying on customer complaint information, such as alarms and performance counters, are based on the perspective of network element equipment to reflect the network operating status, which cannot reflect the status of each network element. The specific details of a call or event cannot reflect the network situation based on user granularity, especially when troubleshooting fake base station events based on signaling content screening statistics, it will be helpless or the process is cumbersome. However, the existing analysis and investigation methods have been unable to provide effective and reliable fake base station information to the public security department in a timely and accurate manner, and the work of criminal investigation and arrest has become extremely difficult.

因而,如何准确实时的告警伪基站的相关信息成为亟待解决的问题。Therefore, how to accurately and real-time alert the related information of the pseudo base station becomes an urgent problem to be solved.

发明内容Contents of the invention

有鉴于此,本发明实施例期望提供一种伪基站定位方法及系统,能准确实时的告警伪基站的相关信息。In view of this, the embodiments of the present invention expect to provide a method and system for locating a pseudo base station, which can accurately and real-time alert related information of the pseudo base station.

为达到上述目的,本发明实施例的技术方案是这样实现的:In order to achieve the above object, the technical solution of the embodiment of the present invention is achieved in this way:

本发明实施例提供了一种伪基站定位方法,所述方法包括:An embodiment of the present invention provides a method for locating a pseudo base station, the method comprising:

按照指定时间切片获取信令数据;Obtain signaling data according to the specified time slice;

基于规则模型库对所述信令数据进行分布式处理;performing distributed processing on the signaling data based on a rule model library;

当分布式处理结果满足预设条件时,进行告警,并将分布式处理结果录入数据分析平台。When the distributed processing results meet the preset conditions, an alarm will be issued, and the distributed processing results will be entered into the data analysis platform.

优选地,所述将分布式处理结果录入数据分析平台之后,还包括:Preferably, after the distributed processing results are entered into the data analysis platform, it also includes:

所述数据分析平台根据所述分布式处理结果,并结合信令数据,进行多维度数据分析以统计伪基站出现规律;The data analysis platform performs multi-dimensional data analysis based on the distributed processing results and in combination with signaling data to count the occurrence rules of pseudo base stations;

根据多维度数据分析结果,调节所述规则模型库的参数,以反向完善所述规则模型库。According to the multi-dimensional data analysis result, the parameters of the rule model library are adjusted to reversely improve the rule model library.

优选地,所述基于规则模型库对所述信令数据进行分布式处理,包括:Preferably, the rule-based model library performs distributed processing on the signaling data, including:

将每个时间切片的信令数据都转换成弹性分布式数据集RDD;Convert the signaling data of each time slice into an elastic distributed dataset RDD;

基于规则模型库对预设时间内的信令数据流进行批处理分析。Batch analysis of signaling data flow within a preset time based on the rule model library.

优选地,所述进行多维度数据分析,至少包括:Preferably, the multidimensional data analysis includes at least:

基于用户、事件、时间、空间进行多维度分析,生成基于全网的伪基站干扰准实时热力图;Based on multi-dimensional analysis of users, events, time, and space, a pseudo-base station interference quasi-real-time heat map based on the entire network is generated;

按时间帧播放所述伪基站干扰热力图,根据流窜型伪基站可疑区域和轨迹,预测所述流窜型伪基站的下一活动地点。The interference heat map of the pseudo-base station is played in time frames, and the next activity location of the pseudo-base station is predicted according to the suspicious area and trajectory of the pseudo-base station.

优选地,所述按照指定时间切片获取信令数据之前,所述方法还包括:Preferably, before the acquisition of signaling data according to a specified time slice, the method further includes:

分布式消息队列平台实时接收信令数据;The distributed message queue platform receives signaling data in real time;

将所述信令数据被按照自定义的方式存储于集群的各个节点;storing the signaling data in each node of the cluster in a custom manner;

其中,所述自定义的方式为:将所述信令数据分成N类,其中N为正整数。Wherein, the manner of self-definition is: dividing the signaling data into N categories, where N is a positive integer.

优选地,所述分布式消息队列平台实时接收信令数据之前,所述方法还包括:Preferably, before the distributed message queue platform receives signaling data in real time, the method also includes:

在集群上搭建Zookeeper,以使所述分布式消息队列平台基于Zoopkeeper均衡负载。Build Zookeeper on the cluster, so that the distributed message queue platform is based on Zookeeper to balance the load.

本发明实施例还提供了一种伪基站定位系统,所述系统包括分布式消息队列平台、流处理平台和数据分析平台;其中,The embodiment of the present invention also provides a pseudo base station positioning system, the system includes a distributed message queue platform, a stream processing platform and a data analysis platform; wherein,

所述分布式消息队列平台,用于实时接收信令数据;将所述信令数据被按照自定义的方式存储于集群的各个节点;其中,所述自定义的方式为:将所述信令数据分成N类,其中N为正整数:The distributed message queue platform is used to receive signaling data in real time; the signaling data is stored in each node of the cluster in a customized manner; wherein, the customized manner is: the signaling The data is divided into N categories, where N is a positive integer:

所述流处理平台,用于按照指定时间切片获取信令数据;基于规则模型库对所述信令数据进行分布式处理;当分布式处理结果满足预设条件时,进行告警,并将分布式处理结果录入数据分析平台;The stream processing platform is used to obtain signaling data according to a specified time slice; perform distributed processing on the signaling data based on a rule model library; when the distributed processing results meet preset conditions, an alarm is issued, and the distributed The processing results are entered into the data analysis platform;

所述数据分析平台,用于根据所述分布式处理结果,并结合信令数据,进行多维度数据分析以统计伪基站出现规律;根据多维度数据分析结果,调节所述规则模型库的参数,以反向完善所述规则模型库。The data analysis platform is used to perform multi-dimensional data analysis based on the distributed processing results and in combination with signaling data to count the occurrence rules of pseudo base stations; adjust the parameters of the rule model library according to the multi-dimensional data analysis results, To inversely perfect the rule model library.

优选地,所述流处理平台,还用于:Preferably, the stream processing platform is also used for:

将每个时间切片的信令数据都转换成RDD;Convert the signaling data of each time slice into RDD;

基于规则模型库对预设时间内的信令数据流进行批处理分析。Batch analysis of signaling data flow within a preset time based on the rule model library.

优选地,所述数据分析平台,还用于:Preferably, the data analysis platform is also used for:

基于用户、事件、时间、空间进行多维度分析,生成基于全网的伪基站干扰准实时热力图;Based on multi-dimensional analysis of users, events, time, and space, a pseudo-base station interference quasi-real-time heat map based on the entire network is generated;

按时间帧播放所述伪基站干扰热力图,根据流窜型伪基站可疑区域和轨迹,预测所述流窜型伪基站的下一活动地点。The interference heat map of the pseudo-base station is played in time frames, and the next activity location of the pseudo-base station is predicted according to the suspicious area and trajectory of the pseudo-base station.

优选地,所述分布式消息队列平台,还用于:Preferably, the distributed message queue platform is also used for:

在集群上搭建Zookeeper,以使所述分布式消息队列平台基于Zoopkeeper均衡负载。Build Zookeeper on the cluster, so that the distributed message queue platform is based on Zookeeper to balance the load.

本发明实施例所提供的基于Spark Streaming流技术的伪基站定位方法及系统,按照指定时间切片获取信令数据;基于规则模型库对所述信令数据进行分布式处理;当分布式处理结果满足预设条件时,进行告警,并将分布式处理结果录入数据分析平台;所述数据分析平台根据所述分布式处理结果,并结合信令数据,进行多维度数据分析以统计伪基站出现规律;根据多维度数据分析结果,调节所述规则模型库的参数,以反向完善所述规则模型库。如此,能准确实时的告警伪基站的相关信息,提高侦测伪基站的准确性。The pseudo base station positioning method and system based on the Spark Streaming flow technology provided by the embodiment of the present invention obtains signaling data according to a specified time slice; performs distributed processing on the signaling data based on a rule model library; when the distributed processing results satisfy When pre-set conditions, an alarm is issued, and the distributed processing results are entered into the data analysis platform; the data analysis platform performs multi-dimensional data analysis based on the distributed processing results and in combination with signaling data to count the appearance of pseudo base stations; According to the multi-dimensional data analysis result, the parameters of the rule model library are adjusted to reversely improve the rule model library. In this way, the relevant information of the false base station can be alerted accurately and in real time, and the accuracy of detecting the false base station can be improved.

附图说明Description of drawings

图1为本发明实施例提供的伪基站定位方法的实现流程图一;FIG. 1 is a first implementation flowchart of a pseudo base station positioning method provided by an embodiment of the present invention;

图2为本发明实施例提供的伪基站定位方法的实现流程图二;Fig. 2 is the implementation flow chart 2 of the pseudo base station positioning method provided by the embodiment of the present invention;

图3为本发明实施例提供的伪基站定位方法的实现流程图三;FIG. 3 is a third implementation flowchart of the pseudo base station positioning method provided by the embodiment of the present invention;

图4为本发明实施例提供的伪基站定位系统的组成结构示意图。FIG. 4 is a schematic diagram of the composition and structure of the pseudo base station positioning system provided by the embodiment of the present invention.

具体实施方式Detailed ways

本发明提出了一种基于Spark Streaming流技术的伪基站定位方法及系统。为了更好地理解本发明,首先介绍一下Spark Streaming流技术。The present invention proposes a pseudo-base station positioning method and system based on Spark Streaming technology. In order to better understand the present invention, first introduce the Spark Streaming flow technology.

Spark Streaming是建立在Spark上的实时计算框架,Spark Streaming的优势在于:能运行在100+的结点上,并达到秒级延迟。Spark Streaming is a real-time computing framework based on Spark. The advantage of Spark Streaming is that it can run on 100+ nodes and achieve second-level delay.

Spark streaming的工作流程如下:接收到实时数据后,给数据分批次,然后传给Spark Engine处理,最后生成该批次的结果。The workflow of Spark streaming is as follows: After receiving real-time data, divide the data into batches, then send them to Spark Engine for processing, and finally generate the results of the batch.

Spark Streaming的基本原理是:将输入数据流以时间片(秒级)为单位进行拆分,然后以类似批处理的方式处理每个时间片数据。Spark Streaming是将流式计算分解成一系列短小的批处理作业。Spark Streaming把实时输入数据流以时间片Δt(如1秒)为单位切分成块;Spark Streaming会把每块数据作为一个弹性分布式数据集(RDD,ResilientDistributed Datasets),并使用RDD操作处理每一小块数据;每个块都会生成一个SparkJob处理,最终结果也返回多块。The basic principle of Spark Streaming is to split the input data stream into time slices (second level), and then process each time slice data in a batch-like manner. Spark Streaming decomposes streaming computing into a series of short batch jobs. Spark Streaming divides the real-time input data stream into blocks in units of time slice Δt (such as 1 second); Spark Streaming regards each piece of data as a resilient distributed dataset (RDD, Resilient Distributed Datasets), and uses RDD operations to process each Small chunks of data; each chunk will generate a SparkJob for processing, and the final result will also return multiple chunks.

下面结合附图和具体实施例对本发明的技术方案进一步详细阐述。The technical solutions of the present invention will be further elaborated below in conjunction with the accompanying drawings and specific embodiments.

图1为本发明实施例提供的伪基站定位方法的实现流程图一,如图1所示,所述方法主要包括以下步骤:Fig. 1 is the implementation flow chart 1 of the pseudo base station positioning method provided by the embodiment of the present invention. As shown in Fig. 1, the method mainly includes the following steps:

步骤101:按照指定时间切片获取信令数据。Step 101: Obtain signaling data according to a specified time slice.

这里,所述时间切片的长度Δt的值可根据实际情况进行设定,例如,所述Δt的值可以是500毫秒。Here, the value of the length Δt of the time slice may be set according to actual conditions, for example, the value of Δt may be 500 milliseconds.

优选地,所述按照指定时间切片获取信令数据之前,所述方法还包括:Preferably, before the acquisition of signaling data according to a specified time slice, the method further includes:

分布式消息队列平台实时接收信令数据;The distributed message queue platform receives signaling data in real time;

将所述信令数据被按照自定义的方式存储于集群的各个节点。The signaling data is stored in each node of the cluster in a custom manner.

其中,所述自定义的方式为:将所述信令数据分成N类,其中N为正整数。Wherein, the manner of self-definition is: dividing the signaling data into N categories, where N is a positive integer.

具体地,将信令数据分类成为若干个话题,如入网用户信息、入网基站来源、入网用户位置、用户事件类型(如主叫、紧急呼叫、被叫、视频主叫、视频被叫、发短信、收短信、切入、切出、BSC内切换、正常位置更新、周期性位置更新、IMSI附着、IMSI分离、寻呼、补充业务、短信状态报告、业务重建、手机状态报告)。Specifically, the signaling data is classified into several topics, such as network access user information, network access base station source, network access user location, user event type (such as calling, emergency call, called, video calling, video called, sending text messages) , receiving SMS, switching in, switching out, intra-BSC switching, normal location update, periodic location update, IMSI attach, IMSI detach, paging, supplementary service, SMS status report, service reestablishment, mobile phone status report).

上述BSC是Base Station Controller的简称,其中文名称为基站控制器。The above-mentioned BSC is the abbreviation of Base Station Controller, and its Chinese name is Base Station Controller.

步骤102:基于规则模型库对所述信令数据进行分布式处理。Step 102: Perform distributed processing on the signaling data based on a rule model library.

优选地,所述基于规则模型库对所述信令数据进行分布式处理,可以包括:Preferably, the distributed processing of the signaling data by the rule-based model library may include:

将每个时间切片的信令数据都转换成弹性分布式数据集(RDD,ResilientDistributed Datasets);Convert the signaling data of each time slice into Resilient Distributed Datasets (RDD, Resilient Distributed Datasets);

基于规则模型库对预设时间内的信令数据流进行批处理分析。Batch analysis of signaling data flow within a preset time based on the rule model library.

这里,所述规则模型库可以包括:Here, the rule model library may include:

1)被伪基站位置更新拒绝(由于原因12、13)时,移动终端会删除伪基站的位置区识别码(LAI,Location Area Identity)和临时识别码(TMSI,Temporary MobileSubscriber Identity),然后在现网以65534或0的LAI和IMSI在现网进行位置更新;1) When being rejected by the pseudo base station location update (due to reasons 12 and 13), the mobile terminal will delete the location area identification code (LAI, Location Area Identity) and temporary identification code (TMSI, Temporary Mobile Subscriber Identity) of the pseudo base station, and then The network performs location update on the live network with the LAI and IMSI of 65534 or 0;

2)被伪基站位置更新拒绝(由于原因15)时,移动终端会使用伪基站分配的LAI和TMSI在现网进行位置更新。2) When the location update of the pseudo base station is rejected (because of reason 15), the mobile terminal will use the LAI and TMSI assigned by the pseudo base station to perform location update on the live network.

3)移动终端伪基站信号变弱或消失,然后移动终端重新搜索频点入现网,再次位置更新时携带更新前的一个LAI和TMSI(伪基站分配)。3) The signal of the pseudo base station of the mobile terminal becomes weak or disappears, and then the mobile terminal re-searches the frequency point to enter the live network, and carries a LAI and TMSI before the update (pseudo base station allocation) when the location is updated again.

上述原因12、原因13、原因15均为通信系统中伪基站的位置更新拒绝原因,具体的,原因12是指“Location Area not allowed”,中文意思是指“位置区域不允许”;原因13是指“Roaming not allowed in this location area”,中文意思是指“本地区内不允许漫游”;原因15是指“No Suitable Cells In Location Area”中文意思是指“在位置区没有合适的小区”。The above-mentioned reasons 12, 13, and 15 are all reasons for rejecting location update of pseudo base stations in the communication system. Specifically, reason 12 refers to "Location Area not allowed", which means "location area not allowed" in Chinese; reason 13 is Refers to "Roaming not allowed in this location area", which means "roaming is not allowed in this area" in Chinese; reason 15 refers to "No Suitable Cells In Location Area" in Chinese, which means "there are no suitable cells in the location area".

当然,伪基站的位置更新拒绝原因还有很多,在此不再赘述。Of course, there are many reasons for the location update rejection of the pseudo base station, which will not be repeated here.

基于规则模型库对所述信令数据进行分布式处理,具体可以包括:Distributed processing of the signaling data based on a rule model library may specifically include:

步骤103:当分布式处理结果满足预设条件时,进行告警,并将分布式处理结果录入数据分析平台。Step 103: When the distributed processing result meets the preset condition, an alarm is issued, and the distributed processing result is entered into the data analysis platform.

具体地,可通过设定相关的告警门限值,当分布式处理结果满足相应的告警门限值时,即可触发进行告警。Specifically, by setting a relevant alarm threshold value, when the distributed processing result meets the corresponding alarm threshold value, an alarm can be triggered.

上述步骤101、102、103的执行主体均可为流处理平台。The execution subject of the above-mentioned steps 101, 102, and 103 can be a stream processing platform.

优选地,所述流处理平台是基于Spark Streaming流技术的处理平台。Preferably, the stream processing platform is a processing platform based on Spark Streaming flow technology.

优选地,所述分布式消息队列平台实时接收信令数据之前,所述方法还可以包括:Preferably, before the distributed message queue platform receives signaling data in real time, the method may also include:

在集群上搭建Zookeeper,以使所述分布式消息队列平台基于Zoopkeeper均衡负载。Build Zookeeper on the cluster, so that the distributed message queue platform is based on Zookeeper to balance the load.

具体地,以使所述分布式消息队列平台基于Zoopkeeper均衡基站与流处理平台之间的负载。Specifically, the distributed message queue platform balances the load between the base station and the stream processing platform based on Zoopkeeper.

本实施例中所述伪基站定位方法,将用户位置事件数据和Spark Streaming流处理技术结合,先从海量数据中筛选伪基站出现的关键信息,然后基于用户、事件、时间、空间进行多维分析,实现能像天气云图一样准实时的显示和告警伪基站活动热点。如此,基于规则模型库批处理时间窗口内部数据,能实现低延迟告警,进而解决现有技术手段不能实时侦测伪基站的问题。The pseudo base station positioning method described in this embodiment combines the user location event data with the Spark Streaming flow processing technology, first screens the key information of the pseudo base station from the massive data, and then performs multi-dimensional analysis based on users, events, time, and space. Realize quasi-real-time display and alarm of pseudo-base station activity hotspots like weather cloud images. In this way, based on the rule model library, batch processing the internal data of the time window can realize low-latency alarms, thereby solving the problem that existing technical means cannot detect fake base stations in real time.

图2为本发明实施例提供的伪基站定位的实现流程图二,如图2所示,该流程主要包括以下步骤:Fig. 2 is the implementation flowchart 2 of the positioning of the pseudo base station provided by the embodiment of the present invention. As shown in Fig. 2, the process mainly includes the following steps:

步骤201:信令数据按照指定的队列方式分话题存储于分布式消息队列平台。Step 201: The signaling data is stored in the distributed message queuing platform according to the specified queuing mode and topic.

具体地,可通过步骤201,即通过存储于分布式消息队列平台的话题数据统计基站实时在网人数;然后建立MC口清单表,并将所有的MC口数据导入到第一流处理平台。Specifically, through step 201, the real-time online number of base stations can be counted through the topic data stored in the distributed message queue platform; then the MC port list table can be established, and all MC port data can be imported to the first stream processing platform.

其中,MC口是指移动交换中心(MSC,Mobile Switching Center)与媒体网关(MGW,Media Gateway)间的接口。Wherein, the MC port refers to an interface between a mobile switching center (MSC, Mobile Switching Center) and a media gateway (MGW, Media Gateway).

具体的,所述第一处理平台是指基于Spark Streaming流技术的流处理平台。Specifically, the first processing platform refers to a stream processing platform based on Spark Streaming streaming technology.

步骤202:按照指定时间切片获取信令数据。Step 202: Obtain signaling data according to a specified time slice.

具体的,基于Spark Streaming流技术的流处理平台把信令数据按照时间切片Δt为单位切分成块,把每块数据作为一个RDD,并使用RDD操作处理每一小块数据;每个小块都会生成一个Spark Job处理,最终结果也返回多块。Specifically, the stream processing platform based on Spark Streaming stream technology divides the signaling data into blocks according to the time slice Δt, regards each block of data as an RDD, and uses RDD operations to process each small block of data; each small block will A Spark Job is generated for processing, and the final result also returns multiple blocks.

具体的,对于话题数据(Topic_Data)来说,当前时间切片(如500ms)的数据为完整的信令数据,包括:入网号码、开始时间、结束时间、协议、事件类型、编码类别、MSC信令点编码、BSC信令点编码、当前位置区、当前小区或者服务区代码(SAC,Service Area Code)、源位置区、源小区、目的位置区、目的小区、开始位置区、开始小区、结束位置区、结束小区、目的无线网络控制区识别码(RNCID,Radio Network Controller Identity)、主叫号码、被叫号码、主叫IMSI、被叫IMSI、主叫IMEI、被叫IMEI、事件结果、切出请求原因、切出开始时间、切出响应时间、切入开始时间、切入响应时间、切出状态、切入状态、位置更新状态、切换标志、振铃时间、应答时间、通话时长。Specifically, for topic data (Topic_Data), the data of the current time slice (such as 500ms) is complete signaling data, including: network access number, start time, end time, protocol, event type, coding category, MSC signaling Point code, BSC signaling point code, current location area, current cell or service area code (SAC, Service Area Code), source location area, source cell, destination location area, destination cell, start location area, start cell, end location Area, end cell, destination radio network control area identification code (RNCID, Radio Network Controller Identity), calling number, called number, calling IMSI, called IMSI, calling IMEI, called IMEI, event result, cut out Request reason, switch-out start time, switch-out response time, switch-in start time, switch-in response time, switch-out status, switch-in status, location update status, switching flag, ringing time, answer time, call duration.

具体地,可通过步骤202获得基站在网人数以及在网基站等数据,通过预定规则,识别异常基站;还可通过步骤202还可以建立正常位置更新临时表,筛选事件为正常位置更新的记录。Specifically, step 202 can be used to obtain data such as the number of people on the network and the number of base stations on the network, and identify abnormal base stations through predetermined rules; a temporary table for normal location updates can also be established through step 202 to filter events for records of normal location updates.

步骤203:将每一个时间切片的信令数据都转换成RDD,然后对数据流的进行实时流的批处理分析。Step 203: Convert the signaling data of each time slice into an RDD, and then perform batch analysis of the real-time stream on the data stream.

具体地,所述进行批处理分析,可以包括:Specifically, the batch analysis may include:

按照信令数据格式和分隔符,按时间切片获取各类话题数据。According to the signaling data format and delimiter, various topic data are obtained by time slice.

所述话题可以是:主叫、紧急呼叫、被叫、视频主叫、视频被叫、发短信、收短信、切入、切出、BSC内切换、正常位置更新、周期性位置更新、IMSI附着、IMSI分离、寻呼、补充业务、短信状态报告、业务重建、手机状态报告。The topic can be: calling, emergency calling, called, video calling, video calling, sending text messages, receiving text messages, switching in, switching out, switching within the BSC, normal location update, periodic location update, IMSI attachment, IMSI separation, paging, supplementary service, SMS status report, service reconstruction, mobile phone status report.

具体地,可通过步骤203获得的异常基站数据,得到用户掉落移动基站的信令数据以及重新入网的信令数据,通过这些信令数据中基站地理位置信息,获得伪基站范围;还可通过步骤203建立正常位置更新临时表,筛选源LAC不为规划LAC的事件。Specifically, the abnormal base station data obtained in step 203 can be used to obtain the signaling data of the user falling off the mobile base station and the signaling data of re-entry into the network, and the range of the pseudo base station can be obtained through the geographical location information of the base station in these signaling data; Step 203 establishes a normal location update temporary table, and filters events where the source LAC is not the planning LAC.

步骤204:分布式处理结果满足预设条件时,输出结果数据,并触发告警。Step 204: When the distributed processing result satisfies the preset condition, output the result data and trigger an alarm.

本实施例中所述伪基站定位方法,通过存储于分布式消息队列平台的话题数据统计基站实时在网人数;然后建立MC口清单表;获得基站在网人数以及在网基站等数据,通过预定规则,识别异常基站;得到用户掉落移动基站的信令数据以及重新入网的信令数据,通过这些信令数据中基站地理位置信息,获得伪基站范围。如此,能实时侦测伪基站。The pseudo-base station location method described in this embodiment is to count the real-time online number of the base station through the topic data stored in the distributed message queue platform; According to the rules, abnormal base stations are identified; the signaling data of the mobile base station dropped by the user and the signaling data of re-entry to the network are obtained, and the geographical location information of the base station in these signaling data is used to obtain the range of the pseudo base station. In this way, false base stations can be detected in real time.

图3为本发明实施例提供的伪基站定位方法的实现流程图三,如图3所示,所述方法主要包括以下步骤:Fig. 3 is the implementation flow chart 3 of the pseudo base station positioning method provided by the embodiment of the present invention. As shown in Fig. 3, the method mainly includes the following steps:

步骤301:根据分布式处理结果,并结合信令数据,进行多维度数据分析以统计伪基站出现规律。Step 301: According to the distributed processing results and combined with the signaling data, multi-dimensional data analysis is performed to collect statistics on the appearance of pseudo base stations.

这里,所述分布式处理结果可以是实施例一中流处理平台的分布式处理结果,所述信令数据可以分布式消息队列平台获取的信令数据。Here, the distributed processing result may be the distributed processing result of the stream processing platform in Embodiment 1, and the signaling data may be signaling data acquired by the distributed message queue platform.

优选地,所述进行多维度数据分析,至少可以包括:Preferably, the multidimensional data analysis may at least include:

基于用户、事件、时间、空间进行多维度分析,生成基于全网的伪基站干扰准实时热力图;Based on multi-dimensional analysis of users, events, time, and space, a pseudo-base station interference quasi-real-time heat map based on the entire network is generated;

按时间帧播放所述伪基站干扰热力图,根据流窜型伪基站可疑区域和轨迹,预测所述流窜型伪基站的下一活动地点。The interference heat map of the pseudo-base station is played in time frames, and the next activity location of the pseudo-base station is predicted according to the suspicious area and trajectory of the pseudo-base station.

具体地,所述进行多维度数据分析,可以包括但不限于以下几种:Specifically, the multi-dimensional data analysis may include but not limited to the following:

1)基于小时、日、月多时间粒度的统计汇总,包括受害用户清单、被干扰小区清单、伪基站LAC清单等报表;1) Statistical summary based on time granularity of hours, days, and months, including reports such as victim user list, interfered cell list, pseudo base station LAC list, etc.;

2)公安伪基站、驻点伪基站、流窜伪基站干扰事件分类;2) Classification of public security pseudo base stations, stationary pseudo base stations, and mobile pseudo base station interference events;

3)根据用户投诉信息查找投诉事件具体发生的事件和地点,验证投诉事件真实有效性;3) Find out the specific event and location of the complaint event based on the user complaint information, and verify the authenticity and validity of the complaint event;

4)计算高频受害用户轨迹,查询基于某时间段的单用户或多用户位置运动轨迹,同时标记轨迹中伪基站事件点,用于分析排查是否为伪基站;4) Calculate the trajectory of high-frequency victimized users, query the location movement trajectory of a single user or multiple users based on a certain period of time, and mark the event points of fake base stations in the trajectory to analyze and check whether it is a fake base station;

5)对正在发生伪基站干扰事件的热点区域、新增的伪基站干扰区域、消失的伪基站干扰区域进行分析,以便于对突发群体伪基站事件进行告警。5) Analyze the hotspot area where the pseudo base station interference event is occurring, the newly added pseudo base station interference area, and the disappearing pseudo base station interference area, so as to give an alarm to the sudden group pseudo base station event.

步骤302:根据多维度数据分析结果,调节所述规则模型库的参数,以反向完善所述规则模型库。Step 302: According to the multi-dimensional data analysis result, adjust the parameters of the rule model library to reversely improve the rule model library.

优选地,所述规则模型库可存储于流处理平台的本地存储器中、或存储于云服务器中。Preferably, the rule model library can be stored in a local storage of the stream processing platform, or in a cloud server.

上述步骤301、步骤302的执行主体均可为数据分析平台。The execution subject of the above step 301 and step 302 can be a data analysis platform.

本实施例中所述伪基站定位方法,数据分析平台基于用户、事件、时间、空间进行多维分析,实现能像天气云图一样准实时的显示和告警伪基站活动热点、以及分析伪基站活动的轨迹趋势,预测下一个犯罪活动区域;并且,根据多维度数据分析结果,调节所述规则模型库的参数,以反向完善所述规则模型库,提高了侦测的准确性。The pseudo-base station positioning method described in this embodiment, the data analysis platform performs multi-dimensional analysis based on users, events, time, and space, and realizes quasi-real-time display and alarm of pseudo-base station activity hotspots and analysis of pseudo-base station activities like a weather cloud map. Trends to predict the next criminal activity area; and, according to the multi-dimensional data analysis results, adjust the parameters of the rule model library to reversely improve the rule model library and improve the accuracy of detection.

图4为本发明实施例提供的伪基站定位系统的组成结构示意图,如图4所示,所述系统包括分布式消息队列平台41、流处理平台42和数据分析平台43;其中,FIG. 4 is a schematic diagram of the composition and structure of the pseudo base station positioning system provided by the embodiment of the present invention. As shown in FIG. 4, the system includes a distributed message queue platform 41, a stream processing platform 42 and a data analysis platform 43; wherein,

所述分布式消息队列平台41,用于实时接收信令数据;将所述信令数据被按照自定义的方式存储于集群的各个节点;The distributed message queue platform 41 is used for receiving signaling data in real time; storing the signaling data in each node of the cluster in a custom manner;

所述流处理平台42,用于按照指定时间切片获取信令数据;基于规则模型库对所述信令数据进行分布式处理;当分布式处理结果满足预设条件时,进行告警,并将分布式处理结果录入数据分析平台43;The stream processing platform 42 is used to obtain signaling data according to a specified time slice; perform distributed processing on the signaling data based on the rule model library; when the distributed processing results meet the preset conditions, an alarm is issued, and the distributed Input data analysis platform 43 of formula processing result;

所述数据分析平台43,用于根据所述分布式处理结果,并结合信令数据,进行多维度数据分析以统计伪基站出现规律;根据多维度数据分析结果,调节所述规则模型库的参数,以反向完善所述规则模型库。The data analysis platform 43 is used to perform multi-dimensional data analysis based on the distributed processing results and in combination with signaling data to count the occurrence rules of pseudo base stations; adjust the parameters of the rule model library according to the multi-dimensional data analysis results , to reversely improve the rule model library.

其中,所述自定义的方式为:将所述信令数据分成N类,其中N为正整数:Wherein, the self-defining method is: dividing the signaling data into N categories, where N is a positive integer:

优选地,所述流处理平台42,还用于:Preferably, the stream processing platform 42 is also used for:

将每个时间切片的信令数据都转换成RDD;Convert the signaling data of each time slice into RDD;

基于规则模型库对预设时间内的信令数据流进行批处理分析。Batch analysis of signaling data flow within a preset time based on the rule model library.

优选地,所述数据分析平台43,还用于:Preferably, the data analysis platform 43 is also used for:

基于用户、事件、时间、空间进行多维度分析,生成基于全网的伪基站干扰准实时热力图;Based on multi-dimensional analysis of users, events, time, and space, a pseudo-base station interference quasi-real-time heat map based on the entire network is generated;

按时间帧播放所述伪基站干扰热力图,根据流窜型伪基站可疑区域和轨迹,预测所述流窜型伪基站的下一活动地点。The interference heat map of the pseudo-base station is played in time frames, and the next activity location of the pseudo-base station is predicted according to the suspicious area and trajectory of the pseudo-base station.

优选地,所述分布式消息队列平台41,还用于:Preferably, the distributed message queue platform 41 is also used for:

在集群上搭建Zookeeper,以使所述分布式消息队列平台基于Zoopkeeper均衡负载。Build Zookeeper on the cluster, so that the distributed message queue platform is based on Zookeeper to balance the load.

本发明实施例提供伪基站定位系统,系统通过将收集到的各个基站的实时数据存储于分布式消息队列平台,流处理平台充当消息队列消费者角色,分组消费消息队列中各话题数据,即利用Spark批处理技术,对MC口历史全量用户行为信息进行ETL流程,筛选原位置区为异常LAC的正常位置更新事件信息进行汇总统计,关联用户资料和基站地理位置信息,可以得到多维度的事件统计,从而判定伪基站主要活动区域以及受害用户群。利用Spark streaming流处理技术,对MC口实时信息进行判定筛选,然后以分钟或小时级时间颗粒进行汇总,利用地理信息系统(GIS,Geographic Information System)系统进行热力点分析,可以有效地得出伪基站干扰区域和轨迹,从而预测伪基站的下一活动地点。通过系统设定相关的告警门限值,实时数据汇总统计后触发门限即可实现伪基站出现告警功能。同时数据分析平台能够存储流处理历史数据,完成离线多维度分析统计,优化基站网络安全。The embodiment of the present invention provides a pseudo-base station positioning system. The system stores the collected real-time data of each base station in a distributed message queue platform, and the stream processing platform acts as a message queue consumer, and consumes each topic data in the message queue in groups, that is, uses Spark batch processing technology, conducts ETL process on the historical full amount of user behavior information of the MC port, screens out the normal location update event information of the abnormal LAC in the original location area, performs summary statistics, correlates user data and base station geographic location information, and obtains multi-dimensional event statistics , so as to determine the main activity area of the pseudo base station and the victim user group. Using the Spark streaming stream processing technology to judge and screen the real-time information of the MC port, and then summarize it with minute or hour-level time particles, and use the Geographic Information System (GIS, Geographic Information System) system to analyze the hot spots, it can effectively obtain pseudo Base station interference area and trajectory, so as to predict the next activity location of the pseudo base station. By setting the relevant alarm threshold value through the system, the alarm function of the false base station can be realized by triggering the threshold after the real-time data is summarized and counted. At the same time, the data analysis platform can store stream processing historical data, complete offline multi-dimensional analysis and statistics, and optimize base station network security.

在本发明所提供的几个实施例中,应该理解到,所揭露的方法、设备和系统,可以通过其它的方式实现。以上所描述的设备实施例仅仅是示意性的,例如,所述单元的划分,仅仅为一种逻辑功能划分,实际实现时可以有另外的划分方式,如:多个单元或组件可以结合,或可以集成到另一个系统,或一些特征可以忽略,或不执行。另外,所显示或讨论的各组成部分相互之间的耦合、或直接耦合、或通信连接可以是通过一些接口,设备或单元的间接耦合或通信连接,可以是电性的、机械的或其它形式的。In the several embodiments provided by the present invention, it should be understood that the disclosed methods, devices and systems can be implemented in other ways. The device embodiments described above are only illustrative. For example, the division of the units is only a logical function division. In actual implementation, there may be other division methods, such as: multiple units or components can be combined, or May be integrated into another system, or some features may be ignored, or not implemented. In addition, the coupling, or direct coupling, or communication connection between the components shown or discussed may be through some interfaces, and the indirect coupling or communication connection of devices or units may be electrical, mechanical or other forms of.

上述作为分离部件说明的单元可以是、或也可以不是物理上分开的,作为单元显示的部件可以是、或也可以不是物理单元,即可以位于一个地方,也可以分布到多个网络单元上;可以根据实际的需要选择其中的部分或全部单元来实现本实施例方案的目的。The units described above as separate components may or may not be physically separated, and the components displayed as units may or may not be physical units, that is, they may be located in one place or distributed to multiple network units; Part or all of the units can be selected according to actual needs to achieve the purpose of the solution of this embodiment.

另外,在本发明各实施例中的各功能单元可以全部集成在一个处理单元中,也可以是各单元分别单独作为一个单元,也可以两个或两个以上单元集成在一个单元中;上述集成的单元既可以采用硬件的形式实现,也可以采用硬件加软件功能单元的形式实现。In addition, each functional unit in each embodiment of the present invention can be integrated into one processing unit, or each unit can be used as a single unit, or two or more units can be integrated into one unit; the above-mentioned integration The unit can be realized in the form of hardware or in the form of hardware plus software functional unit.

本领域普通技术人员可以理解:实现上述方法实施例的全部或部分步骤可以通过程序指令相关的硬件来完成,前述的程序可以存储于一计算机可读取存储介质中,该程序在执行时,执行包括上述方法实施例的步骤;而前述的存储介质包括:移动存储设备、只读存储器(ROM,Read-Only Memory)、磁碟或者光盘等各种可以存储程序代码的介质。Those of ordinary skill in the art can understand that all or part of the steps for realizing the above-mentioned method embodiments can be completed by hardware related to program instructions, and the aforementioned program can be stored in a computer-readable storage medium. When the program is executed, the It includes the steps of the above-mentioned method embodiments; and the aforementioned storage medium includes: a removable storage device, a read-only memory (ROM, Read-Only Memory), a magnetic disk or an optical disk, and other various media that can store program codes.

或者,本发明实施例上述集成的单元如果以软件功能模块的形式实现并作为独立的产品销售或使用时,也可以存储在一个计算机可读取存储介质中。基于这样的理解,本发明实施例的技术方案本质上或者说对现有技术做出贡献的部分可以以软件产品的形式体现出来,该计算机软件产品存储在一个存储介质中,包括若干指令用以使得一台计算机设备(可以是个人计算机、服务器、或者网络设备等)执行本发明各个实施例所述方法的全部或部分。而前述的存储介质包括:移动存储设备、ROM、磁碟或者光盘等各种可以存储程序代码的介质。Alternatively, if the above-mentioned integrated units in the embodiments of the present invention are implemented in the form of software function modules and sold or used as independent products, they may also be stored in a computer-readable storage medium. Based on this understanding, the technical solution of the embodiment of the present invention is essentially or the part that contributes to the prior art can be embodied in the form of a software product. The computer software product is stored in a storage medium and includes several instructions for Make a computer device (which may be a personal computer, a server, or a network device, etc.) execute all or part of the methods described in various embodiments of the present invention. The aforementioned storage medium includes various media capable of storing program codes such as removable storage devices, ROMs, magnetic disks or optical disks.

以上所述,仅为本发明的较佳实施例而已,并非用于限定本发明的保护范围。凡在本发明的精神和原则之内所作的任何修改、等同替换和改进等,均应包含在本发明的保护范围之内。The above descriptions are only preferred embodiments of the present invention, and are not intended to limit the protection scope of the present invention. Any modifications, equivalent replacements and improvements made within the spirit and principles of the present invention shall be included within the protection scope of the present invention.

Claims (9)

1.一种伪基站定位方法,其特征在于,所述方法包括:1. A pseudo-base station location method, characterized in that the method comprises: 流处理平台按照指定时间切片获取信令数据;The stream processing platform obtains signaling data according to the specified time slice; 流处理平台基于规则模型库对所述信令数据进行分布式处理;The stream processing platform performs distributed processing on the signaling data based on the rule model library; 当分布式处理结果满足预设条件时,进行告警,并将分布式处理结果录入数据分析平台;When the distributed processing results meet the preset conditions, an alarm is issued, and the distributed processing results are entered into the data analysis platform; 所述将分布式处理结果录入数据分析平台之后,还包括:After the distributed processing results are entered into the data analysis platform, it also includes: 所述数据分析平台根据所述分布式处理结果,并结合信令数据,进行多维度数据分析以统计伪基站出现规律;The data analysis platform performs multi-dimensional data analysis based on the distributed processing results and in combination with signaling data to count the occurrence rules of pseudo base stations; 根据多维度数据分析结果,调节所述规则模型库的参数,以反向完善所述规则模型库。According to the multi-dimensional data analysis result, the parameters of the rule model library are adjusted to reversely improve the rule model library. 2.根据权利要求1所述的方法,其特征在于,所述基于规则模型库对所述信令数据进行分布式处理,包括:2. The method according to claim 1, wherein the distributed processing of the signaling data by the rule-based model library comprises: 将每个时间切片的信令数据都转换成弹性分布式数据集RDD;Convert the signaling data of each time slice into an elastic distributed dataset RDD; 基于规则模型库对预设时间内的信令数据流进行批处理分析。Batch analysis of signaling data flow within a preset time based on the rule model library. 3.根据权利要求1所述的方法,其特征在于,所述进行多维度数据分析,至少包括:3. The method according to claim 1, wherein said performing multidimensional data analysis at least includes: 基于用户、事件、时间、空间进行多维度分析,生成基于全网的伪基站干扰准实时热力图;Based on multi-dimensional analysis of users, events, time, and space, a pseudo-base station interference quasi-real-time heat map based on the entire network is generated; 按时间帧播放所述伪基站干扰热力图,根据流窜型伪基站可疑区域和轨迹,预测所述流窜型伪基站的下一活动地点。The interference heat map of the pseudo-base station is played in time frames, and the next activity location of the pseudo-base station is predicted according to the suspicious area and trajectory of the pseudo-base station. 4.根据权利要求1所述的方法,其特征在于,所述按照指定时间切片获取信令数据之前,所述方法还包括:4. The method according to claim 1, wherein before the acquisition of signaling data according to a specified time slice, the method further comprises: 分布式消息队列平台实时接收信令数据;The distributed message queue platform receives signaling data in real time; 将所述信令数据被按照自定义的方式存储于集群的各个节点;storing the signaling data in each node of the cluster in a custom manner; 其中,所述自定义的方式为:将所述信令数据分成N类,其中N为正整数。Wherein, the manner of self-definition is: dividing the signaling data into N categories, where N is a positive integer. 5.根据权利要求4所述的方法,其特征在于,所述分布式消息队列平台实时接收信令数据之前,所述方法还包括:5. method according to claim 4, is characterized in that, before described distributed message queue platform receives signaling data in real time, described method also comprises: 在集群上搭建Zookeeper,以使所述分布式消息队列平台基于Zoopkeeper均衡负载。Build Zookeeper on the cluster, so that the distributed message queue platform is based on Zookeeper to balance the load. 6.一种伪基站定位系统,其特征在于,所述系统包括分布式消息队列平台、流处理平台和数据分析平台;其中,6. A pseudo base station positioning system, characterized in that the system includes a distributed message queue platform, a flow processing platform and a data analysis platform; wherein, 所述分布式消息队列平台,用于实时接收信令数据;将所述信令数据被按照自定义的方式存储于集群的各个节点;其中,所述自定义的方式为:将所述信令数据分成N类,其中N为正整数;The distributed message queue platform is used to receive signaling data in real time; the signaling data is stored in each node of the cluster in a customized manner; wherein, the customized manner is: the signaling The data is divided into N categories, where N is a positive integer; 所述流处理平台,用于按照指定时间切片获取信令数据;基于规则模型库对所述信令数据进行分布式处理;当分布式处理结果满足预设条件时,进行告警,并将分布式处理结果录入数据分析平台;The stream processing platform is used to obtain signaling data according to a specified time slice; perform distributed processing on the signaling data based on a rule model library; when the distributed processing results meet preset conditions, an alarm is issued, and the distributed The processing results are entered into the data analysis platform; 所述数据分析平台,用于根据所述分布式处理结果,并结合信令数据,进行多维度数据分析以统计伪基站出现规律;根据多维度数据分析结果,调节所述规则模型库的参数,以反向完善所述规则模型库。The data analysis platform is used to perform multi-dimensional data analysis based on the distributed processing results and in combination with signaling data to count the occurrence rules of pseudo base stations; adjust the parameters of the rule model library according to the multi-dimensional data analysis results, To inversely perfect the rule model library. 7.根据权利要求6所述的系统,其特征在于,所述流处理平台,还用于:7. The system according to claim 6, wherein the stream processing platform is further used for: 将每个时间切片的信令数据都转换成RDD;Convert the signaling data of each time slice into RDD; 基于规则模型库对预设时间内的信令数据流进行批处理分析。Batch analysis of signaling data flow within a preset time based on the rule model library. 8.根据权利要求6所述的系统,其特征在于,所述数据分析平台,还用于:8. The system according to claim 6, wherein the data analysis platform is also used for: 基于用户、事件、时间、空间进行多维度分析,生成基于全网的伪基站干扰准实时热力图;Based on multi-dimensional analysis of users, events, time, and space, a pseudo-base station interference quasi-real-time heat map based on the entire network is generated; 按时间帧播放所述伪基站干扰热力图,根据流窜型伪基站可疑区域和轨迹,预测所述流窜型伪基站的下一活动地点。The interference heat map of the pseudo-base station is played in time frames, and the next activity location of the pseudo-base station is predicted according to the suspicious area and trajectory of the pseudo-base station. 9.根据权利要求6所述的系统,其特征在于,所述分布式消息队列平台,还用于:9. The system according to claim 6, wherein the distributed message queuing platform is also used for: 在集群上搭建Zookeeper,以使所述分布式消息队列平台基于Zoopkeeper均衡负载。Build Zookeeper on the cluster, so that the distributed message queue platform is based on Zookeeper to balance the load.
CN201510151799.9A 2015-04-01 2015-04-01 A pseudo base station positioning method and system Active CN106162688B (en)

Priority Applications (1)

Application Number Priority Date Filing Date Title
CN201510151799.9A CN106162688B (en) 2015-04-01 2015-04-01 A pseudo base station positioning method and system

Applications Claiming Priority (1)

Application Number Priority Date Filing Date Title
CN201510151799.9A CN106162688B (en) 2015-04-01 2015-04-01 A pseudo base station positioning method and system

Publications (2)

Publication Number Publication Date
CN106162688A CN106162688A (en) 2016-11-23
CN106162688B true CN106162688B (en) 2019-08-27

Family

ID=57338784

Family Applications (1)

Application Number Title Priority Date Filing Date
CN201510151799.9A Active CN106162688B (en) 2015-04-01 2015-04-01 A pseudo base station positioning method and system

Country Status (1)

Country Link
CN (1) CN106162688B (en)

Families Citing this family (3)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
CN108243421B (en) * 2016-12-26 2020-12-15 中国移动通信集团山东有限公司 Pseudo base station identification method and system
CN110213724B (en) * 2019-05-17 2020-10-20 国家计算机网络与信息安全管理中心 Pseudo base station motion trajectory identification method
CN111913996B (en) * 2020-07-14 2023-07-18 中国联合网络通信集团有限公司 Data processing method, device, equipment and storage medium

Citations (3)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
CN101453743A (en) * 2008-10-31 2009-06-10 中国移动通信集团北京有限公司 Real-time monitoring system, apparatus and method
CN102075980A (en) * 2009-11-25 2011-05-25 中国移动通信集团福建有限公司 Method and device for obtaining system switching information element
CN104301896A (en) * 2014-10-15 2015-01-21 上海欣方智能系统有限公司 Intelligent fraud short message monitor and alarm system and method

Family Cites Families (2)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
CN101772011B (en) * 2008-12-29 2012-06-20 中国移动通信集团上海有限公司 Method for optimizing configuration of household base station and household base station device
CN104038301B (en) * 2014-06-30 2016-08-24 信亚美科(南京)信息技术有限公司 A kind of method utilizing distributed intelligence radio monitoring system to carry out spectrum monitoring

Patent Citations (3)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
CN101453743A (en) * 2008-10-31 2009-06-10 中国移动通信集团北京有限公司 Real-time monitoring system, apparatus and method
CN102075980A (en) * 2009-11-25 2011-05-25 中国移动通信集团福建有限公司 Method and device for obtaining system switching information element
CN104301896A (en) * 2014-10-15 2015-01-21 上海欣方智能系统有限公司 Intelligent fraud short message monitor and alarm system and method

Also Published As

Publication number Publication date
CN106162688A (en) 2016-11-23

Similar Documents

Publication Publication Date Title
US7966020B2 (en) Wireless user based notification system
CN108848515B (en) Internet of things service quality monitoring platform and method based on big data
KR20110097947A (en) Prediction Notification System for Emergency Services
WO2022161141A1 (en) Earthquake monitoring method, earthquake early warning method, and system
CN109698934A (en) A kind of area monitoring method and device
US8364147B2 (en) System and method for determining commonly used communication terminals and for identifying noisy entities in large-scale link analysis
US20170041762A1 (en) Method and system for identifying significant locations through data obtainable from a telecommunication network
CN108243421B (en) Pseudo base station identification method and system
CN107147521B (en) Early warning and monitoring method for complaint service
US8989701B2 (en) Identifying a wireless device of a target user for communication interception based on individual usage pattern(S)
WO2010031294A1 (en) De-massing method of position advertising service based on regional strategy and system thereof
CN106921507A (en) The method and apparatus being predicted to customer complaint within a wireless communication network
CN106162688B (en) A pseudo base station positioning method and system
CN106033635A (en) A monitoring method and system
CN106911675A (en) A kind of mobile phone Malware method for early warning and device
CN104955097B (en) Mobile network's monitoring signaling method based on cuclear density distribution
WO2011140874A1 (en) Method and apparatus for evaluating behavior of user equipment in standby state
CA2715763C (en) Traveler's alert system
CN111480352A (en) Edge-based location-specific alarm system for L TE networks
CN110248365A (en) A kind of pseudo-base station note Spatial-temporal pattern visual analysis method
US12395845B2 (en) System and method for identifying collocated cellular devices from known fraudulent devices
US20090227239A1 (en) Traveler's alert system (tas)
Aziz et al. Cooperative flood detection using GSMD via SMS
CN102547796A (en) Method and device for monitoring number of users in mobile communication system
US20130346420A1 (en) Method And System For Identifying Aberrant Wireless Behavior

Legal Events

Date Code Title Description
C06 Publication
PB01 Publication
C10 Entry into substantive examination
SE01 Entry into force of request for substantive examination
GR01 Patent grant
GR01 Patent grant