我正在开发一个Android应用程序，它与Spring中配置的jetty服务器交换数据 . 为了获得更动态的Android应用程序，我试图使用带有Stomp消息的WebSocket协议 .
为了实现这个功能，我在Spring中配置了一个Web套接字消息代理：
@Configuration
//@EnableScheduling
@ComponentScan(
basePackages="project.web",
excludeFilters = @ComponentScan.Filter(type= FilterType.ANNOTATION, value = Configuration.class)
)
@EnableWebSocketMessageBroker
public class WebSocketConfig extends AbstractWebSocketMessageBrokerConfigurer {
@Override
public void configureMessageBroker(MessageBrokerRegistry config) {
config.enableSimpleBroker("/message");
config.setApplicationDestinationPrefixes("/app");
}
@Override
public void registerStompEndpoints(StompEndpointRegistry registry) {
registry.addEndpoint("/client");
}
}
和一个 SimpMessageSendingOperations 在Spring控制器中从服务器向客户端发送消息：
@Controller
public class MessageAddController {
private final Log log = LogFactory.getLog(MessageAddController.class);
private SimpMessageSendingOperations messagingTemplate;
private UserManager userManager;
private MessageManager messageManager;
@Autowired
public MessageAddController(SimpMessageSendingOperations messagingTemplate,
UserManager userManager, MessageManager messageManager){
this.messagingTemplate = messagingTemplate;
this.userManager = userManager;
this.messageManager = messageManager;
}
@RequestMapping("/Message/Add")
@ResponseBody
public SimpleMessage addFriendship(
@RequestParam String content,
@RequestParam Long otherUser_id
){
if(log.isInfoEnabled())
log.info("Execute MessageAdd action");
SimpleMessage simpleMessage;
try{
User curentUser = userManager.getCurrentUser();
User otherUser = userManager.findUser(otherUser_id);
Message message = new Message();
message.setContent(content);
message.setUserSender(curentUser);
message.setUserReceiver(otherUser);
messageManager.createMessage(message);
Message newMessage = messageManager.findLastMessageCreated();
messagingTemplate.convertAndSend(
"/message/add", newMessage);//send message through websocket
simpleMessage = new SimpleMessage(null, newMessage);
} catch (Exception e) {
if(log.isErrorEnabled())
log.error("A problem of type : " + e.getClass()
+ " has occured, with message : " + e.getMessage());
simpleMessage = new SimpleMessage(
new SimpleException(e.getClass(), e.getMessage()), null);
}
return simpleMessage;
}
}
当我在带有stomp.js的Web浏览器中测试此配置时，我没有任何问题：在Web浏览器和Jetty服务器之间完美地交换消息 . 用于Web浏览器测试的JavaScript代码：
var stompClient = null;
function setConnected(connected) {
document.getElementById('connect').disabled = connected;
document.getElementById('disconnect').disabled = !connected;
document.getElementById('conversationDiv').style.visibility = connected ? 'visible' : 'hidden';
document.getElementById('response').innerHTML = '';
}
function connect() {
stompClient = Stomp.client("ws://YOUR_IP/client");
stompClient.connect({}, function(frame) {
setConnected(true);
stompClient.subscribe('/message/add', function(message){
showMessage(JSON.parse(message.body).content);
});
});
}
function disconnect() {
stompClient.disconnect();
setConnected(false);
console.log("Disconnected");
}
function showMessage(message) {
var response = document.getElementById('response');
var p = document.createElement('p');
p.style.wordWrap = 'break-word';
p.appendChild(document.createTextNode(message));
response.appendChild(p);
}
当我尝试在Android中使用gozirra，activemq-stomp等库时，会出现问题：大多数情况下，与服务器的连接不起作用 . 我的应用程序停止运行，几分钟后，我在logcat中有以下消息： java.net.UnknownHostException: Unable to resolve host "ws://192.168.1.39/client": No address associated with hostname ，我不明白为什么 . 代码使用Gozzira库管理我的android活动中的stomp吸引力：
private void stomp_test() {
String ip = "ws://192.172.6.39/client";
int port = 8080;
String channel = "/message/add";
Client c;
try {
c = new Client( ip, port, "", "" );
Log.i("Stomp", "Connection established");
c.subscribe( channel, new Listener() {
public void message( Map header, String message ) {
Log.i("Stomp", "Message received!!!");
}
});
} catch (IOException ex) {
Log.e("Stomp", ex.getMessage());
ex.printStackTrace();
} catch (LoginException ex) {
Log.e("Stomp", ex.getMessage());
ex.printStackTrace();
} catch (Exception ex) {
Log.e("Stomp", ex.getMessage());
ex.printStackTrace();
}
}
经过一些研究，我发现大多数想要使用Java客户端使用websocket的人使用ActiveMQ服务器，就像在_1711081中一样 . 但是 spring 工具使用起来非常简单，如果我能像现在这样保持我的服务器层，那将会很酷 . 有人会知道如何在服务器端使用Spring配置在客户端使用stomp java（Android）？
3 回答
我使用RxJava https://github.com/NaikSoftware/StompProtocolAndroid为Android（或普通java）实现STOMP协议 . 使用SpringBoot在STOMP服务器上测试 . 简单示例（使用retrolambda）：
在项目中添加以下类路径：
在app build.gradle中添加以下内容：
全部异步工作！您可以在
subscribe()和send()之后调用connect()，消息将被推送到队列 .附加功能：
用于握手查询的额外HTTP标头（用于传递身份验证令牌或其他）
您可以为库实现自己的传输，只需实现接口ConnectionProvider
订阅连接生命周期事件（已连接，已关闭，错误）
例如 ：
在manifest.xml中添加Internet权限
我实现了使用Android和Spring服务器在web套接字上使用stomp .
要做这样的事情，我使用了一个Web套接字库：werbench（按照这个link下载它） . 要安装，我使用了maven命令
mvn install，然后我在本地存储库中找回了jar . 然后，我需要在基本的网络套接字上添加一个stomp图层，但是我不能犹豫地问我是否要看看它，但我很快意识到这一点，所以它不能像stomp一样管理 . JS . 然后，我需要用我的spring服务器实现身份验证 . 为实现这一目标，我遵循了this site的指示 . 当我回到JSESSIONID cookie时，我只需要在我的stomp "library"中的werbench web套接字的实例化中声明带有此cookie的头 .编辑：这是这个库中的主类，管理web套接字连接的主要类：
这是一个Stomp消息的框架：
这个是用于通过stomp协议 Build 订阅的对象：
至少，有两个接口用作“Run”java类，用于监听Web套接字网络和给定的订阅管道
欲了解更多信息，请不要犹豫，问我 .
完美解决方案Eperrin谢谢 . 我想填写完整的解决方案，例如在您的活动/服务阶段，您调用
connection方法当然不在MainThread中 .并且在websocket weberknecht library中小心 WebSocketHandshake class 中的错误方法 verifyServerHandshakeHeaders 中的错误是在行124上检查只有（！headers.get（"Connection"）.equals（"Upgrade"））并且当服务器发送升级而不是升级时你得到错误连接失败：服务器握手中缺少 Headers 字段：如果（！headers.get（"Connection"）.equalsIgnoreCase（"Upgrade"）），则必须关闭忽略大小写的连接