用websocket写一个一对一的聊天功能，并且还要持久化，因为还需要一个查询聊天记录的功能 java代码示例给我

当然可以！以下是一个使用Java中的WebSocket实现一对一聊天功能，并且持久化聊天记录的示例代码：

import java.io.IOException;
import java.util.Collections;
import java.util.HashSet;
import java.util.Set;
import javax.websocket.OnClose;
import javax.websocket.OnError;
import javax.websocket.OnMessage;
import javax.websocket.OnOpen;
import javax.websocket.Session;
import javax.websocket.server.ServerEndpoint;

@ServerEndpoint("/chat")
public class ChatEndpoint {
    private static Set<Session> sessions = Collections.synchronizedSet(new HashSet<>());

    @OnOpen
    public void onOpen(Session session) {
        sessions.add(session);
    }

    @OnMessage
    public void onMessage(String message, Session session) throws IOException {
        // 在这里处理接收到的消息，可以将消息存储到数据库中

        // 示例中只是简单地将接收到的消息发送给所有连接的会话
        for (Session s : sessions) {
            s.getBasicRemote().sendText(message);
        }
    }

    @OnClose
    public void onClose(Session session) {
        sessions.remove(session);
    }

    @OnError
    public void onError(Throwable error) {
        // 处理错误
    }
}

上述代码使用了Java中的`javax.websocket`包，通过`@ServerEndpoint`注解标记WebSocket服务器端点，客户端可以通过`ws://localhost:8080/chat`连接到该端点。

在`onOpen`方法中，会话被添加到一个`sessions`集合中。

在`onMessage`方法中，可以处理接收到的消息，并将消息持久化到数据库中。

在`onClose`方法中，会话从`sessions`集合中移除。

在`onError`方法中，可以处理WebSocket发生的错误。

需要注意的是，上述代码只是一个简单的示例，实际使用时可能需要更多的逻辑和安全措施。另外，持久化聊天记录可以使用数据库或其他持久化存储方式来实现，这里只是提供了一个基本的框架。