首页编程java编程websocket java是什么,java怎么做websocket

websocket java是什么,java怎么做websocket

编程之家2023-10-1197次浏览

大家好,如果您还对websocket java是什么不太了解,没有关系,今天就由本站为大家分享websocket java是什么的知识,包括java怎么做websocket的问题都会给大家分析到,还望可以解决大家的问题,下面我们就开始吧!

websocket java是什么,java怎么做websocket

java socket怎么与websocket对接

这个问题问的不是很专业!准确的说,应该是java如何开发一个websocket协议的服务端程序与js前端对接!因为java socket不是一种协议,他是tcp的实现,而websocket则是一种协议(类似与HTTP,但与其不完全相同).至于实现方式,在tomcat7中的自带的javax打头的jar包中,就有对于websocket的支持,如果你创建了一个web项目,并且引用了tomcat7的server runtime,那么你可以直接对一个编写好的类进行改造成一个websocket的服务端!

比如:

@ServerEndpoint("/wsdemo")//此处指定访问地址,记得端口为tomcat配置的端口,即ws://localhost:8080/projectName/wsdemo

websocket java是什么,java怎么做websocket

publicclassWsDemo{

@OnMessage//直接加注释即可//其他的OnError等类似的

publicvoidOnMessage(xxxEventevent){//单词忘了....

websocket java是什么,java怎么做websocket

event.getBaseRemote().sendText("");//向客户端发送信息

}

}

怎样用java web和websocket实现网页即时通讯

原理

WebSocket protocol。

现很多网站为了实现即时通讯,所用的技术都是轮询(polling)。轮询是在特定的的时间间隔(如每1秒),由浏览器对服务器发出HTTP request,然后由服务器返回最新的数据给客户端的浏览器。这种传统的HTTP request的模式带来很明显的缺点–浏览器需要不断的向服务器发出请求,然而HTTP request的header是非常长的,里面包含的有用数据可能只是一个很小的值,这样会占用很多的带宽。

而比较新的技术去做轮询的效果是Comet–用了AJAX。但这种技术虽然可达到全双工通信,但依然需要发出请求。

在 WebSocket API,浏览器和服务器只需要做一个握手的动作,然后,浏览器和服务器之间就形成了一条快速通道。两者之间就直接可以数据互相传送。在此WebSocket协议中,为我们实现即时服务带来了两大好处:

1. Header

互相沟通的Header是很小的-大概只有 2 Bytes

2. Server Push

服务器的推送,服务器不再被动的接收到浏览器的request之后才返回数据,而是在有新数据时就主动推送给浏览器。

一、项目简介

WebSocket是HTML5一种新的协议,它实现了浏览器与服务器全双工通信,这里就将使用WebSocket来开发网页聊天室,前端框架会使用AmazeUI,后台使用Java,编辑器使用UMEditor。

二、涉及知识点

网页前端(HTML+CSS+JS)和Java

三、软件环境 Tomcat 7 JDK 7 Eclipse JavaEE现代浏览器

四、效果截图

效果1

效果2

五、项目实战

1.新建项目

打开Eclipse JavaEE,新建一个名为Chat的Dynamic Web Project,然后导入处理JSON格式字符串所需要的包,把commons-beanutils-1.8.0.jar、commons-collections-3.2.1.jar、commons-lang-2.5.jar、commons-logging-1.1.1.jar、ezmorph-1.0.6.jar和json-lib-2.4-jdk15.jar这几个包放在WebContent/WEB-INF/lib目录下,最后把项目发布到Tomcat服务器上,到此空项目就搭建完成了。

2.编写前端页面

在WebContent目录下新建一个名为index.jsp的页面,这里使用了AmazeUI框架,它是一个跨屏自适应的前端框架,消息输入框使用了UMEditor,它是一个富文本在线编辑器,能让我们的消息内容多姿多彩。

首先从 AmazeUI官网下载压缩包,然后解压把assets文件夹拷贝到WebContent目录下,这样我们就能使用AmazeUI了。

再从 UEditer官网下载Mini版的JSP版本压缩包,解压后把整个目录拷贝到WebContent目录下,接下来就可以编写前端代码了,代码如下(你可以按照自己的喜好编写):

