标签：web html5 server-sent event
服务端代码
server.SimpleSocketServer
package server;
import java.io.BufferedReader;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.Random;
public class SimpleSocketServer {
public void doAccept(Socket socket) throws Exception{
InputStream is = socket.getInputStream();
System.out.println("receive below information from client ... ");
byte[] bytes = new byte[1024];
int length = -1;
while((length=is.read(bytes, 0, 1024))>0){
int breakLineCount = 0;
for(int i=0;i<length;i++){
char c = (char) bytes[i];
System.out.print(c);
if(‘\n‘==c){
breakLineCount++;
}
}
if(breakLineCount>1){
break;
}
}
String response = getSimpleRespose();
OutputStream os = socket.getOutputStream();
os.write(response.getBytes());
os.flush();
socket.close();
}
private String getSimpleRespose() throws Exception{
InputStream is = this.getClass().getResourceAsStream("simple_response");
BufferedReader br = new BufferedReader(new InputStreamReader(is));
String line = null;
StringBuilder response = new StringBuilder();
while((line=br.readLine())!=null){
response.append(line).append("\n");
}
String text = getRandomRes();
response.append("Content-Length:"+text.length()).append("\n\n")
.append(text);
return response.toString();
}
private String getRandomRes(){
Random random = new Random();
if(random.nextInt(10)%2==0){
return getDataWithEventRes();
}else{
return getDataRes();
}
}
private String getDataRes(){
Random random = new Random();
int randomValue = random.nextInt(1000);
String text = "data:the random value is : "+randomValue;
text+="\n\n";
return text;
}
private String getDataWithEventRes(){
Random random = new Random();
int randomValue = random.nextInt(1000);
String text = "data:the random value is : "+randomValue+"\n";
text+="event:myevent";
text+="\n\n";
return text;
}
public void start() throws Exception{
ServerSocket serverSocket = new ServerSocket(8888);
while(true){
Socket socket = serverSocket.accept();
doAccept(socket);
}
}
public static void main(String[] args) throws Exception{
new SimpleSocketServer().start();
}
}server/simple_response
HTTP/1.1 200 OK Content-Type: text/event-stream
客户端html
<!DOCTYPE html>
<html>
<body>
<h1>获得服务器更新</h1>
<div id="result"></div>
<script>
if(typeof(EventSource)!=="undefined"){
var source=new EventSource("http://localhost:8888/");
source.onopen = function(){
console.log("connection opened ... ");
};
source.onmessage=function(event){
document.getElementById("result").innerHTML+=event.data + "<br />";
};
source.addEventListener("myevent", function(event) {
console.log("event:"+event.type);
console.log(event.data);
});
source.onerror = function(){
console.log("connection close ... ");
};
}else{
document.getElementById("result").innerHTML="Sorry, your browser does not support server-sent events...";
}
</script>
</body>
</html>HTML5 服务器发送事件(server-sent event)
标签：web html5 server-sent event
原文地址：http://antlove.blog.51cto.com/10057557/1673841
