刷题吧程序

Author: CodeLunatic

.gitignore

@@ -0,0 +1,4 @@
+.idea
+*.iml
+target
+/数据/

anonymous-group-chat/.gitignore

@@ -0,0 +1,3 @@
+.idea
+*.iml
+target

anonymous-group-chat/README.md

@@ -0,0 +1,21 @@
+# 刷题吧匿名群聊
+
+此应用是我在学习`WebSocket`的时候写出来的一个`匿名群聊`，头像和用户名都是`随机分配`，头像素材`来源于网络`
+
++ 请使用`谷歌浏览器`，如果遇到收不到消息的情况，`刷新`浏览器即可
+
++ 尽量不要使用`手机`访问，未做手机兼容
+
++ 每一个浏览器会`随机`分配一个`匿名身份`和`头像`，使用`Cookie`保存，如果想要换一个名字，清理一下`Cookie`即可
+
++ 当前只可以发送`文字`，不考虑加入其它功能
+
++ 聊天不会被`记录`
+
+## 界面预览
+
+![界面预览](http://p.qlogo.cn/qqmail_head/Q3auHgzwzM4g2cLj1J8wBePWc7IpPAic1rjFtR5gfwDLqQGpLicFibGuzLNCXIImDEypicB0a2Wch63wQp3dwbkbCpcKkfqFbSVtBzKdXh2jkW4/0)
+
+
+
+> 2019-01-03 更新了不同用户链接WebSocket自动获取正确的链接

anonymous-group-chat/pom.xml

@@ -0,0 +1,45 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xmlns="http://maven.apache.org/POM/4.0.0"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <parent>
+        <artifactId>question</artifactId>
+        <groupId>com.cy</groupId>
+        <version>1.0</version>
+    </parent>
+    <modelVersion>4.0.0</modelVersion>
+
+    <artifactId>anonymous-group-chat</artifactId>
+
+    <dependencies>
+        <!--WebSocket支持-->
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-websocket</artifactId>
+        </dependency>
+        <!-- FastJSON依赖包 -->
+        <dependency>
+            <groupId>com.alibaba</groupId>
+            <artifactId>fastjson</artifactId>
+            <version>1.2.53</version>
+        </dependency>
+        <!--排除Tomcat依赖-->
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-tomcat</artifactId>
+            <!--<scope>provided</scope>-->
+        </dependency>
+    </dependencies>
+
+    <build>
+        <finalName>GroupChat</finalName>
+        <plugins>
+            <!--可以使用Maven命令spring-boot:run来启动SpringBoot-->
+            <plugin>
+                <groupId>org.springframework.boot</groupId>
+                <artifactId>spring-boot-maven-plugin</artifactId>
+            </plugin>
+        </plugins>
+    </build>
+
+</project>

anonymous-group-chat/src/main/java/com/cy/ChatApplication.java

@@ -0,0 +1,26 @@
+package com.cy;
+
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.boot.builder.SpringApplicationBuilder;
+import org.springframework.boot.web.servlet.support.SpringBootServletInitializer;
+
+/**
+ * By CY
+ * Date 2018/11/24 12:10
+ */
+@SpringBootApplication
+public class ChatApplication extends SpringBootServletInitializer {
+
+    public static void main(String[] args) {
+        SpringApplication.run(ChatApplication.class, args);
+    }
+
+    /**
+     * 部署到Tomcat需要这个方法
+     */
+    @Override
+    protected SpringApplicationBuilder configure(SpringApplicationBuilder application) {
+        return application.sources(ChatApplication.class);
+    }
+}

anonymous-group-chat/src/main/java/com/cy/conf/ApplicationInit.java

@@ -0,0 +1,27 @@
+package com.cy.conf;
+
+import org.springframework.boot.CommandLineRunner;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.core.annotation.Order;
+
+/**
+ * 这个类的作用是项目启动后自动打开浏览器访问项目
+ * By CY
+ * Date 2018/11/26 12:50
+ */
+@Configuration
+public class ApplicationInit implements CommandLineRunner {
+
+    /**
+     * 运行项目后要进行的操作【已测试2018年11月27日23:03:49】
+     *
+     * @param args 参数
+     * @throws Exception 异常
+     */
+    @Order(0) // 运行的顺序，数字越小优先级越高
+    @Override
+    public void run(String... args) throws Exception {
+        // 自动打开默认浏览器访问项目，当前只有Windows平台可用
+        Runtime.getRuntime().exec("cmd /c start http://127.0.0.1:8080/");
+    }
+}

anonymous-group-chat/src/main/java/com/cy/conf/WebSocketConfig.java

@@ -0,0 +1,14 @@
+package com.cy.conf;
+
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.web.socket.server.standard.ServerEndpointExporter;
+
+@Configuration
+public class WebSocketConfig {
+
+    @Bean
+    public ServerEndpointExporter serverEndpointExporter() {
+        return new ServerEndpointExporter();
+    }
+}

anonymous-group-chat/src/main/java/com/cy/controller/InfoController.java

@@ -0,0 +1,50 @@
+package com.cy.controller;
+
+import com.cy.data.OnlineCount;
+import com.cy.service.RandomUserInfo;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+import javax.servlet.http.HttpServletRequest;
+
+/**
+ * 得到用户信息的Controller
+ */
+@RestController
+@RequestMapping("chat")
+public class InfoController {
+
+    /**
+     * 获取一个随机的用户名
+     *
+     * @param request IP
+     * @return 用户的名 + IP
+     * Todo 这种方式不恰当，因为前台可以通过修改Cookie的形式来进行IP的修改
+     * 还可以自定义用户名，这里的设计思路需要改变
+     */
+    @PostMapping(value = "username")
+    public String getRandomUsername(HttpServletRequest request) {
+        return RandomUserInfo.getRandomUserName() + " (" + request.getRemoteAddr() + ")";
+    }
+
+    /**
+     * 得到随机头像
+     *
+     * @return 随机头像的地址
+     */
+    @PostMapping(value = "avatar")
+    public String getRandomAvatar() {
+        return RandomUserInfo.getRandomAvatar();
+    }
+
+    /**
+     * 得到在线的人数
+     *
+     * @return 在线的人数
+     */
+    @PostMapping(value = "getOnlineCount")
+    public synchronized int getOnlineCount() {
+        return OnlineCount.getOnlineCount();
+    }
+}

anonymous-group-chat/src/main/java/com/cy/data/OnlineCount.java

@@ -0,0 +1,33 @@
+package com.cy.data;
+
+import org.springframework.stereotype.Component;
+
+@Component
+public class OnlineCount {
+
+    //静态变量，用来记录当前在线连接数。应该把它设计成线程安全的。
+    private static int onlineCount;
+
+    /**
+     * 增加在线人数
+     */
+    public static synchronized void addOnlineCount() {
+        onlineCount++;
+    }
+
+    /**
+     * 减少在线人数
+     */
+    public static synchronized void subOnlineCount() {
+        onlineCount--;
+    }
+
+    /**
+     * 得到在线人数
+     *
+     * @return 在线人数
+     */
+    public static synchronized int getOnlineCount() {
+        return onlineCount;
+    }
+}

anonymous-group-chat/src/main/java/com/cy/service/RandomUserInfo.java

@@ -0,0 +1,61 @@
+package com.cy.service;
+
+import java.io.IOException;
+import java.io.InputStream;
+import java.util.Date;
+import java.util.Properties;
+import java.util.Random;
+
+/**
+ * 得到随机的匿名用户信息
+ * By CY
+ * Date 2018/11/24 14:05
+ */
+public class RandomUserInfo {
+
+    /**
+     * 头像属性文件的路径地址
+     */
+    private static final String RANDOM_AVATAR_FILE_PATH = "properties/randomAvatar.properties";
+
+    /**
+     * 随机用户名文件的路径地址
+     */
+    private static final String RANDOM_USERNAME_FILE_PATH = "properties/randomUsername.properties";
+
+    /**
+     * 得到随机的头像
+     */
+    public static String getRandomAvatar() {
+        // 读取匿名头像属性文件
+        InputStream resourceAsStream = RandomUserInfo.class.getClassLoader().getResourceAsStream(RANDOM_AVATAR_FILE_PATH);
+        return getRandomValue(resourceAsStream);
+    }
+
+    /**
+     * 得到随机的用户名
+     */
+    public static String getRandomUserName() {
+        // 读取匿名头像属性文件
+        InputStream resourceAsStream = RandomUserInfo.class.getClassLoader().getResourceAsStream(RANDOM_USERNAME_FILE_PATH);
+        return getRandomValue(resourceAsStream);
+    }
+
+    /**
+     * 得到随机值
+     *
+     * @param resourceAsStream 输入流
+     * @return 返回一个随机值
+     */
+    private static String getRandomValue(InputStream resourceAsStream) {
+        Properties properties = new Properties();
+        try {
+            properties.load(resourceAsStream);
+            resourceAsStream.close();
+        } catch (IOException e) {
+            e.printStackTrace();
+        }
+        int i = new Random(new Date().getTime()).nextInt(properties.size());
+        return (String) properties.get(Integer.toString(i));
+    }
+}

anonymous-group-chat/src/main/java/com/cy/websocket/ChatWebSocket.java

@@ -0,0 +1,85 @@
+package com.cy.websocket;
+
+import com.cy.data.OnlineCount;
+import org.springframework.stereotype.Component;
+
+import javax.websocket.*;
+import javax.websocket.server.ServerEndpoint;
+import java.io.IOException;
+import java.util.concurrent.CopyOnWriteArraySet;
+
+/**
+ * ServerEndpoint注解是一个类层次的注解，它的功能主要是将目前的类定义成一个websocket服务器端,
+ * 注解的值将被用于监听用户连接的终端访问URL地址,客户端可以通过这个URL来连接到WebSocket服务器端
+ */
+@Component
+@ServerEndpoint("/chat")
+public class ChatWebSocket {
+
+    /**
+     * concurrent包的线程安全Set，用来存放每个客户端对应的MyWebSocket对象。若要实现服务端与单一客户端通信的话，可以使用Map来存放，其中Key可以为用户标识
+     */
+    private static CopyOnWriteArraySet<ChatWebSocket> webSocketSet = new CopyOnWriteArraySet<>();
+
+    /**
+     * 与某个客户端的连接会话，需要通过它来给客户端发送数据
+     */
+    private Session session;
+
+    /**
+     * 连接建立成功调用的方法
+     *
+     * @param session 可选的参数。session为与某个客户端的连接会话，需要通过它来给客户端发送数据
+     */
+    @OnOpen
+    public void onOpen(Session session) {
+        this.session = session;
+        webSocketSet.add(this);     //加入set中
+        OnlineCount.addOnlineCount();           //在线数加1
+    }
+
+    /**
+     * 连接关闭调用的方法
+     */
+    @OnClose
+    public void onClose() {
+        webSocketSet.remove(this);  //从set中删除
+        OnlineCount.subOnlineCount();           //在线数减1
+    }
+
+    /**
+     * 收到客户端消息后调用的方法
+     *
+     * @param message 客户端发送过来的消息
+     */
+    @OnMessage
+    public void onMessage(String message) {
+        //群发消息
+        for (ChatWebSocket item : webSocketSet) {
+            try {
+                if (item == this) {
+                    continue;
+                }
+                item.session.getBasicRemote().sendText(dealMassage(message));
+            } catch (IOException e) {
+                e.printStackTrace();
+            }
+        }
+    }
+
+    /**
+     * 发生错误时调用
+     */
+    @OnError
+    public void onError(Throwable error) {
+        error.printStackTrace();
+    }
+
+    /**
+     * 这个方法与上面几个方法不一样。没有用注解，是根据自己需要添加的方法。
+     * 处理消息
+     */
+    private String dealMassage(String message) {
+        return message.replaceAll("<", "&lt;").replaceAll(">", "&gt;");
+    }
+}

anonymous-group-chat/src/main/resources/application.properties

@@ -0,0 +1,4 @@
+# 设置日志级别
+logging.level.root=all
+# 端口号
+server.port=8080