?

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293<%@ page language="java" contentType="text/html; charset=UTF-8" pageEncoding="UTF-8"%><!DOCTYPE html><html lang="zh"><head><meta charset="utf-8"><meta http-equiv="X-UA-Compatible" content="IE=edge"><meta name="viewport" content="width=device-width, initial-scale=1, maximum-scale=1, user-scalable=no"><title>ShiYanLou Chat</title><!-- Set render engine for 360 browser--><meta name="renderer" content="webkit"><!-- No Baidu Siteapp--><meta http-equiv="Cache-Control" content="no-siteapp"/><link rel="alternate icon" rel="external nofollow" href="assets/i/favicon.ico"><link rel="stylesheet" rel="external nofollow" href="assets/css/amazeui.min.css"><link rel="stylesheet" rel="external nofollow" href="assets/css/app.css"><!-- umeditor css--><link rel="external nofollow" href="umeditor/themes/default/css/umeditor.css" rel="stylesheet"><style>.title{text-align: center;}.chat-content-container{height: 29rem;overflow-y: scroll;border: 1px solid silver;}</style></head><body><!-- title start--><div class="title"><div class="am-g am-g-fixed"><div class="am-u-sm-12"><h1 class="am-text-primary">ShiYanLou Chat</h1></div></div></div><!-- title end--><!-- chat content start--><div class="chat-content"><div class="am-g am-g-fixed chat-content-container"><div class="am-u-sm-12"><ul id="message-list" class="am-comments-list am-comments-list-flip"></ul></div></div></div><!-- chat content start--><!-- message input start--><div class="message-input am-margin-top"><div class="am-g am-g-fixed"><div class="am-u-sm-12"><form class="am-form"><div class="am-form-group"><script type="text/plain" id="myEditor" style="width: 100%;height: 8rem;"></script></div></form></div></div><div class="am-g am-g-fixed am-margin-top"><div class="am-u-sm-6"><div id="message-input-nickname" class="am-input-group am-input-group-primary"><span class="am-input-group-label"><i class="am-icon-user"></i></span><input id="nickname" type="text" class="am-form-field" placeholder="Please enter nickname"/></div></div><div class="am-u-sm-6"><button id="send" type="button" class="am-btn am-btn-primary"><i class="am-icon-send"></i> Send</button></div></div></div><!-- message input end--><!--[if(gte IE 9)|!(IE)]><!--><script src="assets/js/jquery.min.js"></script><!--<![endif]--><!--[if lte IE 8 ]><script src="http://libs.baidu.com/jquery/1.11.1/jquery.min.js"></script><![endif]--><!-- umeditor js--><script charset="utf-8" src="umeditor/umeditor.config.js"></script><script charset="utf-8" src="umeditor/umeditor.min.js"></script><script src="umeditor/lang/zh-cn/zh-cn.js"></script><script>$(function(){//初始化消息输入框var um= UM.getEditor('myEditor');//使昵称框获取焦点$('#nickname')[0].focus();});</script></body></html>

编写完成之后启动Tomcat服务器,然后访问 http://localhost:8080/Chat/index.jsp,会看到如下界面。

3.编写后台代码

新建一个com.shiyanlou.chat的包,在包中创建一个名为ChatServer的类,从JavaEE 7开始就统一了WebSocket的API,因此无论是什么服务器,用Java写的代码都是一样的,代码如下:

?

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950 package com.shiyanlou.chat;import java.text.SimpleDateFormat;import java.util.Date;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;import net.sf.json.JSONObject;/***聊天服务器类*@author shiyanlou**/@ServerEndpoint("/websocket")public class ChatServer{private static final SimpleDateFormat DATE_FORMAT= new SimpleDateFormat("yyyy-MM-dd HH:mm");//日期格式化@OnOpenpublic void open(Session session){//添加初始化操作}/***接受客户端的消息,并把消息发送给所有连接的会话*@param message客户端发来的消息*@param session客户端的会话*/@OnMessagepublic void getMessage(String message, Session session){//把客户端的消息解析为JSON对象JSONObject jsonObject= JSONObject.fromObject(message);//在消息中添加发送日期jsonObject.put("date", DATE_FORMAT.format(new Date()));//把消息发送给所有连接的会话for(Session openSession: session.getOpenSessions()){//添加本条消息是否为当前会话本身发的标志jsonObject.put("isSelf", openSession.equals(session));//发送JSON格式的消息openSession.getAsyncRemote().sendText(jsonObject.toString());}}@OnClosepublic void close(){//添加关闭会话时的操作}@OnErrorpublic void error(Throwable t){//添加处理错误的操作}}

4.前后台交互

后台写完了,前台要用WebSocket连接后台,需要新建一个WebSocket对象,然后就可以和服务器端进行交互,从浏览器发送消息给服务器端,同时要验证输入框的内容是否为空,然后接受服务端发送的消息,把它们动态地添加到聊天内容框中,在

?

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354 var um= UM.getEditor('myEditor');$('#nickname')[0].focus();//新建WebSocket对象,最后的/websocket对应服务器端的@ServerEndpoint("/websocket")var socket= new WebSocket('ws://${pageContext.request.getServerName()}:${pageContext.request.getServerPort()}${pageContext.request.contextPath}/websocket');//处理服务器端发送的数据socket.onmessage= function(event){addMessage(event.data);};//点击Send按钮时的操作$('#send').on('click', function(){var nickname=$('#nickname').val();if(!um.hasContents()){//判断消息输入框是否为空//消息输入框获取焦点um.focus();//添加抖动效果$('.edui-container').addClass('am-animation-shake');setTimeout("$('.edui-container').removeClass('am-animation-shake')", 1000);} else if(nickname==''){//判断昵称框是否为空//昵称框获取焦点$('#nickname')[0].focus();//添加抖动效果$('#message-input-nickname').addClass('am-animation-shake');setTimeout("$('#message-input-nickname').removeClass('am-animation-shake')", 1000);} else{//发送消息socket.send(JSON.stringify({content: um.getContent(),nickname: nickname}));//清空消息输入框um.setContent('');//消息输入框获取焦点um.focus();}});//把消息添加到聊天内容中function addMessage(message){message= JSON.parse(message);var messageItem='<li class="am-comment'+(message.isSelf?'am-comment-flip':'am-comment')+'">'+'<a rel="external nofollow" rel="external nofollow" href="javascript:void(0)"><img src="assets/images/'+(message.isSelf?'self.png':'others.jpg')+'" alt="" width="48" height="48"/></a>'+'<div><header><div>'+'<a rel="external nofollow" rel="external nofollow" href="javascript:void(0)">'+ message.nickname+'</a><time>'+ message.date+'</time></div></header>'+'<div>'+ message.content+'</div></div></li>';$(messageItem).appendTo('#message-list');//把滚动条滚动到底部$(".chat-content-container").scrollTop($(".chat-content-container")[0].scrollHeight);}

到这步,简单的网页聊天室就完成了,你可以多开几个窗口或在局域网中邀请小伙伴们来一起测试。

六、小结

本次项目课使用WebSocket实现了简单的网页聊天室,其实WebSocket不仅可以应用于浏览器,也可以应用于桌面客户端。

java怎么做websocket

我不知道你想用websocket实现什么样的功能,一般配合HTML5的话websocket可以解决服务端和客户端消息实时传递的问题,如消息推送(webQQ这种)。它的初始连接是http转成websocket连接。

实现的话要做两件事,一端是在服务器实现service,这个有点像tcplistener一样;

另一个是客户端(浏览器)开发,可以用JS实现:

<html>

<head>

<meta

charset="utf-8"

/>

<script

type="text/javascript">

var

host

=

'127.0.0.1';

var

port

=

8080;

var

url

=

'ws://'+host+':'+port+'/';

var

w

=

new

WebSocket(url);

//构建于服务器之间的连接通信

<!--var

audioElement

=

document.createElement('audio');

-->

<!--audioElement.setAttribute('src',

'qqmsg.mp3');-->

w.onopen

=

function()//通过onopen事件句柄来监听socket的打开事件

{

$('chat-box').innerHTML

=

'已连接到服务器......<br/>';

}

w.onmessage

=

function(e)//用onmessage事件句柄接受服务器传过来的数据

{

var

msg

=

e.data;

var

chatBox

=

$('chat-box');

//

audioElement.play();

chatBox.innerHTML

=

chatBox.innerHTML+msg+'<br/>';

}

function

send()//使用send方法向服务器发送数据

{

var

talk

=

$('talk');

var

nike

=

$('nike');

w.send('<strong

style="color:red">'+nike.value+':</strong>'+talk.value);

}

function

$(id)

{

return

document.getElementById(id);

}

</script>

</head>

<body>

<div

id="chat-box"

style="border:1px

solid

#cccccc;

width:400px;

height:400px;

overflow:scroll;"></div>

昵称:

<input

type="text"

id="nike"/>

<br/>

内容:

<input

type="text"

id="talk"/>

<input

type="button"

id="send"

onClick="send();"

value="发送"/>

</body>

可参考IBM社区

http://www.ibm.com/developerworks/cn/web/1112_huangxa_websocket/

</html>

关于websocket java是什么和java怎么做websocket的介绍到此就结束了,不知道你从中找到你需要的信息了吗 ?如果你还想了解更多这方面的信息,记得收藏关注本站。

什么是java se6,javase是什么java 浮点型是什么意思(java里的浮点数是什么意思)