第一问答网»论坛 › 中问网 › 问答 › 利用Socket进行Java网络编程（三）

利用Socket进行Java网络编程（三）

11 |

0 | 2005-10-30 17:05:33 | 显示全部楼层 |阅读模式

出自：天极网郗旻 2002年11月11日 09:28
附：服务器的实现代码
import java.net.*;
import java.io.*;
import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
public class talkServer
{ public static void main(String[] args)
　{ try
　　{ file://建立服务器
　　　ServerSocket server = new ServerSocket(9998);
　　　int i=1;
　　　for(;

　　　　{ Socket incoming = server.accept();
　　　　　new ServerThread(incoming,i).start();
　　　　　i++;
　　　　}
　　　}catch (IOException ex){
　　　ex.printStackTrace();
　　}
　}
}
class ServerThread extends Thread implements ActionListener
{
　private int threadNum;
　private Socket socket;
　talkServerFrm t;
　BufferedReader in;
　PrintWriter out;
　private boolean talking=true;
　public ServerThread(Socket s,int c)
　{ threadNum = c;
　　socket = s;
　}
public void actionPerformed(ActionEvent e)
{ Object source = e.getSource();
　try{
　　if(source==t.btnSend)
　　　{ out.println(t.getTalk());
　　　　t.clearTalk();
　　}else
　　if(source==t.btnEnd)
　　　{ out.println("谈话过程被对方终止&quot

;
　　　　out.close();
　　　　in.close();
　　　　talking = false;
　　　}
　}catch(IOException ex){
　}
}
public void run()
{ try{
　　t=new talkServerFrm(new Integer(threadNum).toString(),this);
　　t.setSize(500,500);
　　t.show();
　　in = new BufferedReader(new
　　　　　 InputStreamReader(socket.getInputStream()));
　　out = new PrintWriter(socket.getOutputStream(),true);
　}catch(Exception e){
}
　new Thread()
　{ public void run()
　　{ try{
　　　　while(true)
　　　　{ checkInput();
　　　　　sleep(1000);
　　}
　}catch (InterruptedException ex){
　}catch(IOException ex){
　}
　}
　}.start();
　while(talking)
　{ }
　t.dispose();
　}
private void checkInput() throws IOException
{ String line;
　if((line=in.readLine())!=null)
　　t.setPartner(line); file://这是界面类里的方法，
　　file://用来将line的内容输出到用户界面
　}
}

使用道具举报

返回列表发新帖

千问

主题	0 回帖	4882万积分

论坛元老

Rank: 8 Rank: 8

积分: 48824836

回复楼主返回列表

问答

热门排行