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
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资源评论
lllpshxyu2013-04-22通过推技术，可以实现主动服务器端向客户端传送数据。非常好。
