Postman 调用将 https：//supplab-callpostappapi-supplab.cn1.mindsphere-in.cn/api/datasource-supplab/v1/updateValue 接口地址复制到 postman 地址栏中, 将 cockie 和 X-XSRF-TOKEN 添加到 headers 中, 从 cockie 中取出 XSRF-TOKEN 值和SESSION 值添加到 headers 中设置 Cockie 参数值和 X-XSRF-TOKEN 参数值{X-XSRF-TOKEN：XSRF-TOKEN}；{Cockie：SESSION=SESSION 值；XSRF-TOKEN =XSRF-TOKEN 值}如
GET 方法在 postman 中调用方法和 POST 调用方法差不多都需要在 header 中添加参数, 这里可以不用在 header 添加 X-XSRF-TOKEN 值只需要设置 Cockie 值即可, postman 调用将 https：//supplab-callpostappapi-supplab.cn1.mindsphere-in.cn/api/datasource-supplab/v1/getValue 接口地址复制到 postman 地址栏中, 从 cockie 中取出 XSRF-TOKEN 值和 SESSION 值添加到 headers 中, 设置 Cockie {Cockie：SESSION=SESSION 值；XSRF-TOKEN =XSRF-TOKEN 值}如
这里的 User token 指的是从 MindShpere 平台中, RequestHeader 中获的 Authorization 的值, Authorization 是在后端程序在实现过程从 RequestHeader 中获取, 我们一般称呼它为 User Token. 利用这个 user token 可以去访问 MindSphere 平台提供 api 和已经注册 app 的 api. 获取 user token 的 Java 代码示例：
@RequestMapping("/getAccessToken") public String getAccessToken(@RequestHeader("Authorization") String userToken) throws IOException, MindsphereException { return userToken； } 利用 user token 访问 MindSphere 的 api, 要使 user token 能够访问 MindSphere api, 必须在 DeveloperCockpit 的授权管理中, 给 app 添加访问 MindSphere api 的相关服务角色(Role), 如要使 user token 能够访问 time series service 提供 api 读写数据, 就必须给 APP 添加 mdsp:core:iot.timAdmin 的角色, 如下图所示： 通过代码实现利用 User Token 访问 MindSphere api 接口格式：https://gateway.cn1.mindsphere-in.cn/{服务相关的 api} 如：https://gateway.cn1.mindspherein.cn/api/iottimeseries/v3/timeseries/9ab3f21ff8ad43638ed74ea6e413bb72/modbus_model @RequestMapping("/getAccessTokenValue") public String getAccessTokenValue(@RequestHeader("Authorization") String token) throws IOException, MindsphereException { HttpHeaders headers = new HttpHeaders(); headers.set("cache-control", "no-cache"); headers.set("Content-Type", "application/json"); headers.add("Authorization", token); RestTemplate restTemplate = new RestTemplate(); String url = "https：//gateway.cn1.mindspherein.cn/api/iottimeseries/v3/timeseries/9ab3f21ff8ad43638ed74ea6e413bb72/modbus_model"; String bodyJson = ""; HttpEntity<String> requestEntity = new HttpEntity<String>(bodyJson, headers); ResponseEntity<String> responseEntity = restTemplate.exchange(url, HttpMethod.GET, requestEntity, String.class); String responseBody = responseEntity.getBody().toString(); System.out.println("responser body：" + responseBody); return responseBody; } 通过 postman 访问 MindSphere api, 在 postman 中地址栏中输入 https://gateway.cn1.mindspherein.cn/api/iottimeseries/v3/timeseries/9ab3f21ff8ad43638ed74ea6e413bb72/modbus_mode, 然后选择 Auth->type->bearer Token, 然后在 Token 中输入 uesrtoken, 点击发送2. 利用 user token 访问 自己开发 app 的 api, 这个方法主要用来验证 app 提供 api, 一般后端程序可以直接获取利用 usertoken 去访问相关的资源, 除非两个后台 app 之间的交互, 这样的情况, 要先获取被访问 app 的 user token
访问格式 https://gateway.cn1.mindsphere-in.cn /api/{app 名称} -{租户名称}/{版本信息}/{app 接口地址}；如 https：//gateway.cn1.mindsphere-in.cn/api/datasource-supplab/v1/getValue 利用 user token 通过 postman 访问 app api, 在 postman 中地址栏中输入 https://gateway.cn1.mindspherein.cn/api/datasource-supplab/v1/getValue, 然后选择 Auth->type->bearer Token, headers 中设置{ key： Content-Type ；Value：application/json } 然后在 Token 中输入 uesrtoken, 点击发送
3. 可以 https://jwt.io/网址中输入 Authorzation 的 token 可以查看 token 可以访问接口的权限, 如图所示
Service credential(租户服务凭证信息). 一般只有开发者账号才有权限申请, 当您购买了 MindSphere 开发者账号时, 就可以创建工单提交工单, 申请开通服务凭证, 具体申请格式可以查看链接中的 https：//developer.mindsphere.io/zh/howto/howtoselfhosted-api-access.html 创建服务凭证内容, 申请的开发者账号（tenant name）服务凭证包括两个内容 client_id 和 client _secret, 我们将开通租房凭证获取的 client_id 和 client_secret 称为 Tech user, 使用 tech user 信息与 MindSphere
平台交互获取 token, 然后应用 token 访问 MindSphere 平台的提供所有 api, 这个 token 的有效时间是 30 分钟, 超过 30 分钟需要重新获取。通过 tech user 获取 token 权限比较高, 几乎可以访问 mindsphere 平台提供的一切资源, 为了您的账户安全,
tech user 信息应注意保存, 防止泄露, 如果发现 tech user 信息泄露, 为了您账号的安全, 请及时重新申请. 利用租户服务凭证信息获取 token 方法有：
1. 通过代码方式从后端程序中获取 token, 中国区获取地址格式为 https://{租户名称}.piam.cn1.mindspherein.cn/uaa/oauth/token, 代码示例如下
@RequestMapping("/getTechUser") public String getTechUser() throws IOException, MindsphereException { String token = ""; HttpHeaders headers = new HttpHeaders(); headers.set("Content-Type", "application/x-www-form-urlencoded"); headers.set("Accept", "application/json"); RestTemplate restTemplate = new RestTemplate(); String url = "https：//supplab.piam.cn1.mindsphere-in.cn/uaa/oauth/token"; String bodyJson = "client_id={服务凭证 id} &client_secret={服务凭证密码} &grant_type=client_credentials"; HttpEntity<String> requestEntity = new HttpEntity<String>(bodyJson, headers); ResponseEntity<String> responseEntity = restTemplate.exchange(url, HttpMethod.POST, requestEntity, String.class); JSONObject jsonObject = new JSONObject(responseEntity.getBody()); if (!jsonObject.isNull("access_token")) { token = jsonObject.getString("access_token"); } else { System.out.println("ge response body access_token is null"); return null; } return token; }在上述代码需要将 bodyJson="client_id={服务凭证 id} &client_secret={服务凭证密码}&grant_type=client_credentials"中的服务凭证 id 和服务凭证密码替换为您自己的服务凭证信息, 其次代码返回是一个 json 格式的字符串, 需要将字符串中 access_token 作为 token 值.
2. 利用凭证信息通过 postman 获取 token, 在 postman 中 Params 中设置为 grant_type, VAULE 为 client_credentials 或者直接在地址栏输入 https://supplab1.piam.cn1.mindsphere-in.cn/uaa/oauth/token?grant_type=client_credentials 地址；Auth 中 type 选择 Basic Auth, 然后 Username 填入服务凭证 id（client_id）, Password 填入服务凭证密码（client_secret）如图所示：
3。 通过代码方式利用 access_token 直接调用 MindSphere api 或已注册的 app 的 api；调用方式基本相同只需要将调用接口进行替换即可：
调用 MindSphere api 地址格式为：https://gateway.cn1.mindsphere-in.cn/{MindSphere api}；如： https://gateway.cn1.mindspherein.cn/api/iottimeseries/v3/timeseries/9ab3f21ff8ad43638ed74ea6e413bb72/modbus_model 调用已注册 APP API 地址格式为：https://gateway.cn1.mindsphere-in.cn /api/{app 名称}-{租户名称}/{版本信息}/{app 接口地址}, 如 https://gateway.cn1.mindsphere-in.cn/api/datasource-supplab/v1/getValue 代码示例： @RequestMapping("/getTechTokenValue") public String getTechTokenValue() throws IOException, MindsphereException { HttpHeaders headers = new HttpHeaders()； headers.set("cache-control", "no-cache")； headers.set("Content-Type", "application/json")； String token = getTechUser()； headers.add("Authorization", token)； RestTemplate restTemplate = new RestTemplate()； String url = "https：//gateway.cn1.mindspherein.cn/api/iottimeseries/v3/timeseries/9ab3f21ff8ad43638ed74ea6e413bb72/modbus_model"； String bodyJson = ""； HttpEntity<String> requestEntity = new HttpEntity<String>(bodyJson, headers)； ResponseEntity<String> responseEntity = restTemplate.exchange(url, HttpMethod.GET, requestEntity, String.class)； String responseBody = responseEntity.getBody().toString()； System.out.println("responser body：" + responseBody)； return responseBody； }上述代码中将 url 地址替换为访问 app 地址(https://gateway.cn1.mindsphere-in.cn/api/datasourcesupplab/v1/getValue)同样有效
4. 利用 https://gateway.cn1.mindspherein.cn/api/iottimeseries/v3/timeseries/9ab3f21ff8ad43638ed74ea6e413bb72/modbus_model 通过 postman 工具调用 MindSphere api 或已注册 app api；调用方式基本相同只需要将调用接口进行替换即可：
通过 postman 调用 MindSphere api, 在 postman 中地址栏中输入 https://gateway.cn1.mindspherein.cn/api/iottimeseries/v3/timeseries/9ab3f21ff8ad43638ed74ea6e413bb72/modbus_model, 送然后选择 Auth->type->bearer Token, headers 中设置{key：Content-Type；Value：application/json} 然后在 Token 中输入 uesrtoken, 点击发送
通过 postman 调用 app api, 调用方式和调用 MindSphere api 一直, 只需要将 postman 中的 MindSphere api 地址替换为 https://gateway.cn1.mindsphere-in.cn/api/datasource-supplab/v1/getValue 即可
1.4.1. 应用凭证介绍
在 app 开发过程中, app 与 MindSphere 平台或是自己后端 app 进行资源交互时, 我们推荐是应用凭证方式进行；App
Credentials（ 应用凭证）是 MindSphere 平台的 token management service 管理应用凭证的一项功能, app 在开发过程中, 如果在 Developer Cockpit 中创建应用凭证, 通过应用凭证信息与 MindSphere 平台 token management service 交互获取 token, 这个 token 有效期也是 30 分钟, 但是 token 在快过期的时 token management service 会提前 5 分钟 token 置换, 用户可以不用关心有效期的问题。
通过应用凭证信息获取的 token 具备跨租户访问数据的能力, 这个功能只有在具有应用凭证的 APP 在分配到 operator 环境, 在从 operator 环境分配用户环境(IoT 用户)时, 只有 IOT 用户授予同意时, 在 operator 部署的环境中 APP 使用此 token 可以获取 IOT 用户中资源。
应用凭证支持自托管程序和 MindSphere Cloud Foundry APP, 它们之间的区别是 MindSphere Cloud Foundry APP 在 operator 对应 Cloud Foundry 中是自动将应用凭证信息设置为环境变量中, 而自托管程序应用则是保存在文件中, 需要用户自行下载。
需要注意的是 developer 环境和 operator 环境中产生的应用凭证是不一样的, 主要区别如下：
在 Developer 环境中的应用凭证只能在 developer 环境中有效, 不具备跨租户访问能力, 手动产生, 需要手动记录便于开发测试, 不能将将 developer 环境的应用凭证设置到 operator 环境 在 Operator 环境中的应用凭证也只能在 operator 环境中有效, 通过 IoT 用户授权之后具备跨租户访问能力, 自动生成应用凭证, 在 cloudfoundry 中自动设置为环境变量, selfhost 自动生成保存在 execel 文件中, 需要手动下载。在开发过程中每个 app 的应用凭证具有唯一性且有有效期, 所以每个 app 只用使用自己的应用凭证, 不要将应用凭信息证嵌入到代码中, 尽量使用官网提供 sdk, 有的 sdk 已经封装了此类接口如(JavaSDK)或者开发语言具有获取自动获取环境变量接口, 便于应用凭证到期的时候能够自动获取延期的变量值, 也便于维护。
关于 token management service 介绍可以参考 https://developer.mindsphere.io/zh/apis/exchangetokenmanager/api-tokenmanager-overview.html 链接中的内容。
1.4.2. APP 与 Token Management Service 置换 token
在 app 应用凭证创建时会提供两个相信 client_id 和 client_secret 两个信息, 此信息只生成一次, 有效期为 365 天。App 必须提供应用凭证信息 client_id, client_secret 及注册应用 appname、appversion 和 hosttenant 名称、usertenant 名称与 token management service 置换 token, 在这个过程需要特别注意一点是 app 从 Developer Cockpit 上传时所选择 read
（受限的）和 readwrite（读和写）在生成 token 分别对应权限为 mdsp:core:Default3rdPartyTechUser 与 mdsp:core:Admin3rdPartyTechUser.
➢ 在 developer 账号中创建的应用凭证需要手动保存文件, 手动设置在环境变量中或者报错 manifest 文件中。
在 Cloud Foundry 中通过 cf set-env APP_NAME ENV_VAR_NAME ENV_VAR_VALUE 手动设置环境变量, 如：
cf set-env appname MDSP_KEY_STORE_CLIENT_ID client_id
cf set-env appname MDSP_KEY_STORE_CLIENT_ID client_secret
Manifest 文件保存, 重现 push APP 设置环境变量如下
---
applications：
- name：dataSource
instances：1
path：dataSource-0.0.1-SNAPSHOT.jar
memory：1G
random-route：true
env：
HOST_ENVIRONMENT：cn1
MDSP_OS_VM_APP_NAME：app name
MDSP_OS_VM_APP_VERSION：app version
MDSP_KEY_STORE_CLIENT_ID：client_id
MDSP_KEY_STORE_CLIENT_SECRET：client_sercret
MDSP_HOST_TENANT：tenant name
MDSP_USER_TENANT：tenant name
JAVA_OPTS：'-XX：ReservedCodeCacheSize=512M
在 Operator Cockpit 环境中 MindSphere Cloud Foundry APP 创建应用凭证, 注册成功会自动保存在环境变量值 MDSP_KEY_STORE_CLIENT_ID, MDSP_KEY_STORE_CLIENT_SECRET 中；Self Hosted app 创建应用凭证注册成 功时会自动保存在文件中, 用户在应用注册项自行下载保存。 在 Operator Cockpit 中将 app 分配 iot 用户时 , 后台服务将会发送邮件给予 IoT Plan 租户是否接受 app 使用后台服务访问 IoT 租户中的资源；用户如果不接受 , 则 App 应用凭证信息 client id 、 client secret 与 appname 、 appversion 、 hosttenant 、 usertenant 与 token management service 进行交互获取 token 就无法访问 iot 用户的中资源 , 这个凭证信息 对于所有 IoT Plan 租户来说是不可见。 在 app 开发过程 , MindSphere 为一些常见的开发言语提供了 SDK, SDK 对 MindSphere 平台的各个服务的 API 进行封装 , 方 便 app 的开发实现 , 当然用户也可以直接使用官网（ https://developer.mindsphere.io/zh/apis/index.html ）提供服务 api 进行实现。1.4.3. 应用凭证的应用流程
不同性质的 app 有不同应用凭证流程 , 目前有两种应用凭证应用流程 MindSphere Cloud Foundry APP 和自托管 APP 。 ➢ MindSphere Cloud Foundry APP 创建应用流程 1. 创建 , 注册 app 2. 上传 app 审核选择 , 上传 app 时 , 根据 app 获取资源的权限 , 选择应用凭证 read （受限的）或者 readwrite （读和写）。 • read （受限的）：产生的 token scope 为 mdsp ： core ： Default3rdPartyTechUser • readwrite （读和写）：产生的 token scope 为 mdsp ： core ： Admin3rdPartyTechUser 3. 审核 app 4. Developer Cockpit 中等待审核时间一般为 5 天 5. 审核结束 , 点击 app, 在 Developer Cockpit 中已通过审核应用显示 6. 分配 app 到 Operator Plan 7. 等待 operator Plan 接受 8. Operator Plan 选择是否接受 app 分配 9. Operator Plan 接受 app 分配 10. Developer Plan 授权 app 给 OperatorPlan 11. Operator Plan 对 app 进行部署注册 , 注册成功时 Operator Cockpit 对应的 cloud foundry 环境中自动将应用凭证信息 client_id 及 client_secret 添加 app 环境变量中 MDSP_KEY_STORE_CLIENT_ID 及 MDSP_KEY_STORE_CLIENT_SECRET 12. Operator Plan 将 app 从开通服务中分配至 IoT Plan 13. 等待接收收件邮件 , IoT Plan 用户收到 Operator Plan 分配 App 邮件并在邮件中点击接受 , 同意带有应用凭证的 App 在使用后台服务读取本 租户中的数据 14. 等待 IoT Plan 用户同意 app 分配 15. 同意接受 app 服务 , Operator Cockpit 开通服务显示已开通服务状态 16. IoT Plan 用户使用 app, app 根据调用的接口可以选择自动获取 cloud foundry 环境中所设置的 app 环境变量信息 , 如 APP 名称、 APP 版本信 息、 client_id, client_secert 和通过 mindsphere 平台请求 header 中 user token 分离出来 host tenat 名称 user tenant 名称与 token management service 交互获取 token, 利用 token 去访问用户租户中的相关资源 ➢ 自托管 APP 应用创建流程 1. 创建 , 注册 app 2. 上传 app 审核选择 , 上传 app 时 , 根据 app 获取资源的权限 , 选择应用凭证 read （受限的）或者 readwrite （读和写）。 • read （受限的）：产生的 token scope 为 mdsp ： core ： Default3rdPartyTechUser • readwrite （读和写）：产生的 token scope 为 mdsp ： core ： Admin3rdPartyTechUser 3. 审核 app 4. Developer Cockpit 中等待审核时间一般为 5 天 5. 审核结束 , 点击 app, 在 Developer Cockpit 中已通过审核应用显示 6. 分配 app 到 Operator Plan 7. 等待 operator Plan 接受 8. Operato rPlan 选择是否接受 app 分配 9. Operator Plan 接受 app 分配 10. Developer Plan 授权 app 给 Operator Plan 11. Operator Plan 对 app 进行部署注册 , 注册成功时将在注册项生成应用凭证信息 client_id 及 client_secret, 将应用凭证信息下载保存 , 随后将应 用凭证信息 client_id 及 client_secret 添加 app 部署环境的环境变量中 MDSP_KEY_STORE_CLIENT_ID 及 MDSP_KEY_STORE_CLIENT_SECRET, 12. Operator Plan 将 app 从开通服务中分配至 IoTPlan 13. IoT Plan 用户收 Operator Plan 分配 App 邮件提示 , 在邮件中点击接受 , 同意带有应用凭证的 App 在使用后台服务读取本租户中的数据 14. 等待 IoT Plan 用户同意 app 分配 15. 同意接受 app 时 , Operator Cockpit 开通服务中显示已开通服务 16. IoT Plan 用户使用 app, app 根据调用的接口可以选择自动获取 app 环境变量信息 APP 名称 ( 设置环境变量 MDSP_OS_VM_APP_NAME ： APP 名称 ) 、 APP 版本信息 ( 设置环境变量 MDSP_OS_VM_APP_VERSION ：： APP 版本信息 ), client_id, client_secert 和通过 mindsphere 平台请求 header 中 usertoken 分离出来 hosttenant 名称 usertenant 名称与 token management service 置换获取 token, 利用 token 去访问用户租户中的 相关资源 注意 ：针对 self-hosted app, 从环境变量获取凭证信息及 app 名称、版本只是其中的一种方法 , 也从配置文件中获取或界面输入 1.4.4. 应用凭证生成 token ➢ 通过代码生成 , 利用生成 token 可以访问 MindSphere api 或者 APP 的 api, 访问方法与租户凭证生成 token 访问方法一致 ▪ 代码示例 public String getInterfaceToken(String appName, String appVersion, String hostTenant, String userTenant) { String responseBody = ""; String token = ""; String bodyJson = "{\n" + " \"appName\"：\"" + appName + "\",\n" + " \"appVersion\"：\"" + appVersion + "\",\n" + " \"hostTenant\"：\"" + hostTenant + "\",\n" + " \"userTenant\"：\"" + userTenant + "\",\n" + " \"grant_type\"：\"client_credentials\"\n" + "}"; String strClientID = "{应用凭证 Id/client_id} "; String strClientSceret = "{应用凭证密钥/client_secret}"; String strBase64 = getBase64(strClientID, strClientSceret); HttpHeaders headers = new HttpHeaders(); headers.set("cache-control", "no-cache"); headers.set("Content-Type", "application/json;charset=UTF-8"); headers.add("x-space-auth-key", "Bearer " + strBase64); RestTemplate restTemplate = new RestTemplate(); String url = "https：//gateway.cn1.mindsphere-in.cn/api/technicaltokenmanager/v3/oauth/token"; HttpEntity<String> requestEntity = new HttpEntity<String>(bodyJson, headers); ResponseEntity<String> responseEntity = restTemplate.exchange(url, HttpMethod.POST, requestEntity, String.class); responseBody = responseEntity.getBody(); JSONObject jsonObject = new JSONObject(responseBody); if (!jsonObject.isNull("access_token")) { token = jsonObject.getString("access_token"); } else { System.out.println("ge response body access_token is null"); return; } System.out.println("responser body：" + token); return token; } // 应用凭证信息转化为 base64 public String getBase64(String clientID, String clientSceret) { String strGorp = clientID + "：" + clientSceret; String base64Creds = ""; try { byte[] base64CredsBytes = Base64.encodeBase64(strGorp.getBytes("UTF-8")); base64Creds = new String(base64CredsBytes, "UTF-8"); } catch (UnsupportedEncodingException e) { System.out.println(e.getMessage()); } return base64Creds; } ➢ 通过 postman 工具生成 token, 利用生成 token 可以访问 MindSphere api 或者 app 的 api, 访问方法与租户凭证生成 token 访问方法一致 首先在 postman 地址栏中输入 https://gateway.cn1.mindsphere-in.cn/api/technicaltokenmanager/v3/oauth/token 地址 首先使用 https://www.base64encode.org 网址中工具 APP 应用凭证 client_id 和 client_secret 转化为 Base64, 转化格式为”client_id：client_secret”；点击 ENCODE 将转化 base64 保存。
在 postman 中设置 headers, 添加
Key：value 为 cache-control：no-cache
Key：value 为 Content-Type：application/json
添加 body, body 设置为 json 格式{
"appName"："app name",
"appVersion"："app version",
"hostTenant"："operator 租户名称",
"userTenant"："iot 用户名称",
"grant_type"："client_credentials"
}
对于未发布的 app 在 Developer 环境中 hostTenant 和 userTenant 设置为 developer 租户名称, 已经发布的 app
hostTenant 和 userTenant 根据 app 分配情况, 从而来设置 operator 租户名称和 iot 用户名称, 有时候为测试同时设置
为 operator 租户名称, 但是不能同时设置为 iot 租户名称。
如：
{
"appName"："datasource",
"appVersion"："v1", //
"hostTenant"："supplab", //必须填 operator tenant 名称如果传参数的时候{{ hostTenant name}}
"userTenant"："supplab" // lot 用户的 tetant 名称如果传参数的时候{{ userTenant name}},
"grant_type"："client_credentials"
}
点击发送获取 access_token通过上述获取的 access_token 访问 MindSphere api 或 app api 方法与 Tenant Credentials 中 access_token 访问MindSphere api 或 app api 方法一致, 请参考前面的内容.WebSocket 通信示例 1.5.1. Example NodeJS 前端 , 该片段模拟了一个前端调用后端 WebSocket 接口的案例； /websocket/stomp 为接口的代理 broker 地址 :
var Stomp = require('stompjs'); var WebSocket = require('ws'); var SockJS = require("sockjs-client"); // ajax post 请求默认添加请求头 var cookie = "SESSION=NmVkYzZjOWYtYzdhNy00NzZkLTgxYzUtZDZkMGIyOTYyMGQy"; var stompClient = null; function connect() { var url = "https://supplab1-websocket-supplab1.cn1.mindsphere-in.cn/websocket/stomp"; var socket = new WebSocket( url, { headers: { "Cookie": cookie } } ); stompClient = Stomp.over(socket); stompClient.connect( {}, function (frame) { console.log('Connected: ' + frame); stompClient.subscribe('/topic/greetings', function (greeting) { showGreeting(JSON.parse(greeting.body).content); }); sendName(); }, function (error) { console.log('Failed to connect, unsuccessfully: [' + error + ']'); } ); } function disconnect() { if (stompClient !== null) { stompClient.disconnect(); } setConnected(false); console.log("Disconnected"); } function sendName() { stompClient.send("/app/hello", {}, JSON.stringify({ 'name': "Hello world is my name" })); } function showGreeting(message) { console.log("Received message: " + message); } connect();
Java 服务端 @Configuration @EnableWebSocketMessageBroker @EnableScheduling public class MessageBrokerConfig extends AbstractWebSocketMessageBrokerConfigurer { public static final String STOMP_ENDPOINT = "/websocket/stomp"; @Override public void configureMessageBroker(final MessageBrokerRegistry config) { config.enableSimpleBroker("/topic"); config.setApplicationDestinationPrefixes("/app"); } @Override public void registerStompEndpoints(final StompEndpointRegistry registry) { registry.addEndpoint(STOMP_ENDPOINT).setAllowedOrigins("*"); registry.addEndpoint(STOMP_ENDPOINT).setAllowedOrigins("*").withSockJS(); } }
