“畅聊”

1：名字解释
首先畅聊就是相当于现在的群发功能，然后可以在相关频道中接收发消息，也可以查看历史消息
2：需求分析

1：打开主页，进行登录功能
2：登陆成功之后，进入主页面
3：主页面显示的是当前具有的频道列表(当前用户所关注的频道)
4：点击某个频道之后，就能看见频道里面的消息内容(某个用户在该频道中发消息，所有在线的用户都能看到)
5：每个用户都能发送消息
6：还有就是历史消息功能，用户登录上线之后，能够看见从上次下线之后发送的所有历史消息记录，也就是这段之间内错过的消息

3：核心技术：websocket
websocket是一个应用层的协议，刚开始学的服务器都是典型的 “一问一答” 模型，也就是说客户端给服务器发送一个请求，服务器处理请求并将响应结果写回给浏览器，使用的都是http协议；重要的是 在聊天的场景中，客户端是没有发送求的，但是服务器却主动的给你发送了数据，这样就叫做 “消息推送”

服务器端

1：在创建类时，使用@ServerEndpoint注释来指定该类所对应的URL路径
2：实现类的一些方法
2.1：onOpen：连接建立调用
2.2：onMessage：收到消息时调用
2.3：onError：连接异常时调用
2.4：onClose：连接关闭时调用
注意： 以上的方法都是不用程序员自己调用，在合适的时机由Tomcat自己进行调用
session.getBasicRemote().sendText()： 这个方法是需要程序员自己调用的，服务器给客户端发送消息的接口：这个方法只要连接建立好，调用这个方法就能写回数据给客户端，无须客户端先发送请求

客户端

1：创建websocket对象，同时指定连接服务器的url
2：给websocket对象注册一些方法
2.1：onOpen：连接建立成功是调用
2.2：onMessage：收到消息时调用
2.3：onError：连接异常时调用
2.4：onClose：连接关闭时调用
websocket.send()：给服务器发送消息

4：数据库的设计：设计好表的结构并创建好实体类
User： 用户信息，本来是用户(User)和频道(Channel)之间的是多对多的关系，在这里我设计成一个用户都关联到了所有的频道，所以是没关系

Channel： 频道

Message： 消息，用来实现历史消息功能

5：实现数据库相关代码：
5.1：创建一个DBUtil类管理获取数据库连接

1：DBUtil工具类实际上是实现了DataSource类的单例版本
2：对于一个简单的应用程序来说，DataSource只需要有一个就好了(正好就可以使用单例模式-—懒汉模式)就可以了

5.2：封装数据库操作—用户DAO

1：新增用户(注册功能)
2：按用户名查找信息(登录功能)
3：按用户ID查找用户信息(把userId转换成昵称的时候使用)
4：更新用户的lastLogout时间，用户下线时更新，为了实现历史记录功能

5.3：封装数据库操作—频道DAO

1：新增频道
2：删除频道
3：查看频道列表
我实现的比较简单，所以就没有实现用户关注频道的功能

5.4：封装数据库操作—消息DAO
主要目的：就是将上次下线到这次上线的消息都查出来

1：新增消息
2：按时间段(mysql中datetime类型是可以直接比较大小的)进行查询消息(把用户上次下线时间点到下次上线的时间点，这两个时间间隔的消息都查出来)

5.5：封装数据库操作—消息中心
主要目的：管理消息记录和用户列表，实现消息转发

1：主要的两个数据结构：
阻塞队列：用来保存消息的队列
哈希表：(ConcurrentHashMap<userId,session>)用来保存在线用户列表
2：实现几个操作这两个数据结构的方法
新增在线的用户
用户下线，要将该用户从在线用户列表中删除
新增消息：就把消息放进阻塞队列中
3：在消息中心构造方法中创建一个线程一直用来扫描消息队列(为了在构造消息中心实例的时候就启动线程)，把队列里面存的消息全部转发给所有在线用户

6：设计前后端交互接口(API设计)







注意：

1：确定好客户端给服务器发送的那些种类的请求
2：服务器收到请求之后应该返回啥样的响应
3：客户端发的大多数请求，都是服务器不能处理的，只有咱们约定好的格式请求，才能正确处理，在这里我们约定的是json格式(它是一种比较常见的数据组织方式) 提前写好将客户端的输入数据转成String类型的
4：同路径下，服务器怎么区分不同的功能，是通过http请求方法来区分的，这种设计叫做restful风格的API，是当下比较流行一种API设计风格
5：以上的都是HTTP接口，使用servlet进行实现就可以了

7：然后就是代码的实现
在这就不一一展示了