网络编程

package com.lovo.client;

import java.io.IOException;

import java.io.OutputStream;

import java.net.Socket;

import java.net.UnknownHostException;

import javax.swing.JOptionPane;

/**

 * 

 * @author Administrator

 * 客户端代码---任务是向服务端发送消息

 */

public class TestClient {

/**
* @param args
*/
public static void main(String[] args) {
// TODO Auto-generated method stub

//1、接收用户信息---这是我们真正要发送的消息
String msg = JOptionPane.showInputDialog("请输入你要发送的信息");

//2、封装应用层协议---这个步骤不是必须的,根据应用需要来确定(双方保持一致)

//3、产生Socket对象（套接字）---Socket的任务是完成传输层\网络互连层的协议封装(TCP/IP),并把数据通过网络发送出去
Socket socket = null;
OutputStream os = null;
try {
socket = new Socket("192.168.1.222", 54188);
//括号内为ip地址和端口号
//4、操作Socket对象发送信息
os = socket.getOutputStream();
os.write(msg.getBytes());
os.flush();

} catch (UnknownHostException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} finally{
//5、关闭Socket
if(os != null){
try {
os.close();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
if(socket != null){
try {
socket.close();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}

}

}

服务器端代码

package com.lovo.server;

import java.io.BufferedReader;

import java.io.IOException;

import java.io.InputStreamReader;

import java.net.Socket;

//处理线程

public class ProcessingThread extends Thread{
//定义socket，以便传入参数
private Socket socket;
//线程启动，传入参数socket
public ProcessingThread(Socket socket){
this.socket = socket;
this.start();
}

public void run(){

BufferedReader br = null;
try {
//读取消息
br = new BufferedReader(new InputStreamReader(
socket.getInputStream()));
//将字节数据转化成字符串数据
String msg = br.readLine();
System.out.println("客户端发送的消息是：" + msg);
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} finally{
if (br != null) {
try {
br.close();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
if (socket != null) {
try {
socket.close();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}

}

}

package com.lovo.server;

import java.io.BufferedReader;

import java.io.IOException;

import java.io.InputStreamReader;

import java.net.ServerSocket;

import java.net.Socket;

public class TestServer {

/**
* @param args
*/
public static void main(String[] args) {
// TODO Auto-generated method stub
// 1、首先产生ServerSocket对象
ServerSocket server = null;

try {
server = new ServerSocket(54188);
// 2、服务端开始监听
System.out.println("服务器开始监听.....");
while (true) {
Socket socket = server.accept();
System.out.println("服务器接收到消息.....");
// 3、开启线程，传入socket，将其交给线程内部去处理数据 
new ProcessingThread(socket);
}

} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} finally {

if (server != null) {

4000
try {
server.close();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}

}

}