Scala代码模拟手游上报数据

àì夳堔傛蜴生んèń 2021-09-23 06:40 240阅读 0赞

> 业务场景：模拟手游cp上报数据用于测试，分为角色升级role\_rank数据和金钱改变money\_flow数据。

Maven项目

com.job.logcollector.LogCollector

Maven依赖

<properties>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
        <slf4j.version>1.7.28</slf4j.version>
        <logback.version>1.2.3</logback.version>
      </properties>
    
      <dependencies>
        <dependency>
          <groupId>org.scala-lang</groupId>
          <artifactId>scala-library</artifactId>
          <version>2.11.12</version>
        </dependency>
        
        <dependency>
          <groupId>com.alibaba</groupId>
          <artifactId>fastjson</artifactId>
          <version>1.2.58</version>
        </dependency>
        
        <dependency>
          <groupId>ch.qos.logback</groupId>
          <artifactId>logback-core</artifactId>
          <version>${logback.version}</version>
        </dependency>
        <dependency>
          <groupId>ch.qos.logback</groupId>
          <artifactId>logback-classic</artifactId>
          <version>${logback.version}</version>
        </dependency>
      </dependencies>
    
      
      <build>
        <plugins>
          <plugin>
            <groupId>net.alchim31.maven</groupId>
            <artifactId>scala-maven-plugin</artifactId>
            <version>3.2.2</version>
            <executions>
              <execution>
                <id>scala-compile-first</id>
                <phase>process-resources</phase>
                <goals>
                  <goal>add-source</goal>
                  <goal>compile</goal>
                </goals>
              </execution>
            </executions>
          </plugin>
          <plugin>
            <artifactId>maven-compiler-plugin</artifactId>
            <version>3.6.1</version>
            <configuration>
              <source>1.8</source>
              <target>1.8</target>
            </configuration>
          </plugin>
          <plugin>
            <artifactId>maven-assembly-plugin</artifactId>
            <configuration>
              <descriptorRefs>
                <descriptorRef>jar-with-dependencies</descriptorRef>
              </descriptorRefs>
            </configuration>
            <executions>
              <execution>
                <id>make-assembly</id>
                <phase>package</phase>
                <goals>
                  <goal>single</goal>
                </goals>
              </execution>
            </executions>
          </plugin>
        </plugins>
      </build>

Logback配置文件 logback.xml，放在resources下。

<?xml version="1.0" encoding="UTF-8"?>
    <configuration debug="false">
        
        <property name="LOG_HOME" value="/data3/logs/cp_api" />
    
        
        <appender name="STDOUT"
                  class="ch.qos.logback.core.ConsoleAppender">
            <encoder
                    class="ch.qos.logback.classic.encoder.PatternLayoutEncoder">
                
                <pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %-5level %logger{50} - %msg%n</pattern>
            </encoder>
        </appender>
    
        
        <appender name="FILE"
                  class="ch.qos.logback.core.rolling.RollingFileAppender">
            
            <rollingPolicy
                    class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
                
                <FileNamePattern>${LOG_HOME}/cp-api%d{yyyy-MM-dd}.log</FileNamePattern>
                
                <MaxHistory>30</MaxHistory>
            </rollingPolicy>
            <encoder
                    class="ch.qos.logback.classic.encoder.PatternLayoutEncoder">
                <pattern>%msg%n</pattern>
            </encoder>
            
            <triggeringPolicy
                    class="ch.qos.logback.core.rolling.SizeBasedTriggeringPolicy">
                <MaxFileSize>10MB</MaxFileSize>
            </triggeringPolicy>
        </appender>
    
        
        <appender name ="ASYNC_FILE" class= "ch.qos.logback.classic.AsyncAppender">
            
            <discardingThreshold >0</discardingThreshold>
            
            <queueSize>512</queueSize>
            
            <appender-ref ref = "FILE"/>
        </appender>
    
        
        <root level="INFO">
            <appender-ref ref="STDOUT" />
            <appender-ref ref="ASYNC_FILE" />
            <appender-ref ref="error" />
        </root>
    </configuration>

**Bean文件**

EventBean，区分事件类型和事件产生时间。

case class EventBean() extends Serializable {
      @BeanProperty var event_time : String = _
      @BeanProperty var event_name : String = _
    
      // override def toString: String = "event_time:" + event_time + "," + "event_name:" + event_name
    }

MoneyFlowBean，金钱改变时间内容。

case class MoneyFlowBean() extends Serializable {
      @BeanProperty var game_server:Int = _                         //区服id
      @BeanProperty var role_id:String = _	                	// 角色id
      @BeanProperty var role_name:String = _			// 角色名
      @BeanProperty var role:String = _		                // 角色职业
      @BeanProperty var school:String = _	  			// 角色门派
      @BeanProperty var combat:Int = _    				// 角色战斗力
      @BeanProperty var role_vip:Int = _		  		// 角色vip等级
      @BeanProperty var role_rank:Int = _	  			// 角色等级
      @BeanProperty var item_id:String = _		        	// 物品名称
      @BeanProperty var count:Int = _   	  			// 物品变化数量
      @BeanProperty var after_count:Int = _    		        // 动作后的物品存量
      @BeanProperty var money_type:String = _		        // 变动时金钱的类型
      @BeanProperty var money:Int = _	  		    	// 变动时获得或消耗的金钱
      @BeanProperty var after_money:Int = _    	            	// 动作后的金钱数
      @BeanProperty var add_or_rduce:Int = _		        // 变动类型：0为增加 1为减少
      @BeanProperty var reason:String = _	  		        // 金钱流动原因
      @BeanProperty var sub_reason:String = _	          	// 金钱流动细节原因
    }

RoleRankBean，等级改变数据内容。

case class RoleRankBean() extends Serializable {
      @BeanProperty var game_server:Int = _                         //区服id
      @BeanProperty var role_id:String = _	                        // 角色id
      @BeanProperty var role_name:String = _	  	        // 角色名
      @BeanProperty var role:String = _		  		// 角色职业
      @BeanProperty var school:String = _	  			// 角色门派
      @BeanProperty var combat:Int = _    				// 角色战斗力
      @BeanProperty var role_vip:Int = _		  		// 角色vip等级
      @BeanProperty var before_rank:Int = _				// 升级前等级
      @BeanProperty var role_rank:Int = _  		            	// 升级后等级（即当前等级）
    }

LogCollector ，模拟生产数据的主类。

/**
      * 模拟数据生成类
      * args 0  延迟,默认0
      * args 1  生成条数,默认100
      */
    
    object LogCollector {
      private val logger = LoggerFactory.getLogger("LogCollector")
      private val rand = new Random()
    
      def main(args: Array[String]): Unit = {
    
        // 参数一：控制生成每条数据的延迟，默认0
        val delay = if (args.length > 0) args(0).toLong else 0L
    
        // 参数二：循环遍历次数
        val loop_len = if (args.length > 1) args(1).toInt else 1000
    
        // 生成数据
        generateLog(delay, loop_len)
      }
    
      /**
        * 生成数据方法
        */
      def generateLog(delay: Long, loop_len: Int): Unit = {
    
        for (i <- 0 to loop_len) {
    
          print(i + "======>")
    
          val flag = rand.nextInt(2)
    
          flag match {
            case 0 =>
              val eventsArray = new JSONArray
              if (rand.nextBoolean) {
                // 角色升级
                eventsArray.add(getRoleRank)
              } else {
                // 角色金钱改变
                eventsArray.add(getMoneyFlow)
              }
              //控制台打印
              logger.info(eventsArray.toJSONString)
            case 1 =>
              val eventsArray = new JSONArray
              if (rand.nextBoolean) {
                // 角色升级
                eventsArray.add(getRoleRank)
              } else {
                // 角色金钱改变
                eventsArray.add(getMoneyFlow)
              }
              //控制台打印
              logger.info(eventsArray.toJSONString)
          }
          // 延迟
          try
            Thread.sleep(delay)
          catch {
            case e: InterruptedException =>
              e.printStackTrace()
          }
        }
      }
    
      /**
        * 设置事件,并拼接所有属性(game_id,事件,角色信息)
        */
      def packEventJson(eventName: String, json: JSON):JSONObject = {
        val packJson = new JSONObject(true)
    
        // 拼接cp_game_id
        val cp_game_id = rand.nextInt(19)
    
        // 拼接事件
        val eventBean = EventBean()
        eventBean.event_time = System.currentTimeMillis - rand.nextInt(99999999) + ""
        eventBean.event_name = eventName
    
        val eventJson = JSON.toJSON(eventBean).asInstanceOf[JSONObject]
    
        packJson.put("cp_game_id", cp_game_id)
        packJson.put("event", eventJson)
        packJson.put("data", json)
    
        packJson
      }
    
      /**
        * 角色升级事件
        */
      def getRoleRank: JSONObject = {
        val roleRank = RoleRankBean()
        roleRank.game_server = rand.nextInt(9999)
        roleRank.role_id = rand.nextInt(99999).toString
        roleRank.role_name = getContent
        roleRank.role = getRole
        roleRank.school = getSchool
        roleRank.combat = rand.nextInt(99999)
        roleRank.role_vip = rand.nextInt(10)
        roleRank.before_rank = rand.nextInt(199)
        roleRank.role_rank = roleRank.before_rank + rand.nextInt(5)
    
        val roleJson = JSON.toJSON(roleRank).asInstanceOf[JSONObject]
    
        packEventJson("role_rank", roleJson)
      }
    
      /**
        * 角色金钱改变事件
        */
      def getMoneyFlow: JSONObject = {
        val moneyFlow = MoneyFlowBean()
        moneyFlow.game_server = rand.nextInt(9999)
        moneyFlow.role_id = rand.nextInt(99999).toString
        moneyFlow.role_name = getContent
        moneyFlow.role = getRole
        moneyFlow.school = getSchool
        moneyFlow.combat = rand.nextInt(99999)
        moneyFlow.role_vip = rand.nextInt(10)
        moneyFlow.role_rank = rand.nextInt(199)
        moneyFlow.item_id = getItem
        moneyFlow.count = rand.nextInt(100)
        moneyFlow.after_count = rand.nextInt(1000)
        moneyFlow.money_type = getMoneyType
        moneyFlow.money = rand.nextInt(9999)
        moneyFlow.after_money = rand.nextInt(99999)
        moneyFlow.add_or_rduce = {
          val i = rand.nextInt(1)
          if (i == 0) 0 else 1
        }
        moneyFlow.reason = getReason
        moneyFlow.sub_reason = getSubReason
    
        val moneyJson = JSON.toJSON(moneyFlow).asInstanceOf[JSONObject]
    
        packEventJson("money_flow", moneyJson)
      }
    
      /**
        * 生成单个汉字
        */
      def getRandomChar: Char = {
        var str: String = ""
        var highPos: Int = 0
        var lowPos: Int = 0
    
        // 随机生成汉字的两个字节
        highPos = Math.abs(rand.nextInt(39)) + 176
        lowPos = Math.abs(rand.nextInt(93)) + 161
    
        val bys = new Array[Byte](2)
        bys(0) = highPos.toByte
        bys(1) = lowPos.toByte
    
        try {
          str = new String(bys, "GBK")
        } catch {
          case e: UnsupportedOperationException =>
            e.printStackTrace()
            println("编码错误")
        }
    
        str.charAt(0)
      }
    
      /**
        * 拼接多个汉字
        */
      def getContent: String = {
        val stringBuffer = new StringBuffer
        for (i <- 0 until rand.nextInt(6)) {
          stringBuffer.append(getRandomChar)
        }
        stringBuffer.toString
      }
    
      /**
        * 职业
        */
      def getRole: String = {
        var role: String = ""
        val array = Array("法师", "狂暴战士", "刺客")
        role = array(rand.nextInt(3))
        role
      }
    
      /**
        * 门派
        */
      def getSchool: String = {
        var school: String = ""
        val array = Array("玄策", "隐士", "唐门")
        school = array(rand.nextInt(3))
        school
      }
    
      /**
        * 物品名称
        */
      def getItem: String = {
        var item: String = ""
        val array = Array("草药", "装备", "神器")
        item = array(rand.nextInt(3))
        item
      }
    
      /**
        * 变动时金钱的类型
        */
      def getMoneyType: String = {
        var moneyType: String = ""
        val array = Array("钻石", "金币", "铜币")
        moneyType = array(rand.nextInt(3))
    
        moneyType
      }
    
      /**
        * 金钱流动原因
        */
      def getReason: String = {
        var reason: String = ""
        val array = Array("商城道具", "邮件领取奖励", "战斗消耗")
        reason = array(rand.nextInt(3))
        reason
      }
    
      /**
        * 金钱流动原因
        */
      def getSubReason: String = {
        var subReason: String = ""
        val array = Array("道具消耗", "购买宠物", "战斗药水消耗")
        subReason = array(rand.nextInt(3))
        subReason
      }
    }

打包，上传，执行

java -cp logcollector-1.0-SNAPSHOT-jar-with-dependencies.jar com.sm.logcollector.LogCollector

数据位置根据 logback.xml设置 /data3/logs/cp\_api/

![20190903160723322.png][]

[20190903160723322.png]: /images/20210923/b3b453a420ba40949bfa2fadf0693356.png