一个完整的Socket例子

　　以下程序在Jbuilder4下调试成功!［下载源程序］
　　服务端的程序:
　　import Java.io.*;
　　import java.net.*;
　　
　　public class SocketServer {
　　ServerSocket ss=null;
　　Socket s=null;
　　DataInputStream inStream=null;
　　DataOutputStream outStream=null;
　　
　　public SocketServer() {
　　try{
　　init();
　　}
　　catch(Exception e){
　　System.out.println(e.toString());
　　}
　　}
　　
　　void init() throws Exception{
　　ss=new ServerSocket(765);
　　s.setSoTimeout(3000);
　　}
　　
　　void waitForClient(){
　　try{
　　s=ss.accept();
　　inStream=new DataInputStream(s.getInputStream());
　　outStream=new DataOutputStream(s.getOutputStream());
　　outStream.writeUTF("1");
　　s.setSoTimeout(3000);
　　waitData();
　　}
　　catch(Exception e){
　　System.out.println(e.toString());
　　}
　　}
　　
　　void waitData(){
　　while(true){
　　try{
　　String str=inStream.readUTF();
　　System.out.println("Server accept: "+str);
　　int nu=Integer.parseInt(str)+1;
　　if(nu>20){
　　System.out.println("Send end!");
　　break;
　　}
　　else{
　　str=Integer.toString(nu);
　　outStream.writeUTF(str);
　　}
　　}
　　catch(Exception e){
　　System.out.println(e.toString());
　　break;
　　}
　　}
　　}
　　
　　public static void main(String[] args) {
　　SocketServer socketServer1 = new SocketServer();
　　socketServer1.waitForClient();
　　}
　　}
　　
　　客户端的程序:
　　
　　
　　import java.net.*;
　　import java.io.*;
　　
　　public class SocketClient{
　　Socket s=null;
　　DataInputStream inStream=null;
　　DataOutputStream outStream=null;
　　
　　public SocketClient() {
　　try{
　　init();
　　waitData();
　　}
　　catch(Exception e){
　　System.out.println(e.toString());
　　}
　　}
　　
　　void init() throws Exception{
　　s=new Socket("192.168.0.32",765); //把这里的IP改成你运行SocketServer.class的IP
　　inStream=new DataInputStream(s.getInputStream());
　　outStream=new DataOutputStream(s.getOutputStream());
　　s.setSoTimeout(3000);
　　}
　　
　　void waitData(){
　　while(true){
　　try{
　　String str=inStream.readUTF();
　　System.out.println("Client accept: "+str);
　　str=Integer.toString(Integer.parseInt(str)+1);
　　outStream.writeUTF(str);
　　}
　　catch(Exception e){
　　System.out.println(e.toString());
　　break;
　　}
　　}
　　}
　　
　　public static void main(String[] args) {
　　SocketClient socketClient1 = new SocketClient();
　　}
　　}