sockettest.java

实现简单的群聊功能

package cn.edu.buaa.scse.liyi.network.test;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;
import java.net.UnknownHostException;

public class SocketTest
{
	/*ServerSocket类例子*/
	public void createServer()
	{
		int port=8888; // 侦听端口
		try
		{
			ServerSocket serverSocket=new ServerSocket(port);		// 创建ServerSocket
			while(true)
			{
				Socket socket=serverSocket.accept();				// 等待连接
				//ServerThread st = new ServerThread(socket);			// 处理链接的线程类
				//new Thread(st).start();								// 启动线程处理
			}
		}
		catch(IOException e)
		{
			e.printStackTrace();
		}
	}
	
	/*客户端的例子*/
	public void createClient()
	{
		String hostIP="127.0.0.1";
		int port=8888;										// 侦听端口
		try
		{
			Socket socket=new Socket(hostIP,port);													// 建立连接
			BufferedReader netIn=new BufferedReader(new InputStreamReader(socket.getInputStream()));		// 输入数据的读取	
			PrintWriter netOut=new PrintWriter(socket.getOutputStream());									// 写入数据
		}
		catch(UnknownHostException e)
		{
			e.printStackTrace();
		}
		catch(IOException e)
		{
			e.printStackTrace();
		}
	}
	/**
	 * @param args
	 */
	public static void main(String[] args)
	{
		// TODO Auto-generated method stub
		
	}
}