如何沿 Websocket 终结点实现 Rest 终结点

Question

我想在Websocket端点上公开一个额外的Rest端点。

websocket 端点已经实现并工作，但我在点击 Rest 端点时遇到了问题。

知道我在这里错过了什么吗？ 我希望以hello的文本纯结果运行localhost:8080/hello.

顺便说一句，如果这很重要，我正在使用夸库斯。

这是我的项目结构

│   │   ├── java
│   │   │   └── org
│   │   │       └── company
│   │   │           ├── chat
│   │   │           │   ├── boundary
│   │   │           │   ├── control
│   │   │           │   └── entity
│   │   │           ├── JAXRSConfiguration.java // Rest endpoint ???
│   │   │           └── websockets
│   │   │               └── ChatSocket.java // Websocket server endpoint (works)
│   │   └── resources
│   │       ├── application.properties
│   │       ├── application.properties.example
│   │       └── META-INF
│   │           └── resources
│   │               ├── index.html

JAXRSConfiguration.java

package org.company;
import javax.ws.rs.ApplicationPath;
import javax.ws.rs.GET;
import javax.ws.rs.Produces;
import javax.ws.rs.core.Application;
import javax.ws.rs.core.MediaType;
@ApplicationPath("hello")
public class JAXRSConfiguration extends Application {
@GET
@Produces(MediaType.TEXT_PLAIN)
public String hello() {
return "hello";
}
}

聊天套接字.java

package org.company.websockets;
import com.google.gson.Gson;
import com.google.gson.JsonObject;
import com.google.gson.JsonParser;
import java.time.LocalDateTime;
import java.util.Dictionary;
import java.util.Enumeration;
import java.util.Hashtable;
import java.util.List;
import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;
import javax.enterprise.context.ApplicationScoped;
import javax.inject.Inject;
import javax.websocket.OnClose;
import javax.websocket.OnError;
import javax.websocket.OnMessage;
import javax.websocket.OnOpen;
import javax.websocket.Session;
import javax.websocket.server.PathParam;
import javax.websocket.server.ServerEndpoint;
import org.company.chat.boundary.ChatResource;
import org.company.chat.entity.Chat;
import org.company.chat.entity.ChatGroup;
import org.company.chat.entity.ChatMessage;
import org.company.time.Time;
import org.jboss.logging.Logger;
@ServerEndpoint("/chat/websocket/{username}/{chatRoom}")
@ApplicationScoped
public class ChatSocket {
@Inject
Time time;
@Inject
ChatResource chatResource;
// Chatroom, user, session dictionary
final Dictionary<String, Map<String, Session>> chatRooms = new Hashtable<>();

@OnOpen
public void onOpen(final Session session, @PathParam("username") final String username, @PathParam("chatRoom") final String chatRoom) {
// ...
}
@OnClose
public void onClose(final Session session, @PathParam("username") final String username, @PathParam("chatRoom") final String chatRoom)
throws Exception {
// ...
}
@OnError
public void onError(final Session session, @PathParam("username") final String username, @PathParam("chatRoom") final String chatRoom,
final Throwable throwable) throws Exception {
// ...
}
@OnMessage
public void onMessage(String json, @PathParam("username") final String username, @PathParam("chatRoom") final String chatRoom)
throws Exception {
// ...        
}
private void broadcast(final String event, final String chatRoom) {
// ...
}

Answer 1

解决方案只是添加另一个@Path注释。

在这里，我更改了JAXRSConfiguration.java，如下所示。 现在工作，如果我调用localhost:8080/api/hello端点。

@ApplicationPath("api") // Changed the basic route to 'api'
@Path("hello") // Added a new path
public class JAXRSConfiguration extends Application {
@GET
@Produces(MediaType.TEXT_PLAIN)
public String hello() {
return "hello";
}
}