javaweb聊天室引入图灵机器人智能对话

喜欢ヅ旅行 2022-06-04 23:30 295阅读 0赞

很多人都开发过在线聊天室，但是很少有引入robot api的，如果有一个智能机器人和大家“聊骚”，这样聊天室的氛围岂不是更加愉快。

图灵机器人网址：[http://www.tuling123.com/][http_www.tuling123.com]

注册登录后可设置一些机器人的基本信息（它还可以随着年龄的增长而学习知识技能的提升）

![Center][]

在知识库一栏可设置一些常用知识关键词汇的答案信息

![Center 1][]

能力扩展中开启你所涉及的领域:

![Center 2][]

下面开始在web中引入robot，先上图（当然也支持多人在线聊天）

![Center 3][]

怎么样，挺智能的吧。说说开发吧，首先要用到websocket和tomcat8

Js核心代码：

Java Websocket服务核心代码：

package com.amayadream.webchat.websocket;
    
    import com.alibaba.fastjson.JSON;
    import com.alibaba.fastjson.JSONObject;
    
    import javax.servlet.http.HttpSession;
    import javax.websocket.*;
    import javax.websocket.server.ServerEndpoint;
    import java.io.IOException;
    import java.util.ArrayList;
    import java.util.HashMap;
    import java.util.List;
    import java.util.Map;
    import java.util.concurrent.CopyOnWriteArraySet;
    
    /**
     * websocket服务
     * @author  :  Ardo
     * @time   :  2017.05
     */
    @ServerEndpoint(value = "/chatServer", configurator = HttpSessionConfigurator.class)
    public class ChatServer {
        private static int onlineCount = 0; //静态变量，用来记录当前在线连接数。应该把它设计成线程安全的。
        private static CopyOnWriteArraySet<ChatServer> webSocketSet = new CopyOnWriteArraySet<ChatServer>();
        private Session session;    //与某个客户端的连接会话，需要通过它来给客户端发送数据
        private String userid;      //用户名
        private HttpSession httpSession;    //request的session
    
        private static List<String> list = new ArrayList<String>();   //在线列表,记录用户名称
        private static Map<String, Object> routetab = new HashMap<String, Object>();  //用户名和websocket的session绑定的路由表
    
        /**
         * 连接建立成功调用的方法
         * @param session  可选的参数。session为与某个客户端的连接会话，需要通过它来给客户端发送数据
         */
        @OnOpen
        public void onOpen(Session session, EndpointConfig config){
        	//System.out.println("********************ChatServer onOpen************************");
            this.session = session;
            webSocketSet.add(this);     //加入set中
            addOnlineCount();           //在线数加1;
            this.httpSession = (HttpSession) config.getUserProperties().get(HttpSession.class.getName());
            this.userid=(String) httpSession.getAttribute("userid");    //获取当前用户
            list.add(userid);           //将用户名加入在线列表
            routetab.put(userid, session);   //将用户名和session绑定到路由表
            String message = getMessage("[" + userid + "]加入聊天室,当前在线人数为"+getOnlineCount()+"位", "notice",  list);
            broadcast(message);     //广播
        }
    
        /**
         * 连接关闭调用的方法
         */
        @OnClose
        public void onClose(){
        	//System.out.println("********************ChatServer onClose************************");
            webSocketSet.remove(this);  //从set中删除
            subOnlineCount();           //在线数减1
            list.remove(userid);        //从在线列表移除这个用户
            routetab.remove(userid);
            String message = getMessage("[" + userid +"]离开了聊天室,当前在线人数为"+getOnlineCount()+"位", "notice", list);
            broadcast(message);         //广播
        }
    
        /**
         * 接收客户端的message,判断是否有接收人而选择进行广播还是指定发送
         * @param _message 客户端发送过来的消息
         */
        @OnMessage
        public void onMessage(String _message) {
        	//System.out.println("********************ChatServer onMessage************************");
            JSONObject chat = JSON.parseObject(_message);
            JSONObject message = JSON.parseObject(chat.get("message").toString());
            if(message.get("to") == null || message.get("to").equals("")){      //如果to为空,则广播;如果不为空,则对指定的用户发送消息
                broadcast(_message);
            }else{
                String [] userlist = message.get("to").toString().split(",");
                singleSend(_message, (Session) routetab.get(message.get("from")));      //发送给自己,这个别忘了
                for(String user : userlist){
                    if(!user.equals(message.get("from"))){
                        singleSend(_message, (Session) routetab.get(user));     //分别发送给每个指定用户
                    }
                }
            }
        }
    
        /**
         * 发生错误时调用
         * @param error
         */
        @OnError
        public void onError(Throwable error){
        	//System.out.println("********************ChatServer onError************************");
            error.printStackTrace();
        }
    
        /**
         * 广播消息
         * @param message
         */
        public void broadcast(String message){
        	//System.out.println("********************ChatServer broadcast************************");
            for(ChatServer chat: webSocketSet){
                try {
                    chat.session.getBasicRemote().sendText(message);
                } catch (IOException e) {
                    e.printStackTrace();
                    continue;
                }
            }
        }
    
        /**
         * 对特定用户发送消息
         * @param message
         * @param session
         */
        public void singleSend(String message, Session session){
        	//System.out.println("********************ChatServer singleSend************************");
            try {
                session.getBasicRemote().sendText(message);
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    
        /**
         * 组装返回给前台的消息
         * @param message   交互信息
         * @param type      信息类型
         * @param list      在线列表
         * @return
         */
        public String getMessage(String message, String type, List list){
        	//System.out.println("********************ChatServer getMessage************************");
            JSONObject member = new JSONObject();
            member.put("message", message);
            member.put("type", type);
            member.put("list", list);
            return member.toString();
        }
    
        public int getOnlineCount() {
        	//System.out.println("********************ChatServer getOnlineCount************************");
            return onlineCount;
        }
    
        public void addOnlineCount() {
        	//System.out.println("********************ChatServer addOnlineCount************************");
            ChatServer.onlineCount++;
        }
    
        public void subOnlineCount() {
        	//System.out.println("********************ChatServer subOnlineCount************************");
            ChatServer.onlineCount--;
        }
    }

以上为核心代码，需要源码的留下邮箱吧！

[http_www.tuling123.com]: http://www.tuling123.com/
[Center]: /images/20220605/d8754cfa2dd1424886cb3110886daf12.png
[Center 1]: /images/20220605/07abf3142eda40e983d0c7049f715131.png
[Center 2]: /images/20220605/47bd429e370e4f15889e7d162e2b6610.png
[Center 3]: /images/20220605/e25bea3ec6b34964b78865f73a003162.png