yuyinserver.java

P2P聊天系统 该程序是由NetBeans IDE 6.5

/*
 * To change this template, choose Tools | Templates
 * and open the template in the editor.
 */

package voice;

import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.logging.Level;
import java.util.logging.Logger;

/**
 *
 * @author Administrator
 */
public class yuyinserver extends Thread{
        public yuyinserver(ServerSocket ss) {
            checkServer = ss;
        }

        public int port=6002;
        public int maxThreadNum=5;
        private ServerSocket checkServer = null;
        private Socket aSocket = null;
        Capture cap = null;
        private boolean serverRunning = false; //服务器是否运行

        public void run() {
            serverRunning = true;
                try {
                    checkServer = new ServerSocket(port);
                } catch (IOException ex) {
                    Logger.getLogger(yuyinserver.class.getName()).log(Level.SEVERE, null, ex);
                }

            while (serverRunning) {
                    try {
                        System.out.println("Started...");
                        aSocket = checkServer.accept();
                        System.out.println("client connected");
                        Playback player=new Playback(aSocket);
                        cap=new Capture(aSocket);
                        cap.start();
                        player.start();
                    }
                    catch (Exception ex) {
                        ex.printStackTrace();
                    }
            }
            try {
                checkServer.close();
            } catch (IOException ex1) {
            }
        }

        public void stopserver(){
            serverRunning=false;
        try {
            aSocket.close();
        } catch (IOException ex) {
            Logger.getLogger(yuyinserver.class.getName()).log(Level.SEVERE, null, ex);
        }
        }
    
}