您的位置:首页 > 其它

常用流的基本操作记录

2012-02-11 20:57 239 查看
System.in
String line;
InputStreamReader input = new InputStreamReader(System.in);//System.in为nputStream类u22411
System.out.println("Enter data and push enter");
BufferedReader reader = new BufferedReader(input);
line = reader.readLine();
System.out.println("data entered--->"+line);
FILE
private String forTest(String file) throws IOException {
BufferedReader in = new BufferedReader(new FileReader(file));
String s, s2 = new String();
while ((s = in.readLine()) != null)
s2 += s + "\n";
in.close();
return s2;
}

public void generCorpFile(String localSavePath,String path, List list) {
if (!(new File(localSavePath).isDirectory())) {
new File(localSavePath).mkdir();
}
if (!(new File(path).isDirectory())) {
new File(path).mkdir();
}

File file = new File(path + File.separator + "corporation");
PrintWriter out = null;
try {
out = new PrintWriter(new FileWriter(file));
if (list != null && list.size() > 0) {
for (int i = 0; i < list.size(); i++) {
CorpModel data = (CorpModel) list.get(i);
out.print(data.toString());
}
}
out.flush();
} catch (IOException e) {
} finally {
if (out != null)
out.close();
}
}

HTTP

private String readXMLFromRequestBody(HttpServletRequest request)
throws UnsupportedEncodingException {
StringBuffer xml = new StringBuffer();
String line = null;
try {
BufferedReader reader = request.getReader();
while ((line = reader.readLine()) != null) {
xml.append(line);
}
Logoo.info(xml.toString());
} catch (Exception e) {
Logoo.error(e.getMessage(), e);
}
return xml.toString();
}

public static void sendGisRequest() {
URL url = null;
BufferedWriter writer = null;
BufferedReader in = null;
URLConnection conn = null;
StringBuffer sb = new StringBuffer();
try {
url = new URL("http://10.10.43.210:8080/cstar/NvLoveServlet?actiontype=hellodrf");
conn = url.openConnection();
conn.setDoInput(true);
conn.setDoOutput(true);
in = new BufferedReader(new InputStreamReader(
conn.getInputStream(), "UTF-8"));
for (String line = null; (line = in.readLine()) != null;) {
sb.append(line + "\n");
}
in.close();
String responseXML = sb.toString();
} catch (MalformedURLException ue) {
Logoo.debug(ue.getMessage());
} catch (Exception ioe) {
Logoo.debug(ioe.getMessage());
} finally {
}
}

SOCKET
import java.net.*;
import java.io.*;

public class Server {
private ServerSocket ss;
private Socket socket;
private BufferedReader in;
private PrintWriter out;

public Server() {
try {
ss = new ServerSocket(10000);

while (true) {
socket = ss.accept();
in = new BufferedReader(new InputStreamReader(
socket.getInputStream()));
out = new PrintWriter(socket.getOutputStream(), true);

String line = in.readLine();
out.println("you input is :" + line);
out.close();
in.close();
socket.close();
}
ss.close();
} catch (IOException e) {
}
}

public static void main(String[] args) {
new Server();
}
}

///////////////////
import java.io.*;
import java.net.*;

public class Client {
Socket socket;
BufferedReader in;
PrintWriter out;

public Client() {
try {
socket = new Socket("xxx.xxx.xxx.xxx", 10000);
in = new BufferedReader(new InputStreamReader(
socket.getInputStream()));
out = new PrintWriter(socket.getOutputStream(), true);
BufferedReader line = new BufferedReader(new InputStreamReader(
System.in));

out.println(line.readLine());
line.close();
out.close();
in.close();
socket.close();
} catch (IOException e) {
}
}

public static void main(String[] args) {
new Client();
}
}
 http://tech.163.com/06/0410/09/2EBABUD20009159T_2.html UDP
DatagramSocket receiveSocket, sendSocket;
DatagramPacket receivePacket ,sendPacket;

public void receiveMessage()//服u21153 器u21457 送u28040 息
{
try
{
receiveSocket=new DatagramSocket(4001);//服u21153 器u25509 受u31471 口

while(true)
{

byte[] buf=new byte[200];
receivePacket=new DatagramPacket(buf,buf.length);
receiveSocket.receive(receivePacket);
ip=receivePacket.getAddress();
if(receivePacket.getLength()==0)
{
ta.append("空u28040 息");
continue;
}
ByteArrayInputStream bin=new ByteArrayInputStream(receivePacket.getData());
BufferedReader read=new BufferedReader(new InputStreamReader(bin));
ta.append("客u25143 端"+read.readLine());
ta.append("\n");
read.close();
bin.close();

}
}
catch(Exception e)
{
ta.append(e+"sendmessage error\n");

}

}
public void sendMessage()
{
try{
String s=tf.getText();
tf.setText("");
ta.append("服u21153 器"+s);
ta.append("\n");
ByteArrayOutputStream out=new ByteArrayOutputStream();
PrintStream pout=new PrintStream(out);
pout.print(s);
byte[] buf=out.toByteArray();
sendPacket=new DatagramPacket(buf,buf.length,ip,3001);
sendSocket.send(sendPacket);
buf=null;
}
catch(Exception e)
{
ta.append(e+"\n");

}
}
 http://blog.csdn.net/wintys/article/details/3525643
内容来自用户分享和网络整理,不保证内容的准确性,如有侵权内容,可联系管理员处理 点击这里给我发消息
标签: