“is 百脑汇”项目上线以来，我们在不断挖掘小伙伴们的奇思妙想，也在接收各方的优秀内容，希望大家持续保持产出热情，不断学习不断进步哦！
我们将在这里分享来自指令集小伙伴们的行业经验、技术讨论，构建一个高品质的交流平台。在这里，你可以开启物联网奥秘的大门；在这里，可以点燃技术起飞的引信。
is 百脑汇
????历史文章分享，常读常新。
《Kotlin x Nodejs》的具体操作方法
今天的分享依然来自重庆研发团队的何晓杰同学：“Springboot + Kotlin 实现 WebSocket”
自从 springboot 官方引入 kotlin 的支持后，一切又变得方便了很多，以前我们需要先弄出一个 java 项目，然后加入 kotlin 的支持，而现在，直接 kotlin 覆盖了全部的东西。
那么这一篇就带大家来玩一下如何用 springboot + kotlin 来构建 websocket 应用。在这里我们用的 springboot 版本是 2.2.5，对应的 kotlin 版本为 1.3.61，在此特别需要注意的是，我们应当使用 org.springframework.boot:spring-boot-dependencies 来整体更新依赖版本，如果单独更新某个依赖，会发生不兼容的情况。如果需要使用 Kotlin 1.3.72 版本，则需要更新 springboot 到 2.3.1。
建好项目后，添加 websocket 的依赖:
dependencies { ... ... implementation 'org.springframework.boot:spring-boot-starter-websocket:2.2.5.RELEASE' }注意此处版本号，要与 springboot 版本号一致。
然后我们可以很轻松的在 springboot 里建立起一个 WebSocket 服务:
@Component open class SocketController : WebSocketHandler { init { println("SocketController init") } override fun handleTransportError(session: WebSocketSession, t: Throwable) { println("handleTransportError") } override fun afterConnectionClosed(session: WebSocketSession, cs: CloseStatus) { println("afterConnectionClosed") } override fun handleMessage(session: WebSocketSession, message: WebSocketMessage<*>) { println("handleMessage: $message") session.sendMessage(RESPONSE_MESSAGE.toMessage()) } override fun afterConnectionEstablished(session: WebSocketSession) { println("afterConnectionEstablished") } override fun supportsPartialMessages() = false }其中对于 handleMessage 方法，将发送返回数据，此处有一个扩展，即是将字符串包装为 WebSocketMessage 对象，实现如下:
fun String.toMessage() = TextMessage(this)下一步我们需要将服务暴露出来，使得前端可以访问到它:
@Configuration @EnableWebSocket open class WebSocketConfig: WebSocketConfigurer { private fun getSocketHandler(): WebSocketHandler = SocketController() override fun registerWebSocketHandlers(registry: WebSocketHandlerRegistry) { registry.addHandler(getSocketHandler(), "/ws").setAllowedOrigins("*") } }注意加入 @EnableWebSocket 注解，同时还需要注意，由于注解的存在，所以 class 必须是open 的，不然会产生 注解标注于 final class 的异常。
然后我们可以直接把项目跑起来，看到以下日志时，说明 WebSocket 已经正常工作了。
INFO 48488 --- [main] c.i.boot.web.monitor.MonitorAspect : Boot Monitor-void com.rarnu.sample.socket.WebSocketConfig.registerWebSocketHandlers(WebSocketHandlerRegistry)，in：4ms接着来实现客户端，这里分两种实现方式，先来看看用 kotlin 怎么做吧:
@ClientEndpoint class SocketClient(uri: URI,val openHandler: () -> Unit,val closeHandler: () -> Unit,val errorHandler: (t: Throwable) -> Unit,val msgHandler:(msg: String) -> Unit) { private var session: Session? = null init { try { val container = ContainerProvider.getWebSocketContainer() container.connectToServer(this, uri) } catch (th: Throwable) { throw RuntimeException(th) } } @OnOpen fun onOpen(session: Session) { this.session = session openHandler() } @OnClose fun onClose(session: Session, reason: CloseReason) { this.session = null closeHandler() } @OnMessage fun onMessage(message: String) { msgHandler(message) } @OnError fun onError(t: Throwable) { errorHandler(t) } fun sendMessage(message: String) { session?.basicRemote?.sendText(message) } } class SocketIO { private var endPoint: SocketClient? = null private var timerHeartbeat: Timer? = null private var working = false init { endPoint = SocketClient(URI("ws://127.0.0.1:9011/ws"), { // open callback startHeartHeat() }, { // close callback working = false }, { // error callback println("SocketIO Error: $it") }, { // message callback println("received: $it") }) } } private fun startHeartHeat() { working = true timerHeartbeat = Timer("_socket_heartbeat_") timerHeartbeat?.schedule(timerTask { if (!working) { this.cancel() timerHeartbeat?.cancel() timerHeartbeat = null return@timerTask } endPoint?.sendMessage(MSG_HEARTBEAT) }, 0, 10000L) } }这里启用了一个简单的心跳包机制，来确保服务不断。
再来个 js 的调用方法，也很简单:
<script type="text/javascript"> let ws = new WebSocket("ws://127.0.0.1:9011/ws"); ws.onopen = function (event) { console.log("Opened."); } ws.onmessage = function (msg) { console.log(msg.data); } ws.onclose = function (event) { console.log("Closed.") } function sendText() { let txt = $("#txt").value; ws.send(txt); } </script>当然了，springboot 集成 WebSocket 还有很多方法，比如用 @ServerEndpoint 注解来完成，又或者是集成一些第三方的框架，但是不论如何我们都能实现功能，那么下面就剩设计一个靠谱的数据传输协议了。
本期分享就到这里了，我们下期再见。
指令集招聘
如果你也是一个有想法、有追求，想要实现个人价值的优秀人才，我们随时敞开大门欢迎你！最新招聘信息，请扫描下方二维码获取。
与指令集一起乘风破浪吧！
指令集招聘公众号
