java网络编程之TCP/IP ——SocketServer与Socket

java网络编程主要包含4部分： （注意设置超时时间）
1.URL 连接 ：类 URL 代表一个统一资源定位符，它是指向互联网“资源”的指针。资源可以是简单的文件或目录，也可以是对更为复杂的对象的引用，例如对数据库或搜索引擎的查询。
2.HttpURLConnection连接：相当于servlet，发送单个以post或get方式的请求，
3.TCP/IP连接 可靠传输ServerSocket类
4.UDP连接 DatagramSocket 类， 此类表示用来发送和接收数据报包的套接字。

TCP/IP 连接 Server服务器端

Java代码



import java.io.BufferedInputStream;

import java.io.BufferedReader;

import java.io.BufferedWriter;

import java.io.IOException;

import java.io.InputStream;

import java.io.InputStreamReader;

import java.io.OutputStreamWriter;

import java.net.ServerSocket;

import java.net.Socket;

/**

*@ClassName:Server

*@author: chenyoulong

*@date :2012-7-30 上午10:35:09

*@Description:TODO

*/

public class SendServer {

/**

* @throws IOException

* @Title: main

* @Description: TODO

* @param @param args

* @return void

* @throws

*/

public static void main(String[] args) throws IOException {

// TODO Auto-generated method stub

ServerSocket server=new ServerSocket(8888);

System.out.println("server start");

Socket sock=server.accept();

sock.setSoTimeout(6000); //服务器端设置连接超时时间，该操作只对读取（read）操作有效。

//读取

//字节流的形式读取

// 优缺点分析，弱点：受byte[]大小的限制 ，优点：不受回车符（\r）和换行符（\n）限制

InputStream input=sock.getInputStream();

byte[] buf =new byte[1024];

System.out.println("InputStream==="+input);

if(input!=null){

int len=input.read(buf);

ToolKit.writeLog(SendServer.class.getName(), "服务器端收到的报文：\n"+new String(buf, 0, len));

}

/* //字符流的形式读取

//(遇到换行符或者回车符就终止，还是谨慎使用)

BufferedReader read=new BufferedReader(new InputStreamReader(sock.getInputStream()));

String readStr=null;

if((readStr=read.readLine())!=null){

ToolKit.writeLog(Server.class.getName(), "服务器端收到的报文：\n"+readStr);

}

if(read!=null) read.close();

*/

/*//输出

String outStr="我是server服务器端";

BufferedWriter write=new BufferedWriter(new OutputStreamWriter(sock.getOutputStream()));

if(outStr!=null){

write.write(outStr);

}

if(write!=null) write.close();*/

//挂关闭资源

if(sock!=null) sock.close();

if(server!=null) server.close();

}

TCP/IP连接 Client客户端

Java代码



import java.io.BufferedInputStream;

import java.io.BufferedOutputStream;

import java.io.IOException;

import java.net.Socket;

import java.net.UnknownHostException;

import org.apache.log4j.Logger;

/**

*@ClassName:ReceiveClient

*@author: chenyoulong

*@date :2012-8-3 下午2:17:26

*@Description:TODO

*/

public class ReceiveClient {

private final String IP=Setting.RECEIVE_IP;

private final int PORT=Setting.RECEIVE_PORT;

private Logger log = Logger.getLogger(Sender.class.getName());

//发送

/**

* @throws Exception

* 发送报文

* @Title: send

* @Description: TODO

* @param @param reqMessage

* @return void

* @throws

*/

public void send(String reqMessage) throws Exception{

Socket sock=null;

BufferedOutputStream out=null;

try {

sock=new Socket();

SocketAddress sockAdd=new InetSocketAddress(IP, PORT);

sock.connect(sockAdd, 2000); //客户端设置连接建立超时时间

out=new BufferedOutputStream(sock.getOutputStream());

out.write(reqMessage.getBytes());

out.flush();

} catch (UnknownHostException e) {

// TODO Auto-generated catch block

log.error("网络连接异常"+Strings.getStackTrace(e));

e.printStackTrace();

} catch (IOException e) {

// TODO Auto-generated catch block

log.error("网络连接异常\n"+Strings.getStackTrace(e));

e.printStackTrace();

}finally{

if(out!=null){

try {

out.close();

} catch (IOException e) {

// TODO Auto-generated catch block

e.printStackTrace(); }

}

if(sock!=null){

try {

sock.close();

} catch (IOException e) {

// TODO Auto-generated catch block

e.printStackTrace();

}

}

}

}

//接收

public String reiceve() throws Exception{

Socket sock=null;

BufferedInputStream in=null;

try {

sock=new Socket(IP,PORT);

in = new BufferedInputStream(sock.getInputStream());

if ((sock == null) || (in == null)) {

throw new Exception("套接口无效，无法读取数据");

}

} catch (UnknownHostException e) {

// TODO Auto-generated catch block

e.printStackTrace();

} catch (IOException e) {

// TODO Auto-generated catch block

e.printStackTrace();

}

byte[] bts = new byte[10000];

int totalLen = 0, len = 0;

while ((len = in.read(bts, totalLen, 1000)) != -1) {

totalLen += len;

}

String result = new String(bts); //注意字符编码

return result.trim();

}

//main函数示例

public static void main(String[] args){

//发送报文

//发送

String str="我是客户端！"

try {

new ReceiveClient().send(str);

} catch (Exception e) {

// TODO Auto-generated catch block

e.printStackTrace();

}

//接收报文

/*try {

String recStr=new Receiver().reiceve();

System.out.println("客户端接收到的结果=="+recStr);

} catch (Exception e) {

// TODO Auto-generated catch block

e.printStackTrace();

}*/

}

}