多维数组转化成一维数组

网络通讯项目总结

java中网络通讯主要是通过两个类来实现，一个是服务器（ServerSocket），另一个是客户端（Socket）。
首先，实现一个简单的服务器程序：

public class ChatServer {
/**
* 在指定端口上启动一个服务器
*/
public void setUpServer(int port){
try{
//建立绑定在指定端口上的服务器对象
ServerSocket server=new ServerSocket(port);
System.out.println("服务器创建成功！"+port);
while(true){
//让服务器进入等待状态：阻塞状态
Socket client=server.accept();
//从连接对象上得到输入输出流对象
OutputStream out=client.getOutputStream();
InputStream ins=client.getInputStream();
String s="你好，欢迎来javake.com\r\n";
byte[] data=s.getBytes();
out.write(data);
out.flush();
int in=0;
while(in!=13){
in=ins.read();
char ch=(char)in;
System.out.println("读到的是："+ch);
}
System.out.println("得到回车，退出！");
client.close();
}

}catch(Exception ef){
ef.printStackTrace();
}
}

//主函数
public static void main(String[] args){
ChatServer cs=new ChatServer();
cs.setUpServer(9090);
}
}

然后用windows提供的telnet客户端去连接测试；服务器有IP和端口号，端口号的范围一般在0到65535之间。服务器有输出流

和输入流，输出流是输出信息到客户端的，输入流是接受客户端发来的信息的，我们通过相应的方法去处理接受的数据，同时

可以通过线程去解决信息阻塞的问题，实现发送消息的同时接受消息。
也可以用过各种途径实现网络五子棋，网络画板等网络程序。

客户端，跟服务器差不多，区别就是多个客户端可以同时连接一个服务器，然后客户端直接可以通讯。具体实现看代码。

package Client_v1;

import java.awt.FlowLayout;
import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.Socket;
import java.net.UnknownHostException;

import javax.swing.JButton;
import javax.swing.JFrame;
import javax.swing.JTextArea;

public class ClientThread extends Thread {

private Socket client;
private OutputStream ous;
private InputStream ins;

public ClientThread(Socket client){
this.client=client;
}

//界面组件
private JFrame frame=new JFrame("客户端");
private JTextArea Rjta=new JTextArea(8,25);
private JTextArea Sjta=new JTextArea(4,25);
private JButton sbt=new JButton("发送");

/**
* 显示界面
* @return
*/
public void showUI(){
frame.setSize(300,400);
frame.setTitle("客户端");
frame.setDefaultCloseOperation(3);
frame.setLayout(new FlowLayout());
frame.add(Rjta);
frame.add(Sjta);
frame.add(sbt);
frame.setVisible(true);

sbt.addActionListener(new ActionListener(){
public void actionPerformed(ActionEvent e) {
SendMassager(Sjta.getText());

Sjta.setText("");
}
});
}

/**
* run方法
*/
public void run(){
showUI();
processMsg(client);
}

/**
* 处理消息的函数
*/
public void processMsg(Socket client){
client=this.client;
try {
ins=client.getInputStream();
while(true){
//Rjta.setText("服务器："+readString(ins));
Rjta.append(readString(ins)+"\r\n");
System.out.println("1");
}
//client.close();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}

}

/**
* 发送消息的方法
* @throws IOException
*/
public void SendMassager(String std) {
std=std+"\r\n";
byte data[]=std.getBytes();
try {
ous=client.getOutputStream();
ous.write(data);
ous.flush();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}

}

/**
* 收到的字符换成字符串
* @throws IOException
*/
public String readString(InputStream ins) throws IOException{
StringBuffer std=new StringBuffer();
char ch=0;
int in=0;
while(ch!='\n'){
in=ins.read();
ch=(char)in;
std.append(ch);
}
System.out.println("xxx:"+std.toString());
return std.toString().trim();//trim为消除后面的空格符
}

public static void main(String[] args){
Socket soc;
try {
soc = new Socket("localhost",9090);
ClientThread cl=new ClientThread(soc);
cl.start();
} catch (IOException e) {
e.printStackTrace();
}

}
}

难点在于如何用线程去实现发收信息的同步。