用javaapplet方式实现服务器推技术

共13个文件

class：6个

jar：3个

java：2个

java

applet

服务器推

5星 · 超过95%的资源需积分: 10 6 浏览量 2010-11-18 14:52:15 上传评论收藏 1.23MB RAR 举报

Java Applet是Java技术在Web应用中的早期形式，它允许开发者在浏览器中嵌入小程序，以提供交互式和动态的功能。在这个场景中，我们将探讨如何使用Java Applet来实现服务器推（Server-Side Push）技术，这是一个使得服务器能够主动向客户端发送数据而非等待客户端请求的机制，特别适用于实时性要求高的应用，如温度监控。服务器推技术通常用于实时数据更新，例如股票报价、在线聊天或实时天气预报等。传统的HTTP协议是基于请求-响应模型的，而服务器推打破了这种模式，使服务器可以在需要时主动推送信息。在Java Applet中实现服务器推，通常会利用Socket编程或者持久连接（Persistent Connections）。Applet在客户端运行，可以创建一个到服务器的Socket连接，保持这个连接的打开状态，以便服务器可以在有新数据时立即通过这个连接发送给客户端。这种方式的一个挑战是如何处理网络中断或者浏览器刷新等情况，需要有适当的恢复机制。描述中提到的"温度监控"是一个很好的应用示例。可以设想，服务器端收集来自各种传感器的温度数据，然后通过服务器推技术将这些实时数据推送给客户端的Java Applet。Applet接收到数据后，可以更新显示界面，展示当前的温度状况。在DOS环境下启动服务端，意味着我们需要在命令行界面操作服务器应用程序，这可能涉及到启动监听特定端口的Java服务程序。而Tomcat是一个流行的Java应用服务器，可以用于部署和运行包含Java Applet的Web应用。部署过程通常包括将Applet的.class文件放入Tomcat的Web应用目录下，并在HTML页面中正确引用Applet的代码和参数。 "运行，相当震撼！有介绍！"这部分可能指的是在部署和运行Java Applet后，用户界面或者实时数据更新的效果令人印象深刻，且提供了相关的说明文档或教程帮助用户理解和使用。这个项目展示了如何利用Java Applet结合服务器推技术实现一个实时温度监控系统。尽管现代Web开发中，由于安全性和性能的原因，Java Applet已逐渐被Web Socket、WebRTC等技术替代，但理解这一历史背景下的技术实践仍然有助于我们了解Web技术的发展历程和现有技术的由来。

资源推荐

资源详情

资源评论

收起资源包目录

temperature.rar （13个子文件）

temperature

server_start.bat 20B

source

server

TServer.class 924B

TServer.java 3KB

util

Debug.class 917B

Debug.java 798B

Svc_thread.class 2KB

util

Debug.class 917B

client

applet

temperature$DataGenerator.class 770B

temperature.class 6KB

index.htm 308B

lib

jfreechart-1.0.1.jar 1.03MB

jcommon-1.0.0.jar 288KB

server.jar 5KB

package server; import java.io.*; import java.net.*; import java.util.*; import java.sql.*; import util.*; public class TServer{ static String info; static double temperature; static ArrayList clientList=new ArrayList(); public static void main(String args[]){ ServerSocket svc_socket=null; Svc_thread svc_thread; Socket c_socket=null; while(true){ try{ svc_socket=new ServerSocket(12345); } catch(IOException e){Debug.println("正在监听……");} try{ c_socket=svc_socket.accept(); clientList.add(c_socket); } catch(IOException e){Debug.println("正在等待用户……");} if(c_socket!=null){ new Svc_thread(c_socket).start(); } else{continue;} }//while() }//main() } class Svc_thread extends Thread{ Socket socket1; DataOutputStream out=null;DataInputStream in=null; String s=null; double value=0; Svc_thread(Socket t){ socket1=t; try{ in=new DataInputStream (socket1.getInputStream()); out=new DataOutputStream (socket1.getOutputStream()); } catch(IOException e){} } public void run(){ try{ out.writeUTF("rev ready"); out.writeUTF(String.valueOf(TServer.temperature)); Debug.println("发送rev ready&"+TServer.temperature); }catch(Exception ee){Debug.println("发送失败");} while(true){ try{ s=null; s=in.readUTF(); Debug.println("收到"+s); if(s.equals("send value")){ Debug.println("send value request accepted"); value=Double.valueOf(in.readUTF()).doubleValue(); Debug.println("收到"+value); TServer.temperature=value; sendToAllClient(); }//if }//try catch(IOException ee){ Debug.println("一个客户离开"); TServer.clientList.remove(socket1);//用户离开时从套接子列表中移除连接； //不然程序会向已不存在的客户发数据，进而会使服务端不能正常工作 break; } catch(Exception e){break;} }//while }//run /* 向所有客户发送数据 */ public void sendToAllClient() throws IOException{ Iterator clients=TServer.clientList.iterator(); DataOutputStream out=null;DataInputStream in=null; Socket tmpSocket=null; while(clients.hasNext()){ tmpSocket=(Socket)clients.next(); in=new DataInputStream (tmpSocket.getInputStream()); out=new DataOutputStream (tmpSocket.getOutputStream()); out.writeUTF("rev ready"); out.writeUTF(String.valueOf(TServer.temperature)); Debug.println("sendToAllClient temperature value is "+TServer.temperature); } } }//class

评论收藏

内容反馈