关键词：
引入spring-websocket包
<dependencies>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-websocket</artifactId>
<version>$websocket.version</version>
</dependency>
</dependencies>1.创建聊天记录信实体类MessageLog
package com.bjhy.ven.domain;
import java.util.Date;
import javax.persistence.Entity;
import javax.persistence.Id;
import javax.persistence.JoinColumn;
import javax.persistence.ManyToOne;
import javax.persistence.Table;
import org.springframework.format.annotation.DateTimeFormat;
/**
* 聊天记录信息表
* @author xiaowen
*
*/
@Entity
@Table(name = "t_message")
public class MessageLog
//id
@Id
private String id;
//发送的消息
private String msg;
// 发送者
@ManyToOne
@JoinColumn(name = "fromId")
private SysUser from;
//接收者
@ManyToOne
@JoinColumn(name = "toId")
private SysUser to;
//发送时间
@DateTimeFormat(pattern="yyyy-MM-dd HH:mm:ss")
private Date createDate;
/**
* @return the id
*/
public String getId()
return id;
/**
* @param id the id to set
*/
public void setId(String id)
this.id = id;
/**
* @return the msg
*/
public String getMsg()
return msg;
/**
* @param msg the msg to set
*/
public void setMsg(String msg)
this.msg = msg;
/**
* @return the from
*/
public SysUser getFrom()
return from;
/**
* @param from the from to set
*/
public void setFrom(SysUser from)
this.from = from;
/**
* @return the to
*/
public SysUser getTo()
return to;
/**
* @param to the to to set
*/
public void setTo(SysUser to)
this.to = to;
/**
* @return the createDate
*/
public Date getCreateDate()
return createDate;
/**
* @param createDate the createDate to set
*/
public void setCreateDate(Date createDate)
this.createDate = createDate;
package com.bjhy.ven.service;
import com.bjhy.ven.biz.commons.service.BizCommonService;
import com.bjhy.ven.domain.MessageLog;
public interface MessageService extends BizCommonService<MessageLog, String>
/**
* 保存message
*/
public void saveAndSendMessage(String from,String to,String message);
package com.bjhy.ven.biz.commons.service;
import java.io.Serializable;
import java.util.List;
import org.springframework.data.domain.Sort;
import com.bjhy.platform.commons.pager.Condition;
import com.bjhy.platform.commons.pager.PageBean;
/**
*
* 公用业务接口
* @author wbw
*
* @param <T> 实体对象
* @param <PK> 实体对象id
*/
public interface BizCommonService<T,PK extends Serializable>
/**
* 根据对象的ID查询对象信息
* @param id
* 对象ID
* @return
* 返回查询的对象
*/
public T findById(PK id);
/**
* 查询所有数据
*/
public List<T> findAll(Sort sort);
/**
* 根据条件查询数据
* @param conditions 条件对象
*/
public List<T> findByCondition(Condition... conditions);
/**
* 保存一个对象
* @param entity
* 保存的对象
*/
public PK save(T entity);
/**
* 修改一个对象
* @param entity
* 修改的对象
*/
public void update(T entity);
/**
* 保存或者修改一个对象
* @param entity
* 保存或者修改的对象
* @return
* 返回保存或者修改的对象的ID
*/
public PK saveOrUpdate(T entity);
/**
* 根据ID删除一个或者多个对象
* @param ids
* 删除的对象ID数组
* @throws Exception
*/
@SuppressWarnings("unchecked")
public void deleteById(PK... ids);
/**
* 分页查询
* @param pageBean 分页对象
*/
void pageQuery(PageBean pageBean);
package com.bjhy.ven.service.impl;
import java.util.Date;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.messaging.simp.SimpMessagingTemplate;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import com.bjhy.platform.persist.dao.CommonRepository;
import com.bjhy.ven.biz.commons.service.impl.AbstractBizCommonService;
import com.bjhy.ven.dao.MesasgeRepository;
import com.bjhy.ven.domain.MessageLog;
import com.bjhy.ven.domain.SysUser;
import com.bjhy.ven.service.MessageService;
import com.bjhy.ven.service.SysUserService;
@Service
@Transactional
public class MessageServiceImpl extends AbstractBizCommonService<MessageLog, String> implements MessageService
// 基础查询ql
private static final String BASE_FIELD_QUERY = "select m.id,m.msg,m.createDate,fromer.userName,toer.userName from MessageLog m left join m.from fromer left join m.to toer where 1=1 ";
@Autowired
private MesasgeRepository mesasgeRepository;
@Autowired
private SysUserService userService;
@Autowired
private SimpMessagingTemplate template;
@Override
protected CommonRepository<MessageLog, String> getRepository()
return mesasgeRepository;
@Override
protected String getPageQl()
return BASE_FIELD_QUERY;
@Override
public void saveAndSendMessage(String from, String to, String message)
String convertMessage ="from:'"+from+"',to:'"+to+"',message:'"+message+"'";
template.convertAndSend("/topic/"+to,convertMessage);
//判断非空
SysUser userFrom = userService.findByUserName(from);
SysUser userTo = userService.findByUserName(from);
MessageLog msg = new MessageLog();
msg.setFrom(userFrom);
msg.setTo(userTo);
msg.setMsg(message);
msg.setCreateDate(new Date());
this.save(msg);
package com.bjhy.ven.biz.commons.service.impl;
import java.io.Serializable;
import java.lang.reflect.Field;
import java.lang.reflect.ParameterizedType;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.Date;
import java.util.List;
import org.springframework.data.domain.Sort;
import org.springframework.stereotype.Component;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.util.StringUtils;
import com.bjhy.platform.commons.exception.PlatformException;
import com.bjhy.platform.commons.pager.Condition;
import com.bjhy.platform.commons.pager.Order;
import com.bjhy.platform.commons.pager.PageBean;
import com.bjhy.platform.persist.dao.CommonRepository;
import com.bjhy.platform.util.BeanUtils;
import com.bjhy.ven.biz.commons.service.BizCommonService;
/**
* 公用业务接口抽象实现类
* @author wbw
*/
@Component
@Transactional
public abstract class AbstractBizCommonService<T,PK extends Serializable> implements BizCommonService<T, PK>
@SuppressWarnings("unchecked")
protected Class<T> entityClass = (Class<T>)((ParameterizedType)getClass().getGenericSuperclass()).getActualTypeArguments()[0];
/**
* 返回实现repository接口的实例对象
*/
protected abstract CommonRepository<T, PK> getRepository();
/**
* 返回分页ql语句
*/
protected abstract String getPageQl();
@Override
public T findById(PK id)
return getRepository().findOne(id);
@Override
public List<T> findAll(Sort sort)
return getRepository().findAll(sort);
@SuppressWarnings("unchecked")
@Override
public List<T> findByCondition(Condition... conditions)
return (List<T>)getRepository().doList(getPageQl(), Arrays.asList(conditions), new ArrayList<Order>(), false);
@SuppressWarnings("unchecked")
@Override
public PK save(T entity)
PK id = null;
try
//判断是否有创建时间字段
try
Field createDateField = entity.getClass().getDeclaredField("createDate");
if(createDateField != null)
createDateField.setAccessible(true);
createDateField.set(entity, new Date());
catch (NoSuchFieldException e)
getRepository().store(entity);
Field field = entity.getClass().getDeclaredField("id");
field.setAccessible(true);
id = (PK)field.get(entity);
catch (Exception e)
e.printStackTrace();
throw new PlatformException(e.getMessage());
return id;
@SuppressWarnings("unchecked")
@Override
public void update(T entity)
try
Field field = entity.getClass().getDeclaredField("id");
field.setAccessible(true);
PK id = (PK)field.get(entity);
T sourceEntity = getRepository().findOne(id);
BeanUtils.copyNotNullProperties(entity, sourceEntity);
getRepository().update(sourceEntity);
catch (Exception e)
e.printStackTrace();
throw new RuntimeException(e);
@SuppressWarnings("unchecked")
@Override
public PK saveOrUpdate(T entity)
try
Field field = entity.getClass().getDeclaredField("id");
field.setAccessible(true);
PK id = (PK)field.get(entity);
if(StringUtils.isEmpty(id))
return save(entity);
else
update(entity);
return id;
catch (Exception e)
e.printStackTrace();
throw new PlatformException(e.getMessage());
@SuppressWarnings("unchecked")
@Override
public void deleteById(PK... ids)
for (PK pk : ids)
getRepository().delete(pk);
@Override
public void pageQuery(PageBean pageBean)
getRepository().doPager(pageBean, getPageQl());
package com.bjhy.ven.dao;
import com.bjhy.platform.persist.dao.CommonRepository;
import com.bjhy.ven.domain.MessageLog;
public interface MesasgeRepository extends CommonRepository<MessageLog, String>
package com.bjhy.platform.persist.dao;
import java.io.Serializable;
import java.util.List;
import java.util.Map;
import org.springframework.data.jpa.repository.JpaRepository;
import org.springframework.data.repository.NoRepositoryBean;
import com.bjhy.platform.commons.pager.Condition;
import com.bjhy.platform.commons.pager.Order;
import com.bjhy.platform.commons.pager.PageBean;
/**
*
* 自定义repository的方法接口
*/
@NoRepositoryBean
public interface CommonRepository<T, ID extends Serializable> extends JpaRepository<T, ID>
/**
* 保存对象<br/>
* 注意：如果对象id是字符串，并且没有赋值，该方法将自动设置为uuid值
* @param item
* 持久对象，或者对象集合
* @throws Exception
*/
public void store(Object... item);
/**
* 更新对象数据
*
* @param item
* 持久对象，或者对象集合
* @throws Exception
*/
public void update(Object... item);
/**
* 执行ql语句
* @param qlString 基于jpa标准的ql语句
* @param values ql中的?参数值,单个参数值或者多个参数值
* @return 返回执行后受影响的数据个数
*/
public int executeUpdate(String qlString, Object... values);
/**
* 执行ql语句
* @param qlString 基于jpa标准的ql语句
* @param params key表示ql中参数变量名，value表示该参数变量值
* @return 返回执行后受影响的数据个数
*/
public int executeUpdate(String qlString, Map<String, Object> params);
/**
* 执行ql语句，可以是更新或者删除操作
* @param qlString 基于jpa标准的ql语句
* @param values ql中的?参数值
* @return 返回执行后受影响的数据个数
* @throws Exception
*/
public int executeUpdate(String qlString, List<Object> values);
/**
* 结合提供的分页信息，获取指定条件下的数据对象
* @param pageBean 分页信息
* @param qlString 基于jpa标准的ql语句
*/
public void doPager(PageBean pageBean, String qlString);
/**
* 结合提供的分页信息，获取指定条件下的数据对象
* @param pageBean 分页信息
* @param qlString 基于jpa标准的ql语句
* @param cacheable 是否启用缓存查询
*/
public void doPager(PageBean pageBean,String qlString,boolean cacheable);
/**
* 结合提供的分页信息，获取指定条件下的数据对象
* @param pageBean 分页信息
* @param qlString 基于jpa标准的ql语句
* @param params key表示ql中参数变量名，value表示该参数变量值
*/
public void doPager(PageBean pageBean, String qlString,
Map<String, Object> params);
/**
* 结合提供的分页信息，获取指定条件下的数据对象
* @param pageBean 分页信息
* @param qlString 基于jpa标准的ql语句
* @param values ql中的?参数值
*/
public void doPager(PageBean pageBean, String qlString, List<Object> values);
/**
* 结合提供的分页信息，获取指定条件下的数据对象
* @param pageBean 分页信息
* @param qlString 基于jpa标准的ql语句
* @param values ql中的?参数值
*/
public void doPager(PageBean pageBean, String qlString, Object... values);
/**
* 批量删除数据对象
* @param entityClass
* @param primaryKeyValues
* @return
*/
public int batchDeleteByQl(Class<?> entityClass,Object...primaryKeyValues);
/**
* 批量删除数据对象
* @param entityClass
* @param pKeyVals 主键是字符串形式的
* @return
* @throws Exception
*/
public int batchDeleteByQl(Class<?> entityClass,String...pKeyVals);
/**
* @param qlString 查询hql语句
* @param values hql参数值
* @param conditions 查询条件
* @param orders 排序条件
* @return
*/
public List<?> doList(String qlString, List<Object> values, List<Condition> conditions, List<Order> orders, boolean sqlable);
public List<?> doList(String qlString, List<Condition> conditions, List<Order> orders, boolean sqlable);
5.消息服务前端控制器MessageController
package com.bjhy.ven.controller.messager;
import java.util.List;
import javax.servlet.http.HttpSession;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;
import com.bjhy.ven.domain.SysUser;
import com.bjhy.ven.service.MessageService;
/**
* webSocket 发送接收消息controller
* @author xiaowen
*
*/
import com.bjhy.ven.service.SysUserService;
@Controller
@RequestMapping("/message")
public class MessageController
@Autowired
private MessageService messageService;
@Autowired
private SysUserService sysUserService;
private static final String MESSAGE_INDEX="message/message";
private static final String STAUTS="ok";
/**
* 请求首页
* @return
*/
@RequestMapping("/index")
public String index()
return MESSAGE_INDEX;
/**
* 发送消息
* @param from 发送消息者
* @param to 接受消息者
* @param message 消息
* @return
*/
@RequestMapping("/sendMessage")
public @ResponseBody String recieveMessage(String from,String to,String message)
messageService.saveAndSendMessage(from, to, message);
return STAUTS;
/**
* 获取在线用户
* @return
*/
@RequestMapping("/onlineUsers")
public @ResponseBody List<SysUser> onlineUsers(HttpSession session)
String sessionUserName = (String) session.getAttribute("username");
return sysUserService.findUserByUserName(sessionUserName);
<!DOCTYPE html>
<html>
<head>
<meta charset="UTF-8">
<title>聊天</title>
$static_context$appJs$jquery$toast$bootstrap$socketJS
<script type="text/javascript" src="$request.contextPath/js/message/message.js"></script>
</head>
<body>
<input type="hidden" value="$username" id="username" />
<input type="hidden" id="to"/>
<div style="margin-bottom:20px"></div>
<div class="container">
<div class="row">
<!-- 在线用户列表 -->
<div class="col-md-3">
<div class="list-group">
<ul class="list-group" id="online">
<li class="list-group-item active">在线用户</li>
</ul>
</div>
</div>
<!-- 聊天窗体-->
<div class="col-md-9" id="chatwindows">
</div>
</div>
<!-- 发送消息文本 -->
<div class="row" style="display:none" id="send_text">
<div class="col-md-2"></div>
<div class="col-md-1"></div>
<div class="col-md-9" >
<textarea id="messgeContext" class="form-control" rows="3" placeholder="按下回车键发送消息...."></textarea>
</div>
</div>
<!-- 发送按钮 -->
<div class="row" style="display:none" id="execute_send">
<div class="col-md-2"></div>
<div class="col-md-4">
</div>
<div class="col-md-5" style="margin-top:5px;">
<button type="button" class="btn btn-danger btn_lg" id="btn_close" >关闭</button>
<button type="button" class="btn btn-danger btn_lg" id="btn_send" >发送</button>
</div>
</div>
</div>
</body>
</html>页面的呈现效果
6.创建message.js处理消息动作
var messageArr = ;
$(function()
mseeage.init();
bindEvent.init();
);
var bindEvent =
//初始化
init :function()
this.sendEvent();
,
//渲染视图
viewEvent: function()
$(".list-group-item").not(":eq(0)").click(function()
var name = $(this).attr("value");
$(".panel-primary").hide();
$("#"+name).show();
$("#to").val(name);
messageArr[name] = null;
$(".list-group-item[value='" + name + "']").find("span").html("");
$("#send_text").show();
$("#execute_send").show();
);
,
//发送消息
sendEvent : function()
//发送
$('#btn_send').click(function()
mseeage.snedMessage();
);
//关闭
$('#btn_close').click(function()
$(".panel-primary").remove();
$("#send_text").hide();
$("#execute_send").hide();
);
//enter事件
$(window).keydown(function(event)
if(event.keyCode ==13)
mseeage.snedMessage();
);
var mseeage =
init : function()
this.initOnlineUsers();
this.initSocket();
,
//初始化在线用户
initOnlineUsers : function()
$.ajax(
url:contextPath + "/message/onlineUsers",
success : function(data)
var $html =""
var $content = "";
for (var i = 0; i < data.length; i++)
var userName = data[i].userName;
var alias = data[i].alias;
$html +=" <li class='list-group-item' value='"+alias+"'>"+userName+"<span class='badge'></span></li>"
$content +="<div class='panel panel-primary' style='height:400px;display:none' id='"+alias+"'>" +
" <div class='panel-heading'>聊天栏--<span>"+userName+"</span></div>" +
"<div id='tolk' class='panel-body'></div></div>";
$('#chatwindows').append($content);
$("#online").not("li:eq(0)").append($html);
//绑定点击事件
bindEvent.viewEvent();
)
,
//初始化
initSocket : function()
var userName = $("#username").val();
var socket = new SockJS(contextPath + "/" + wsEndPoint);
var stompClient = Stomp.over(socket);
stompClient.connect(, function(frame)
stompClient.subscribe('/topic/'+userName, function(greeting)
var result=eval("("+greeting.body+")");
console.log(result);
var msg_="<br>"+result.from+"说："+result.message;
$("#"+result.from).find("div:eq(1)").append(msg_);
if($('#to').val() != result.from)
if(messageArr[result.from])
messageArr[result.from]++;
else
messageArr[result.from] = 1;
$(".list-group-item[value='" + result.from + "']").find("span").html(messageArr[result.from]);
);
);
,
//发送消息
snedMessage : function()
var messge = $("#messgeContext").val();
var from = $("#username").val();
var to = $("#to").val();
if(messge.trim().length>0 && $("#to").val())
var data =
from : from,
to :to,
message : messge
$.ajax(
url:contextPath + "/message/sendMessage",
data: data,
success : function(data)
$("#messgeContext").val("");
)
else
toastr.warning("请输入消息!");
;
关于websocket配置
1.注册socket.js、stomp.js资源,实现ServletContextAware接口,在页面上通过$socketJs就可以引用js
package com.bjhy.platform.websocket.client;
import javax.servlet.ServletContext;
import org.springframework.stereotype.Component;
import org.springframework.web.context.ServletContextAware;
@Component
public class RegistrySocketJS implements ServletContextAware
public final static String GLOBAL_ENDPOINT = "platform-ws";
private final static String SOCKET_JS = "socketJS";
@Override
public void setServletContext(ServletContext servletContext)
String contextPath = servletContext.getContextPath();
servletContext.setAttribute(SOCKET_JS,buildSocketJSResource(contextPath));
private String buildSocketJSResource(String contextPath)
String socketGloablJS = "<script type=\\"text/javascript\\" >var wsEndPoint = '" + GLOBAL_ENDPOINT + "';</script>";
String socketJS = "<script type=\\"text/javascript\\" src=\\"" + contextPath + "/websocket/js/sockjs.min.js\\"></script>";
String stompJS = "<script type=\\"text/javascript\\" src=\\"" + contextPath + "/websocket/js/stomp.min.js\\"></script>";
return socketGloablJS + socketJS + stompJS;
package com.bjhy.platform.websocket.config;
import org.springframework.context.annotation.Configuration;
import org.springframework.messaging.simp.config.MessageBrokerRegistry;
import org.springframework.web.socket.config.annotation.AbstractWebSocketMessageBrokerConfigurer;
import org.springframework.web.socket.config.annotation.EnableWebSocketMessageBroker;
import org.springframework.web.socket.config.annotation.StompEndpointRegistry;
@Configuration
@EnableWebSocketMessageBroker
public class WebSocketConfig extends AbstractWebSocketMessageBrokerConfigurer
@Override
public void registerStompEndpoints(StompEndpointRegistry registry)
registry.addEndpoint("/platform-ws").withSockJS();
@Override
public void configureMessageBroker(MessageBrokerRegistry registry)
registry.setApplicationDestinationPrefixes("/app");
registry.enableSimpleBroker("/topic", "/quene");
7.测试
简易版聊天系统实现socketvsnio两种实现方式
1.Socket方式实现简易聊天效果1.1服务端Server.java123456789101112131415161718192021222324252627282930313233package com.example.socket.server;import java.io.IOException;import java.net.InetAddress;impo 查看详情
ajaxphpjavascriptmysql实现简易的无刷新在线聊天室
...jax的相关的知识，就做了个简单的在线网络聊天室。思路实现聊天室，基本上就是通过Ajax来传递数据，让PHP来实现对数据的差入和查找，再交给前端JavaScript实现页面的更新，达到即时聊天的功能。消息显 查看详情
用运gui实现简易的聊天室客户端
day389.使用javanio实现简易在线多人聊天室-nio(代码片段)
使用JavaNIO实现简易在线多人聊天室一、服务端代码packagechatroom.server;importjava.io.IOException;importjava.net.InetSocketAddress;importjava.nio.ByteBuffer;importjava.nio.channels.*;importjava.nio.charset.Charset;importja 查看详情
nio代码实现简易多人聊天(代码片段)
这几天在学习nio相关知识。实现了一个简单的多人聊天程序。服务端代码;1importjava.io.IOException;2importjava.net.InetSocketAddress;3importjava.nio.ByteBuffer;4importjava.nio.channels.*;5importjava.nio.charset.Charset;6importjava.util.* 查看详情
vue使用websocket模拟实现聊天功能-简易版(代码片段)
vue使用WebSocket模拟实现聊天功能-简易版效果展示两个浏览器相互模拟1.创建模拟node服务在vue根目录下创建server.js文件模拟后端服务器**在server终端目录下载**npminstall--sws2.编写server.js文件代码如下varuserNum=0;//统计在线人数varchat... 查看详情
vue+socket.io实现一个简易聊天室
vue+vuex+elementUi+socket.io实现一个简易的在线聊天室，提高自己在对vue系列在项目中应用的深度。因为学会一个库或者框架容易，但要结合项目使用一个库或框架就不是那么容易了。功能虽然不多，但还是有收获... 查看详情
实现简易聊天室
预备工作：（1）读取文件的时候可能会遇到多个文件一起传，可以用线程池。（2）发送不同类型的请求时，如发送的是聊天信息，发送的是文件，发送的是好友上线请求等，但对于接受者来说都是字节流无法分别，这就需要我... 查看详情
《基于node.js实现简易聊天室系列之引言》
简述：这个聊天室是基于Node.js实现的，完成了基本的实时通信功能。在此之前，对node.js和mongodb一无所知，但是通过翻阅博客，自己动手基本达到了预期的效果。技术，不应该是闭门造车，而是学会分享总结才能进... 查看详情
day389.使用javanio实现简易在线多人聊天室-nio(代码片段)
使用JavaNIO实现简易在线多人聊天室一、服务端代码packagechatroom.server;importjava.io.IOException;importjava.net.InetSocketAddress;importjava.nio.ByteBuffer;importjava.nio.channels.*;importjava.nio.charset.Charset;importjava.util.Iterator;importjava.util.Set;/******@author阿... 查看详情
springboot+websocket实现简易聊天室
①：什么是WebSocket？?WebSocket是一种在单个TCP连接上进行全双工通信的协议?根据这个定义有两个注意的地方：1.什么是协议？?协议就是相互通信的计算机双方必须共同遵守的一组约定。2.WebSocket协议和HTTP协议的区别？?1）HTTP协议... 查看详情
laravel+swoole打造im简易聊天室(代码片段)
Laravel+Swoole打造IM简易聊天室应用场景：实现简单的即时消息聊天室(一)扩展安装(二)webSocket服务端代码(三)客户端实现应用场景：实现简单的即时消息聊天室(一)扩展安装peclinstallswoole安装完成后可以通过以下命令检测Sw... 查看详情
laravel+swoole打造im简易聊天室(代码片段)
Laravel+Swoole打造IM简易聊天室应用场景：实现简单的即时消息聊天室(一)扩展安装(二)webSocket服务端代码(三)客户端实现应用场景：实现简单的即时消息聊天室(一)扩展安装peclinstallswoole安装完成后可以通过以下命令检测Sw... 查看详情
《基于node.js实现简易聊天室系列之详细设计》
一个完整的项目基本分为三个部分：前端、后台和数据库。依照软件工程的理论知识，应该依次按照以下几个步骤：需求分析、概要设计、详细设计、编码、测试等。由于缺乏相关知识的储备，导致这个Demo系列的文章层次不是... 查看详情
如何使用 Spring-websocket 拒绝基于用户权限的主题订阅
】如何使用Spring-websocket拒绝基于用户权限的主题订阅【英文标题】：HowtorejecttopicsubscriptionbasedonuserrightswithSpring-websocket【发布时间】：2014-02-2812:36:21【问题描述】：我正在实现一个版本的股票应用程序，其中服务器能够根据用户... 查看详情
socket编程一实现简易的聊天功能以及文件传输
...言哦。题外话就扯这么多了，接着还是上技术。看看今天实现的功能效果图：可以这里使用多台手机进行通讯，【凤歌】我采用的服务器发送消息。是不是只有发送消息，有些显得太单 查看详情
socket入门笔记用tcpclient实现一个简易聊天室
效果 实现思路使用TcpListener建一个服务器,接收所有客户端发送的消息,然后由服务器再发送到其他客户端客户端使用TcpClient,发消息给服务器,接收服务器的消息,不和其他客户端直接交互服务器端接收客户端开启一个线程,死循... 查看详情
网络编程之java简易聊天室实现
最近浅学习了一些关于网络编程方面的知识，视频是跟着狂神学习的，可能学习的不是很深说到网络，相信大家都对TCP、UDP和HTTP协议这些都不是很陌生，学习这部分应该先对端口、Ip地址这些基础知识有一定了解，后面我们都是... 查看详情