Java 简单的Socket通讯的客户端实现

矫情吗；* 2022-01-17 04:01 326阅读 0赞

前面发了服务器端的代码，这里发客户端的,[服务器类连接][Link 1]

有2个类，因为用了多线程，要实现Runnable接口

主类代码

/**
     * 这是测试类
     * @author WantnRun
     * 2013年6月24日 11:10:19
     */
    public class Test {
    
    	/**
    	 * @param args
    	 */
    	public static void main(String[] args) {
    		MySocket mySocket=new MySocket();//新建客户端Socket类对象
    		new Thread(mySocket).start();//启动线程调用run方法
    
    	}
    
    }

客户端Socket类主要代码类

import java.io.BufferedReader;
    import java.io.IOException;
    import java.io.InputStreamReader;
    import java.io.OutputStreamWriter;
    import java.io.PrintWriter;
    import java.net.InetAddress;
    import java.net.Socket;
    import java.net.UnknownHostException;
    
    /**
     * 客户端的Socket类
     * @author WantnRun
     * 2013年6月24日 10:29:54
     */
    public class MySocket implements Runnable {
    
    	/**
    	 * Socket对象
    	 */
    	private Socket socket=null;
    	/**
    	 * 服务器地址，如果在同一个机器上不能使用127.0.0.1的回环地址
    	 */
    	private String HOST="192.168.1.222";
    	/**
    	 * 服务器端口
    	 */
    	private int PORT=8886;
    	/**
    	 * 读取接收的数据
    	 */
    	private BufferedReader bufferedReader=null;
    	/**
    	 * 将数据发送给对方
    	 */
    	private PrintWriter printWriter=null;
    	/**
    	 * 多线程的run方法
    	 */
    	public void run() {
    		try {
    			//创建套接字，根据ip和端口号
    			socket=new Socket(InetAddress.getByName(HOST),PORT);
    			//使用套接字的输入流构造BUfferedReader对象
    			bufferedReader=new BufferedReader(new InputStreamReader(socket.getInputStream()));
    			//使用套接字的输出流构造PrintWriter对象
    			printWriter=new PrintWriter(new OutputStreamWriter(socket.getOutputStream()),true);
    			//键盘输入对象
    			BufferedReader in=new BufferedReader((new InputStreamReader(System.in)));
    			while(true)
    			{
    				if(socket.isConnected())
    				{
    					//是连接状态
    					//客户端首先发送消息给服务器端
    					System.out.println("输入消息");
    					String str=in.readLine();//获取输入
    					printWriter.println(str);//发送给服务器
    					//接收服务器返回的消息
    					String msg=bufferedReader.readLine();//读取服务器的消息
    					System.out.println("服务器："+msg);//打印服务器消息
    				}
    					
    			}
    		} catch (UnknownHostException e) {
    			e.printStackTrace();
    		} catch (IOException e) {
    			e.printStackTrace();
    		}
    		
    	}
    
    
    }

如有任何错误点，请大神们指出，小弟在这里谢谢了

[Link 1]: http://blog.csdn.net/wantnrun/article/details/9159847