美文网首页Spark专题
flume+kafka+Spark+mysql+ssm+高德地图

flume+kafka+Spark+mysql+ssm+高德地图

作者: 小月半会飞 | 来源:发表于2019-03-08 11:46 被阅读0次

    第一步、编写python脚本,产生模拟数据

    
    #coding=UTF-8
    
    import random
    import time
    
    phone=[
        "13869555210",
        "18542360152",
        "15422556663",
        "18852487210",
        "13993584664",
        "18754366522",
        "15222436542",
        "13369568452",
        "13893556666",
        "15366698558"
    ]
    
    location=[
        "116.191031, 39.988585",
        "116.389275, 39.925818",
        "116.287444, 39.810742",
        "116.481707, 39.940089",
        "116.410588, 39.880172",
        "116.394816, 39.91181",
        "116.416002, 39.952917"
    ]
    
    def sample_phone():
        return random.sample(phone,1)[0]
    def sample_location():
        return random.sample(location, 1)[0]
    
    def generator_log(count=10):
        time_str=time.strftime("%Y-%m-%d %H:%M:%S",time.localtime())
        f=open("/opt/log.txt","a+")
        while count>=1:
            query_log="{phone}\t{location}\t{date}".format(phone=sample_phone(),location=sample_location(),date=time_str)
            f.write(query_log+"\n")
         #   print query_log
            count=count-1
    
    if __name__=='__main__':
        generator_log(100)
    

    第二步、配置Flume

    在Flume安装目录下(conf)添加配置文件 storm_pro.conf

    agent.sources = s1
    agent.channels = c1
    agent.sinks = k1
    
    agent.sources.s1.type=exec
    agent.sources.s1.command=tail -F /opt/log.txt
    agent.sources.s1.channels=c1
    agent.channels.c1.type=memory
    agent.channels.c1.capacity=10000
    agent.channels.c1.transactionCapacity=100
    
    #kafka接收器  
    agent.sinks.k1.type= org.apache.flume.sink.kafka.KafkaSink
    #设置Kafka的broker地址和端口号
    agent.sinks.k1.brokerList=hadoop3:9092,hadoop4:9092,hadoop5:9092                                                                                 
    #设置Kafka的Topic
    agent.sinks.k1.topic=ss_kafka
    #设置序列化方式
    agent.sinks.k1.serializer.class=kafka.serializer.StringEncoder
    agent.sinks.k1.channel=c1
    
    

    第三步、启动集群

    1、将python脚本放到hadoop3里面,然后运行一下脚本,看看是否是好的,如果能出来结果,就继续下面步骤,如果不行,就检查python脚本

    python kafka.py
    

    2、启动hadoop集群

    start-dfs.sh
    

    3、启动zookeeper

    zkServer.sh start
    

    4、启动kafka

    kafka-server-start.sh /opt/modules/app/kafka/config/server.properties
    

    5、启动flume

    在flume目录下

    ./bin/flume-ng agent -n agent -c conf -f conf/storm_pro.conf -Dflume.root.logger=INFO,console
    

    6、创建一个flume里面定义的topic

    kafka-topics.sh --create --zookeeper hadoop3:2181 --replication-factor 1 --partitions 1 --topic ss_kafka
    

    7、开启消费者,消费内容

    kafka-console-consumer.sh --zookeeper hadoop3:2181 -from-beginning --topic ss_kafka
    

    8、执行python脚本

    python kafka.py
    

    第三步、spark程序编写

    1、停止消费者消费

    按ctrl+z退出

    2、离开hdfs的安全模式

    hdfs dfsadmin -safemode leave
    

    3、在Intellij上面写java代码,连接hadoop3上面的flume日志上面的数据

    import kafka.serializer.StringDecoder
    import org.apache.spark.streaming._
    import org.apache.spark.streaming.kafka._
    import org.apache.spark.SparkConf
    /**
      * Created by Administrator on 2019/3/7.
      */
    object Kafkademo {
      def main(args: Array[String]): Unit = {
        System.setProperty("HADOOP_USER_NAME", "root")
    
        val sparkConf = new SparkConf().setAppName("Kafkademo").setMaster("local[2]")
        val ssc = new StreamingContext(sparkConf, Seconds(5))
        ssc.checkpoint("hdfs://hadoop3:8020/spark_check_point")
        //kafka的topic集合,即可以订阅多个topic,args传参的时候用,隔开
        val topicsSet = Set("ss_kafka")
        //设置kafka参数,定义brokers集合
        val kafkaParams = Map[String, String]("metadata.broker.list" -> "192.168.159.133:9092,192.168.159.130:9092,192.168.159.134:9092")
        val messages = KafkaUtils.createDirectStream[String, String, StringDecoder, StringDecoder](
          ssc, kafkaParams, topicsSet)
        print("---------:" +messages)
    
        val lines = messages.map(_._2)
        //    val words = lines.flatMap(_.split(" "))
        //    val wordCounts = words.map(x => (x, 1)).reduceByKey(_ + _)
        lines.print()
    
    
    
        ssc.start()
        ssc.awaitTermination()
      }
    }
    

    第四步、连接数据库

    1、新建数据库test

    2、新建表

    CREATE TABLE `NewTable` (
    `time`  bigint(20) NULL ,
    `latitude`  double NULL ,
    `longtitude`  double NULL 
    )
    ;
    

    3、添加依赖

    在properties添加javaversion

    <?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>neusoft</groupId>
      <artifactId>neusoft</artifactId>
      <version>1.0-SNAPSHOT</version>
      <packaging>war</packaging>
    
      <name>neusoft Maven Webapp</name>
      <!-- FIXME change it to the project's website -->
      <url>http://www.example.com</url>
    
      <properties>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
        <maven.compiler.source>1.8</maven.compiler.source>
        <maven.compiler.target>1.8</maven.compiler.target>
        <!-- spring版本号 -->
        <spring.version>4.0.2.RELEASE</spring.version>
        <!-- mybatis版本号 -->
        <mybatis.version>3.2.6</mybatis.version>
        <!-- log4j日志文件管理包版本 -->
        <slf4j.version>1.7.7</slf4j.version>
        <log4j.version>1.2.17</log4j.version>
      </properties>
    
      <dependencies>
        <dependency>
          <groupId>junit</groupId>
          <artifactId>junit</artifactId>
          <version>3.8.1</version>
          <scope>test</scope>
        </dependency>
        <!-- 导入java ee jar包(可以去除index.jsp报错) -->
        <dependency>
          <groupId>javax</groupId>
          <artifactId>javaee-api</artifactId>
          <version>7.0</version>
        </dependency>
        <dependency>
          <groupId>junit</groupId>
          <artifactId>junit</artifactId>
          <version>4.11</version>
          <!-- 表示开发的时候引入,发布的时候不会加载此包 -->
          <scope>test</scope>
        </dependency>
        <!-- spring核心包 -->
        <dependency>
          <groupId>org.springframework</groupId>
          <artifactId>spring-core</artifactId>
          <version>${spring.version}</version>
        </dependency>
        <dependency>
          <groupId>org.springframework</groupId>
          <artifactId>spring-web</artifactId>
          <version>${spring.version}</version>
        </dependency>
        <dependency>
          <groupId>org.springframework</groupId>
          <artifactId>spring-oxm</artifactId>
          <version>${spring.version}</version>
        </dependency>
        <dependency>
          <groupId>org.springframework</groupId>
          <artifactId>spring-tx</artifactId>
          <version>${spring.version}</version>
        </dependency>
        <dependency>
          <groupId>org.springframework</groupId>
          <artifactId>spring-jdbc</artifactId>
          <version>${spring.version}</version>
        </dependency>
        <dependency>
          <groupId>org.springframework</groupId>
          <artifactId>spring-webmvc</artifactId>
          <version>${spring.version}</version>
        </dependency>
        <dependency>
          <groupId>org.springframework</groupId>
          <artifactId>spring-aop</artifactId>
          <version>${spring.version}</version>
        </dependency>
        <dependency>
          <groupId>org.springframework</groupId>
          <artifactId>spring-context-support</artifactId>
          <version>${spring.version}</version>
        </dependency>
        <dependency>
          <groupId>org.springframework</groupId>
          <artifactId>spring-test</artifactId>
          <version>${spring.version}</version>
        </dependency>
        <!-- mybatis核心包 -->
        <dependency>
          <groupId>org.mybatis</groupId>
          <artifactId>mybatis</artifactId>
          <version>${mybatis.version}</version>
        </dependency>
        <!-- mybatis/spring包 -->
        <dependency>
          <groupId>org.mybatis</groupId>
          <artifactId>mybatis-spring</artifactId>
          <version>1.2.2</version>
        </dependency>
        <!-- 导入Mysql数据库链接jar包 -->
        <dependency>
          <groupId>mysql</groupId>
          <artifactId>mysql-connector-java</artifactId>
          <version>5.1.30</version>
        </dependency>
        <!-- 导入dbcp的jar包,用来在applicationContext.xml中配置数据库 -->
        <dependency>
          <groupId>commons-dbcp</groupId>
          <artifactId>commons-dbcp</artifactId>
          <version>1.2.2</version>
        </dependency>
        <!-- JSTL标签类 -->
        <dependency>
          <groupId>jstl</groupId>
          <artifactId>jstl</artifactId>
          <version>1.2</version>
        </dependency>
        <!-- 日志文件管理包 -->
        <!-- log start -->
        <dependency>
          <groupId>log4j</groupId>
          <artifactId>log4j</artifactId>
          <version>${log4j.version}</version>
        </dependency>
        <!-- 格式化对象,方便输出日志 -->
        <dependency>
          <groupId>com.alibaba</groupId>
          <artifactId>fastjson</artifactId>
          <version>1.1.41</version>
        </dependency>
        <dependency>
          <groupId>org.slf4j</groupId>
          <artifactId>slf4j-api</artifactId>
          <version>${slf4j.version}</version>
        </dependency>
        <dependency>
          <groupId>org.slf4j</groupId>
          <artifactId>slf4j-log4j12</artifactId>
          <version>${slf4j.version}</version>
        </dependency>
        <!-- log end -->
        <!-- 映入JSON -->
        <dependency>
          <groupId>org.codehaus.jackson</groupId>
          <artifactId>jackson-mapper-asl</artifactId>
          <version>1.9.13</version>
        </dependency>
        <!-- 上传组件包 -->
        <dependency>
          <groupId>commons-fileupload</groupId>
          <artifactId>commons-fileupload</artifactId>
          <version>1.3.1</version>
        </dependency>
        <dependency>
          <groupId>commons-io</groupId>
          <artifactId>commons-io</artifactId>
          <version>2.4</version>
        </dependency>
        <dependency>
          <groupId>commons-codec</groupId>
          <artifactId>commons-codec</artifactId>
          <version>1.9</version>
        </dependency>
        <dependency>
          <groupId>com.alibaba</groupId>
          <artifactId>druid</artifactId>
          <version>1.0.9</version>
        </dependency>
        <dependency>
          <groupId>javax</groupId>
          <artifactId>javaee-api</artifactId>
          <version>8.0</version>
          <scope>provided</scope>
        </dependency>
        <dependency>
          <groupId>org.glassfish.web</groupId>
          <artifactId>javax.servlet.jsp.jstl</artifactId>
          <version>1.2.2</version>
        </dependency>
    
    
        <dependency>
          <groupId>org.apache.storm</groupId>
          <artifactId>storm-core</artifactId>
          <version>0.9.5</version>
          <!--<scope>provided</scope>-->
        </dependency>
    
        <dependency>
          <groupId>org.apache.storm</groupId>
          <artifactId>storm-kafka</artifactId>
          <version>0.9.5</version>
          <!--<scope>provided</scope>-->
        </dependency>
    
    
        <dependency>
          <groupId>org.apache.kafka</groupId>
          <artifactId>kafka_2.11</artifactId>
          <version>0.8.2.0</version>
          <exclusions>
            <exclusion>
              <groupId>org.apache.zookeeper</groupId>
              <artifactId>zookeeper</artifactId>
            </exclusion>
            <exclusion>
              <groupId>log4j</groupId>
              <artifactId>log4j</artifactId>
            </exclusion>
          </exclusions>
        </dependency>
        <dependency>
          <groupId>mysql</groupId>
          <artifactId>mysql-connector-java</artifactId>
          <version>5.1.31</version>
        </dependency>
      </dependencies>
    
      <build>
        <finalName>neusoft</finalName>
        <resources>
          <resource>
            <directory>src/main/java</directory>
            <!-- 此配置不可缺,否则mybatis的Mapper.xml将会丢失 -->
            <includes>
              <include>**/*.xml</include>
            </includes>
          </resource>
          <!--指定资源的位置-->
          <resource>
            <directory>src/main/resources</directory>
          </resource>
        </resources>
        <pluginManagement><!-- lock down plugins versions to avoid using Maven defaults (may be moved to parent pom) -->
          <plugins>
            <plugin>
              <artifactId>maven-clean-plugin</artifactId>
              <version>3.0.0</version>
            </plugin>
            <!-- see http://maven.apache.org/ref/current/maven-core/default-bindings.html#Plugin_bindings_for_war_packaging -->
            <plugin>
              <artifactId>maven-resources-plugin</artifactId>
              <version>3.0.2</version>
            </plugin>
            <plugin>
              <artifactId>maven-compiler-plugin</artifactId>
              <version>3.7.0</version>
            </plugin>
            <plugin>
              <artifactId>maven-surefire-plugin</artifactId>
              <version>2.20.1</version>
            </plugin>
            <plugin>
              <artifactId>maven-war-plugin</artifactId>
              <version>3.2.0</version>
            </plugin>
            <plugin>
              <artifactId>maven-install-plugin</artifactId>
              <version>2.5.2</version>
            </plugin>
            <plugin>
              <artifactId>maven-deploy-plugin</artifactId>
              <version>2.8.2</version>
            </plugin>
          </plugins>
        </pluginManagement>
      </build>
    </project>
    

    3、在intellij连接数据库

    package com.neusoft
    import java.sql
    import java.sql.DriverManager
    import java.util.Date
    
    import kafka.serializer.StringDecoder
    import org.apache.spark.streaming._
    import org.apache.spark.streaming.kafka._
    import org.apache.spark.SparkConf
    /**
      * Created by Administrator on 2019/3/7.
      */
    object Kafkademo {
      def main(args: Array[String]): Unit = {
        System.setProperty("HADOOP_USER_NAME", "root")
    
        val sparkConf = new SparkConf().setAppName("DirectKafkaWordCount").setMaster("local[2]")
        val ssc = new StreamingContext(sparkConf, Seconds(5))
        ssc.checkpoint("hdfs://hadoop3:8020/spark_check_point")
        //kafka的topic集合,即可以订阅多个topic,args传参的时候用,隔开
        val topicsSet = Set("ss_kafka")
        //设置kafka参数,定义brokers集合
        val kafkaParams = Map[String, String]("metadata.broker.list" -> "192.168.159.133:9092,192.168.159.130:9092,192.168.159.134:9092")
        val messages = KafkaUtils.createDirectStream[String, String, StringDecoder, StringDecoder](
          ssc, kafkaParams, topicsSet)
        print("---------:" +messages)
    
        val lines = messages.map(_._2)
        //    val words = lines.flatMap(_.split(" "))
        //    val wordCounts = words.map(x => (x, 1)).reduceByKey(_ + _)
        //    lines.print()
    
    
    
        lines.foreachRDD(rdd => {
          //内部函数
          def func(records: Iterator[String]) {
            var conn: sql.Connection = null
            var stmt: sql.PreparedStatement = null
            try {
              val url = "jdbc:mysql://localhost:3306/test"
              val user = "root"
              val password = "root"  //笔者设置的数据库密码是hadoop,请改成你自己的mysql数据库密码
              conn = DriverManager.getConnection(url, user, password)
              //          conn.setAutoCommit(false)
    
              //          var sql = "delete from wordcount"
              //          stmt = conn.prepareStatement(sql);
              //          stmt.executeUpdate()
              //          13893556666   116.191031, 39.988585   2019-03-08 05:26:12
              records.foreach(p => {
                val arr = p.split("\\t")
                val phoneno = arr(0)
                val jingwei = arr(1)
                var arrjingwei = jingwei.split(",")
                //wei,jing
                var sql = "insert into location(time,latitude,longtitude) values (?,?,?)"
                stmt = conn.prepareStatement(sql);
                stmt.setLong(1, new Date().getTime)
                stmt.setDouble(2,java.lang.Double.parseDouble(arrjingwei(0).trim))
                stmt.setDouble(3,java.lang.Double.parseDouble(arrjingwei(1).trim))
                stmt.executeUpdate()
              })
    
    
            } catch {
              case e: Exception => e.printStackTrace()
    
            } finally {
              if (stmt != null) {
                stmt.close()
              }
              if (conn != null) {
                conn.close()
              }
            }
          }
    
          val repartitionedRDD = rdd.repartition(1)
          repartitionedRDD.foreachPartition(func)
        })
    
    
    
    
        ssc.start()
        ssc.awaitTermination()
      }
    }
    

    4、运行python脚本生成数据

    python spark.py
    

    5、查看数据库出现数据

    出现如下图所示,即为成功


    image.png

    第五步、创建热力图

    1、创建一个web新项目,使用ssm框架

    添加以下依赖

    <?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>neusoft</groupId>
      <artifactId>neusoft</artifactId>
      <version>1.0-SNAPSHOT</version>
      <packaging>war</packaging>
    
      <name>neusoft Maven Webapp</name>
      <!-- FIXME change it to the project's website -->
      <url>http://www.example.com</url>
    
      <properties>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
        <maven.compiler.source>1.8</maven.compiler.source>
        <maven.compiler.target>1.8</maven.compiler.target>
        <!-- spring版本号 -->
        <spring.version>4.0.2.RELEASE</spring.version>
        <!-- mybatis版本号 -->
        <mybatis.version>3.2.6</mybatis.version>
        <!-- log4j日志文件管理包版本 -->
        <slf4j.version>1.7.7</slf4j.version>
        <log4j.version>1.2.17</log4j.version>
      </properties>
    
      <dependencies>
        <dependency>
          <groupId>junit</groupId>
          <artifactId>junit</artifactId>
          <version>3.8.1</version>
          <scope>test</scope>
        </dependency>
        <!-- 导入java ee jar包(可以去除index.jsp报错) -->
        <dependency>
          <groupId>javax</groupId>
          <artifactId>javaee-api</artifactId>
          <version>7.0</version>
        </dependency>
        <dependency>
          <groupId>junit</groupId>
          <artifactId>junit</artifactId>
          <version>4.11</version>
          <!-- 表示开发的时候引入,发布的时候不会加载此包 -->
          <scope>test</scope>
        </dependency>
        <!-- spring核心包 -->
        <dependency>
          <groupId>org.springframework</groupId>
          <artifactId>spring-core</artifactId>
          <version>${spring.version}</version>
        </dependency>
        <dependency>
          <groupId>org.springframework</groupId>
          <artifactId>spring-web</artifactId>
          <version>${spring.version}</version>
        </dependency>
        <dependency>
          <groupId>org.springframework</groupId>
          <artifactId>spring-oxm</artifactId>
          <version>${spring.version}</version>
        </dependency>
        <dependency>
          <groupId>org.springframework</groupId>
          <artifactId>spring-tx</artifactId>
          <version>${spring.version}</version>
        </dependency>
        <dependency>
          <groupId>org.springframework</groupId>
          <artifactId>spring-jdbc</artifactId>
          <version>${spring.version}</version>
        </dependency>
        <dependency>
          <groupId>org.springframework</groupId>
          <artifactId>spring-webmvc</artifactId>
          <version>${spring.version}</version>
        </dependency>
        <dependency>
          <groupId>org.springframework</groupId>
          <artifactId>spring-aop</artifactId>
          <version>${spring.version}</version>
        </dependency>
        <dependency>
          <groupId>org.springframework</groupId>
          <artifactId>spring-context-support</artifactId>
          <version>${spring.version}</version>
        </dependency>
        <dependency>
          <groupId>org.springframework</groupId>
          <artifactId>spring-test</artifactId>
          <version>${spring.version}</version>
        </dependency>
        <!-- mybatis核心包 -->
        <dependency>
          <groupId>org.mybatis</groupId>
          <artifactId>mybatis</artifactId>
          <version>${mybatis.version}</version>
        </dependency>
        <!-- mybatis/spring包 -->
        <dependency>
          <groupId>org.mybatis</groupId>
          <artifactId>mybatis-spring</artifactId>
          <version>1.2.2</version>
        </dependency>
        <!-- 导入Mysql数据库链接jar包 -->
        <dependency>
          <groupId>mysql</groupId>
          <artifactId>mysql-connector-java</artifactId>
          <version>5.1.30</version>
        </dependency>
        <!-- 导入dbcp的jar包,用来在applicationContext.xml中配置数据库 -->
        <dependency>
          <groupId>commons-dbcp</groupId>
          <artifactId>commons-dbcp</artifactId>
          <version>1.2.2</version>
        </dependency>
        <!-- JSTL标签类 -->
        <dependency>
          <groupId>jstl</groupId>
          <artifactId>jstl</artifactId>
          <version>1.2</version>
        </dependency>
        <!-- 日志文件管理包 -->
        <!-- log start -->
        <dependency>
          <groupId>log4j</groupId>
          <artifactId>log4j</artifactId>
          <version>${log4j.version}</version>
        </dependency>
        <!-- 格式化对象,方便输出日志 -->
        <dependency>
          <groupId>com.alibaba</groupId>
          <artifactId>fastjson</artifactId>
          <version>1.1.41</version>
        </dependency>
        <dependency>
          <groupId>org.slf4j</groupId>
          <artifactId>slf4j-api</artifactId>
          <version>${slf4j.version}</version>
        </dependency>
        <dependency>
          <groupId>org.slf4j</groupId>
          <artifactId>slf4j-log4j12</artifactId>
          <version>${slf4j.version}</version>
        </dependency>
        <!-- log end -->
        <!-- 映入JSON -->
        <dependency>
          <groupId>org.codehaus.jackson</groupId>
          <artifactId>jackson-mapper-asl</artifactId>
          <version>1.9.13</version>
        </dependency>
        <!-- 上传组件包 -->
        <dependency>
          <groupId>commons-fileupload</groupId>
          <artifactId>commons-fileupload</artifactId>
          <version>1.3.1</version>
        </dependency>
        <dependency>
          <groupId>commons-io</groupId>
          <artifactId>commons-io</artifactId>
          <version>2.4</version>
        </dependency>
        <dependency>
          <groupId>commons-codec</groupId>
          <artifactId>commons-codec</artifactId>
          <version>1.9</version>
        </dependency>
        <dependency>
          <groupId>com.alibaba</groupId>
          <artifactId>druid</artifactId>
          <version>1.0.9</version>
        </dependency>
        <dependency>
          <groupId>javax</groupId>
          <artifactId>javaee-api</artifactId>
          <version>8.0</version>
          <scope>provided</scope>
        </dependency>
        <dependency>
          <groupId>org.glassfish.web</groupId>
          <artifactId>javax.servlet.jsp.jstl</artifactId>
          <version>1.2.2</version>
        </dependency>
    
    
        <dependency>
          <groupId>org.apache.storm</groupId>
          <artifactId>storm-core</artifactId>
          <version>0.9.5</version>
          <!--<scope>provided</scope>-->
        </dependency>
    
        <dependency>
          <groupId>org.apache.storm</groupId>
          <artifactId>storm-kafka</artifactId>
          <version>0.9.5</version>
          <!--<scope>provided</scope>-->
        </dependency>
    
    
        <dependency>
          <groupId>org.apache.kafka</groupId>
          <artifactId>kafka_2.11</artifactId>
          <version>0.8.2.0</version>
          <exclusions>
            <exclusion>
              <groupId>org.apache.zookeeper</groupId>
              <artifactId>zookeeper</artifactId>
            </exclusion>
            <exclusion>
              <groupId>log4j</groupId>
              <artifactId>log4j</artifactId>
            </exclusion>
          </exclusions>
        </dependency>
        <dependency>
          <groupId>mysql</groupId>
          <artifactId>mysql-connector-java</artifactId>
          <version>5.1.31</version>
        </dependency>
      </dependencies>
    
      <build>
        <finalName>neusoft</finalName>
        <resources>
          <resource>
            <directory>src/main/java</directory>
            <!-- 此配置不可缺,否则mybatis的Mapper.xml将会丢失 -->
            <includes>
              <include>**/*.xml</include>
            </includes>
          </resource>
          <!--指定资源的位置-->
          <resource>
            <directory>src/main/resources</directory>
          </resource>
        </resources>
        <pluginManagement><!-- lock down plugins versions to avoid using Maven defaults (may be moved to parent pom) -->
          <plugins>
            <plugin>
              <artifactId>maven-clean-plugin</artifactId>
              <version>3.0.0</version>
            </plugin>
            <!-- see http://maven.apache.org/ref/current/maven-core/default-bindings.html#Plugin_bindings_for_war_packaging -->
            <plugin>
              <artifactId>maven-resources-plugin</artifactId>
              <version>3.0.2</version>
            </plugin>
            <plugin>
              <artifactId>maven-compiler-plugin</artifactId>
              <version>3.7.0</version>
            </plugin>
            <plugin>
              <artifactId>maven-surefire-plugin</artifactId>
              <version>2.20.1</version>
            </plugin>
            <plugin>
              <artifactId>maven-war-plugin</artifactId>
              <version>3.2.0</version>
            </plugin>
            <plugin>
              <artifactId>maven-install-plugin</artifactId>
              <version>2.5.2</version>
            </plugin>
            <plugin>
              <artifactId>maven-deploy-plugin</artifactId>
              <version>2.8.2</version>
            </plugin>
          </plugins>
        </pluginManagement>
      </build>
    </project>
    

    2、配置web.xml

    <?xml version="1.0" encoding="UTF-8"?>
    <web-app xmlns="http://xmlns.jcp.org/xml/ns/javaee"
             xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
             xsi:schemaLocation="http://xmlns.jcp.org/xml/ns/javaee http://xmlns.jcp.org/xml/ns/javaee/web-app_3_1.xsd"
             version="3.1">
        <!--  tomcat服务器,一启动马上读取spring/applicationContext-*.xml-->
        <servlet>
            <servlet-name>springDispatcherServlet</servlet-name>
            <servlet-class>org.springframework.web.servlet.DispatcherServlet</servlet-class>
            <init-param>
                <param-name>contextConfigLocation</param-name>
                <param-value>classpath:spring/springmvc.xml</param-value>
            </init-param>
            <load-on-startup>1</load-on-startup>
        </servlet>
    
        <servlet-mapping>
            <servlet-name>springDispatcherServlet</servlet-name>
            <url-pattern>/</url-pattern>
        </servlet-mapping>
    </web-app>
    
    

    3、创建资源目录

    在main下面创建一个资源目录resources
    在该资源目录下创建一个spring文件夹
    在spring文件夹下面创建一个springmv.xml文件
    代码如下:

    <?xml version="1.0" encoding="UTF-8"?>
    <beans xmlns="http://www.springframework.org/schema/beans"
           xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
           xmlns:context="http://www.springframework.org/schema/context"
           xmlns:mvc="http://www.springframework.org/schema/mvc"
           xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
             http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-4.0.xsd
             http://www.springframework.org/schema/mvc http://www.springframework.org/schema/mvc/spring-mvc-4.0.xsd">
    
        <!-- 配置视图解析器 如何把handler 方法返回值解析为实际的物理视图 -->
        <bean class="org.springframework.web.servlet.view.InternalResourceViewResolver">
            <property name="prefix" value="/WEB-INF/jsp/"/>
            <property name="suffix" value=".jsp"></property>
        </bean>
        <!-- 文件上传 -->
        <bean id="multipartResolver" class="org.springframework.web.multipart.commons.CommonsMultipartResolver">
            <property name="maxUploadSize" value="10000000"></property>
            <property name="defaultEncoding" value="UTF-8"></property>
        </bean>
    
        <!-- 配置自动扫描的包 -->
        <context:component-scan base-package="com.neusoft.controller"></context:component-scan>
    
    </beans>
    

    4、写后台代码

    1)、创建com.neusoft.util包

    然后创建MysqlUtil类

    package com.neusoft.util;
    
    
    import java.sql.Connection;
    import java.sql.DriverManager;
    import java.sql.PreparedStatement;
    import java.sql.ResultSet;
    
    public class MysqlUtil {
        private static final String DRIVER_NAME="jdbc:mysql://localhost:3306/test?user=root&password=root";
        private static Connection connection;
        private static PreparedStatement pstm;
        private static ResultSet resultSet;
    
        public static Connection getConnection(){
            try {
                Class.forName("com.mysql.jdbc.Driver");
                connection=DriverManager.getConnection(DRIVER_NAME);
            }catch (Exception e){
                e.printStackTrace();
            }
            return connection;
        }
        public static void release(){
            try {
                if(resultSet!=null) {
                    resultSet.close();
                }
                if (pstm != null) {
                    pstm.close();
                }
                if(connection!=null){
                    connection.close();
                }
            }catch (Exception e){
                e.printStackTrace();
            }finally {
                if(connection!=null){
                    connection=null;    //help GC
                }
            }
        }
    
    }
    
    
    2)、创建com.neusoft.domain包

    然后创建Location类

    package com.neusoft.domain;
    
    /**
     * Created by Administrator on 2019/3/11.
     */
    public class Location {
        private Integer count;
        private double latitude;
        private double longitude;
    
        public Integer getCount() {
            return count;
        }
        public void setCount(Integer count) {
            this.count = count;
        }
        public double getLatitude() {
            return latitude;
        }
        public void setLatitude(double latitude) {
            this.latitude = latitude;
        }
        public double getLongitude() {
            return longitude;
        }
        public void setLongitude(double longitude) {
            this.longitude = longitude;
        }
    }
    
    
    
    3)、创建com.neusoft.dao包

    然后创建LocationDao类

    package com.neusoft.dao;
    
    import com.neusoft.domain.Location;
    import com.neusoft.util.MysqlUtil;
    import org.springframework.stereotype.Component;
    
    import java.sql.Connection;
    import java.sql.PreparedStatement;
    import java.sql.ResultSet;
    import java.util.ArrayList;
    import java.util.List;
    
    /**
     * Created by Administrator on 2019/3/11.
     */
    @Component
    public class LocationDao {
    
        private static MysqlUtil mysqlUtil;
    
        public List<Location> map() throws Exception{
            List<Location> list = new ArrayList<Location>();
            Connection connection=null;
            PreparedStatement psmt=null;
            try {
                connection = MysqlUtil.getConnection();
                psmt = connection.prepareStatement("select latitude,longtitude,count(*) num from location where "
                        + "time>unix_timestamp(date_sub(current_timestamp(),interval 20second))*1000 "
                        + "group by longtitude,latitude");
                ResultSet resultSet = psmt.executeQuery();
                while (resultSet.next()) {
                    Location location = new Location();
                    location.setLongitude(resultSet.getDouble(1));
                    location.setLatitude(resultSet.getDouble(2));
                    location.setCount(resultSet.getInt(3));
                    list.add(location);
                }
            }catch (Exception e){
                e.printStackTrace();
            }finally {
                MysqlUtil.release();
            }
            return list;
        }
    
    }
    
    4)、创建com.neusoft.controller包

    然后创建 HomeController类

    package com.neusoft.controller;
    
    import com.alibaba.fastjson.JSON;
    import com.neusoft.dao.LocationDao;
    import org.springframework.stereotype.Controller;
    import org.springframework.web.bind.annotation.RequestMapping;
    import org.springframework.web.servlet.ModelAndView;
    
    import javax.servlet.http.HttpServletResponse;
    
    /**
     * Created by Administrator on 2019/3/11.
     */
    @Controller
    public class HomeController {
    
    
        @RequestMapping("/")
        public ModelAndView home()
        {
            ModelAndView modelAndView = new ModelAndView();
    
            modelAndView.setViewName("index");
            return modelAndView;
        }
        @RequestMapping("/get_map")
        public void getMap(HttpServletResponse response) throws Exception{
            System.out.println("getMap");
            LocationDao locationDao = new LocationDao();
            String json = JSON.toJSONString(locationDao.map());
            response.getWriter().print(json);
        }
    }
    
    5)、修改index页面

    改成固定时间自动刷新ajax

    <%--
      Created by IntelliJ IDEA.
      User: ttc
      Date: 2018/7/6
      Time: 14:06
      To change this template use File | Settings | File Templates.
    --%>
    <%@ page contentType="text/html;charset=UTF-8" language="java" %>
    <!DOCTYPE html>
    <html lang="en">
    <head>
        <meta charset="UTF-8"/>
        <title>高德地图</title>
        <link rel="stylesheet" href="http://cache.amap.com/lbs/static/main1119.css"/>
    </head>
    <body>
    <script src="https://cdn.bootcss.com/echarts/4.1.0.rc2/echarts.min.js"></script>
    <script src="https://cdn.bootcss.com/jquery/3.3.1/jquery.min.js"></script>
    <script src="http://webapi.amap.com/maps?v=1.4.9&amp;key=d16808eab90b7545923a1c2f4bb659ef"></script>
    <div id="container"></div>
    
    <script>
        var map = new AMap.Map("container", {
            resizeEnable: true,
            center: [123.453169, 41.742567],
            zoom: 17
        });
    
        var heatmap;
        map.plugin(["AMap.Heatmap"],function() {      //加载热力图插件
            heatmap = new AMap.Heatmap(map,{
                raduis:50,
                opacity:[0,0.7]
            });    //在地图对象叠加热力图
            //具体参数见接口文档
        });
        setInterval(function (args) {
            var points =(function a(){  //<![CDATA[
                var city=[];
                $.ajax({
                    type:"POST",
                    url:"${pageContext.request.contextPath}/get_map",
                    dataType:'json',
                    async:false,        //
                    success:function(result){
                        for(var i=0;i<result.length;i++){
                            //alert("调用了");
                            city.push({"lng":result[i].longitude,"lat":result[i].latitude,"count":result[i].count});
                        }
    
                    }
                })
                return city;
            })();//]]>
            heatmap.setDataSet({data:points,max:30}); //设置热力图数据集
        },1000)
    
    
        // var map = new AMap.Map('container', {
        //    pitch:75, // 地图俯仰角度,有效范围 0 度- 83 度
        //    viewMode:'3D' // 地图模式
        //});
    </script>
    
    </body>
    </html>
    
    6)、修改python自动生成数据脚本
    import random
    import os
    import sys
    import time
    import numpy as np
    
    
    def genertor():
        Point=[random.uniform(123.449169,123.458654),random.uniform(41.740567,41.743705)]
        arr = []
        for i in range(1, random.randint(0, 500)):
            bias = np.random.randn() * pow(10,-4)
        bias = round(bias,4)
            X = Point[0] + bias
            bias1 = np.random.randn() * pow(10,-4)
        bias1 = round(bias,4)
            Y = Point[1] + bias
        time_str=time.strftime("%Y-%m-%d %H:%M:%S",time.localtime())
            arr.append(['13888888888'+'\t',str(X)+',', str(Point[1])+'\t',time_str])
        return arr
    
    
    if __name__ == '__main__':
        path = sys.argv[1]
        if not os.path.isfile(path):
            open(path, 'w')
        with open(path,'a') as f:
            while True:
                arr = genertor()
                for i in range(len(arr)):
                    f.writelines(arr[i])
                    f.write('\n')
                time.sleep(5)
    
    7)、 centos6.9安装/升级到python2.7并安装pip

    https://www.jianshu.com/p/1f78757f9e07

    最后,启动tomcat服务器,数据就谁显示在页面上了

    相关文章

      网友评论

        本文标题:flume+kafka+Spark+mysql+ssm+高德地图

        本文链接:https://www.haomeiwen.com/subject/zmtrpqtx.html