序：

        官方给的node对接火星的demo其实只适用于node开发的web应用，但是对于纯node 作为服务端，也就是作为webapi来调用，你会发现，location.host直接是获取不到location的。这个时候，其实要单独起个wss的服务的，关于这点，雪狼写了本篇教程，

        1、博主的node：v18.12.1

        2、ws：v8.14.1（WebSocket）

        3、CryptoJS：4.0.0

正文：

1.、来首先我们安装依赖，下面两个命令

cnpm install crypto-js@4.0.0 -S

cnpm install ws@8.14.1 -S

2、引入

import WebSocket from "ws";
import CryptoJS from 'crypto-js'

3、写初始化url

function getWebsocketUrl(){
	    return new Promise((resolve, reject) => {
	        var apiKey = "你的apiKey"
	        var apiSecret = "你的apiSecret"
	        var url = 'wss://spark-api.xf-yun.com/v1.1/chat'
	        var host = "localhost:8001"
	        var date = new Date().toGMTString()
	        var algorithm = 'hmac-sha256'
	        var headers = 'host date request-line'
	        var signatureOrigin = `host: ${host}\ndate: ${date}\nGET /v1.1/chat HTTP/1.1`
	        var signatureSha = CryptoJS.HmacSHA256(signatureOrigin, apiSecret)
	        var signature = CryptoJS.enc.Base64.stringify(signatureSha)
	        var authorizationOrigin = `api_key="${apiKey}", algorithm="${algorithm}", headers="${headers}", signature="${signature}"`
	        var authorization = btoa(authorizationOrigin)
	        url = `${url}?authorization=${authorization}&date=${date}&host=${host}`
	        resolve(url)
	    })
	}

注意，这里localhost:8001你直接写8001!，后续你调试直接监听这个端口接口

4、开始监听

function wsFun(userSay,callback){
		getWebsocketUrl().then(url => {
			
			let ws = new WebSocket(url);
			ws.on('error', console.error);
			ws.on('open', function open() {
			  var params = {
			      "header": {
			          "app_id":"你的app_id",//这里记得替换app_id
			          "uid": "fd3f47e4-d"
			      },
			      "parameter": {
			          "chat": {
			              "domain": "general",
			              "temperature": 0.5,
			              "max_tokens": 1024
			          }
			      },
			      "payload": {
			          "message": {
			              "text": [
			                  {
			                      "role": "user",
			                      "content": userSay
			                  }
			              ]
			          }
			      }
			  }
			  ws.send(JSON.stringify(params))
			});
			ws.on('close', function close() {
			  
			});
			ws.on('message', function message(data) {
				var msgData=JSON.parse(data)
				if (msgData.header.code !== 0) {
					callback("提问失败",2)
				}else{
					callback(msgData.payload.choices.text[0].content,msgData.header.status)// 这个就是返回啦
				}
			});

		})
		
	}
wsFun("你好啊");

5、断点运行代码

$ node --inspect-brk=8001 index.js

注意，这个8001就是咱刚host写的端口， message里面是火星的回复，大家可以自行监听并回调

#程序员干货  #人间清醒  #前端回忆录  #争议话题  #程序员圈子热点