Java基础---Java---网络编程---TCP的传输、客户端和服务端的互访、建立一个文本转换器、编写一个聊天程序

class TcpClient2{
public static void main(String[] args) throws Exception{
Socket a=new Socket("172.16.196.12",10004);
OutputStream out=s.getOutputStream();
out.write("服务端你好".getBytes());
InputStream in=s.getInputStream();
byte[] buf=new byte[1024];
int len=in.read(buf);//只有等待服务端发送数据，才能进行开始读
System.out.println(new String(buf,0,len));
s.close();

}
}

</pre><strong><span style="color:rgb(255,0,0); font-size:18px">服务端：</span></strong><pre code_snippet_id="272018" snippet_file_name="blog_20140403_2_3221842" name="code" class="html">class TcpServer2{
public static void main(String[] args){
//不要觉得代码差不多，是两个独立的程序
ServerSocket ss=new ServerSocket(10004);//监听10004端口
Socket s=ss.accept();
String ip=s.getInetAddress().getHostAddress();//拿到客户端的地址
System.out.println(ip+"...is connect");
InputStrean in=s.getInputStream();
byte [] buf=new byte[1024];
int len=in.read(buf);
System.out.println(new String(buf,0,len));
OutputStream out=s.getOutputStream();
out.write("哥们收到".getBytes());
s.close();
ss.close();
}

}

class TransClient{
public static void main(String [] args){
Socket s=new Socket("172.16.196.12",10005);
//定义读取键盘数据的流对象
BufferedReader bufr=new BufferedReader(new InputStreamReader(System.in));

//定义目的：将数据写入到socket输出流，发给服务端。
BufferedWriter bufw=new BufferedWriter(new OutputStreamWriter(s.getOutputStream()));
//这是用到转换流，OutputStreamWriter.

//定义一个socket读取流。读取服务端返回的大写信息。

BufferedReader bufIn=new BufferedReader(new InputStreamReader(e.getInputStream()));
String line=null;
while((line=bufr.readLine())!null){

if("over".equals(line))
break;
bufOut.write(line+"\r\n");//这个地方要加换行。不然服务端没法找到什么时候结束。
bufOut.flush();
String str=bufIn.readLine();
System.out.println("server"+str);

}
butr.close();
s.close();

}
}

class TransServer{
public static void main(String[] args)throws Exception{
ServerSocket ss=new ServerSocket(10005);

Socket s=ss.accept();
String ip=s.getInetAddress().getHostAddress();
System.out.println(ip+"....is connected");
//读取socket读取流中的数据
BufferedReader bufIn=new BufferedReader(new InputStreamReader(e.getInputStream()));
//目的。socket输出流，将大写数据写入到socket输出流，并发送给客户端

BufferedWriter bufOut=new
BufferedWriter(new OutputStreamWriter(s.getOutputStream());

String line=null;
while((line=bufIn.readLine())!null){//判断的是回车标识
//当关闭服务端时，客户端也相应结束。
System.out.println(line);
bufOut.write(line.toUpperCase());
bufOut.newLine();
bufOut.flush();
}
s.close();
ss.close();

}

}

import java.io.*;
import java.net.*;
class Send implements Runnable
{
private DatagramSocket ds;
public Send(DatagramSocket ds)
{
this.ds = ds;
}
public void run()
{
try
{
BufferedReader bufr = new BufferedReader(new InputStreamReader(System.in));
String line = null;
while((line=bufr.readLine())!=null)
{

byte[] buf = line.getBytes();

DatagramPacket dp =
new DatagramPacket(buf,buf.length,InetAddress.getByName("172.16.196.12"),10002);

ds.send(dp);

if("886".equals(line))
break;
}
}
catch (Exception e)
{
throw new RuntimeException("发送端失败");
}
}
}

class Rece implements Runnable
{

private DatagramSocket ds;
public Rece(DatagramSocket ds)
{
this.ds = ds;
}
public void run()
{
try
{
while(true)
{
byte[] buf = new byte[1024];
DatagramPacket dp = new DatagramPacket(buf,buf.length);

ds.receive(dp);

String ip = dp.getAddress().getHostAddress();

String data = new String(dp.getData(),0,dp.getLength());

if("886".equals(data))
{
System.out.println(ip+"....离开聊天室");
break;
}

System.out.println(ip+":"+data);
}
}
catch (Exception e)
{
throw new RuntimeException("接收端失败");
}
}
}

class  ChatDemo
{
public static void main(String[] args) throws Exception
{
DatagramSocket sendSocket = new DatagramSocket();
DatagramSocket receSocket = new DatagramSocket(10002);

new Thread(new Send(sendSocket)).start();
new Thread(new Rece(receSocket)).start();

}
}