版本說明：

spring boot：2.5.9

jdk：1.8

spark：2.4.5

sclala：2.11.12

首先你需要有一個完美的spring boot項(xiàng)目（java版本）能成功運(yùn)行，這就不贅述了，按照網(wǎng)上的自己搭建吧，然后重要的來了，我搗鼓了兩天時間，各樣的報錯見過了，網(wǎng)上的處理方法要嘛是不全，要嘛是沒有用，各種辦法都試過，我只分享我成功后的配置，

xml配置添加：（scala環(huán)境和spark環(huán)境）

在原有的<dependencies>依賴?yán)锩嫣砑酉旅娴囊蕾嚕缓笤?lt;plugins>里面添加scala編譯依賴，不然編譯不通過，會報錯找不到符號

        <dependency>
            <groupId>org.scala-lang</groupId>
            <artifactId>scala-library</artifactId>
            <version>2.11.12</version>
        </dependency>
        <dependency>
            <groupId>org.apache.spark</groupId>
            <artifactId>spark-core_2.11</artifactId>
            <version>2.4.5</version>
        </dependency>

            <!--            加入Scala的編譯插件，否則無法進(jìn)行編譯-->
            <plugin>
                <groupId>org.scala-tools</groupId>
                <artifactId>maven-scala-plugin</artifactId>
                <version>2.15.2</version>
                <executions>
                    <execution>
                        <goals>
                            <goal>compile</goal>
                            <goal>testCompile</goal>
                        </goals>
                    </execution>
                </executions>
            </plugin>

service層，注意前端調(diào)用scala接口，那么scala服務(wù)的所有代碼都需要用scala代碼編寫，不能跟java代碼混編（會報錯：包導(dǎo)入成功了但是運(yùn)行時報錯找不到包）

scala service層測試代碼

package com.jack.graduation.service

import org.apache.spark.rdd.RDD
import org.apache.spark.{SparkConf, SparkContext}
import org.springframework.stereotype.Service


@Service
class TestService {
  def test(): Boolean = {
    true
  }

  def wc(): Map[String, Int] = {
    val sparkConf: SparkConf = new SparkConf()
      .set("spark.driver.host", "myword")
      .setAppName("test_scala")
      .setMaster("local[*]")
    val sc = new SparkContext(sparkConf)

    val fileRDD: RDD[String] = sc.textFile("D:/idea2020/IdeaProjects/graduation/src/main/resources/files/a.txt")
    val tempRDD: RDD[String] = fileRDD.flatMap(_.split(" "))
    val mapRDD: RDD[(String, Int)] = tempRDD.map((_, 1))
    val map: Map[String, Int] = mapRDD.reduceByKey(_ + _).collect().toMap
    println("testmap"+map)
    sc.stop()
    map
  }
}

scala controller層測試代碼

package com.jack.graduation.controller


import com.jack.graduation.service.TestService
import javax.annotation.Resource
import org.springframework.web.bind.annotation._

/**
 *
 * @param test
 */
@RestController
@RequestMapping(Array("/sparkCon"))
class CustomerController @Resource()(test: TestService) {
  @GetMapping(Array("/test"))
  def test(): String = {
    val bool: Boolean = test.test()
    println(bool)
    "hello scala"
  }

  @GetMapping(Array("/wc"))
  def wcTest(): Boolean = {
    val stringToInt: Map[String, Int] = test.wc()
    println("wcmap" + stringToInt)
    stringToInt.nonEmpty
  }
}

注意上面的服務(wù)層代碼的導(dǎo)入方式： @Resource()(test: TestService)，如果通過@Autowired會報錯

途中碰到各種困難，可以嘗試以下方法

1. maven先clean

2. 然后install

3. 然后重啟idea

也可重新編譯代碼文章來源地址http://www.zghlxwxcb.cn/news/detail-497140.html