java socket swt聊天糸统

import java.io.DataInputStream; import java.io.DataOutputStream; import java.io.IOException; import java.net.ServerSocket; import java.net.Socket; import org.eclipse.swt.SWT; import org.eclipse.swt.events.SelectionAdapter; import org.eclipse.swt.events.SelectionEvent; import org.eclipse.swt.events.ShellAdapter; import org.eclipse.swt.events.ShellEvent; import org.eclipse.swt.layout.RowData; import org.eclipse.swt.layout.RowLayout; import org.eclipse.swt.widgets.Button; import org.eclipse.swt.widgets.Composite; import org.eclipse.swt.widgets.Display; import org.eclipse.swt.widgets.Shell; import org.eclipse.swt.widgets.Text; public class server extends SelectionAdapter implements Runnable{ final Display display; final Shell shell; Composite com,com1; Text tf,tx; Button bl,bf; Socket s; public DataInputStream in; DataOutputStream out; private ServerSocket ss; server(){ display = Display.getDefault(); shell=new Shell(); shell.addShellListener(new ShellAdapter(){ public void shellClosed(ShellEvent e){ System.exit(0); try { out.flush(); close(); } catch (IOException e1) { // TODO 自动生成 catch 块 e1.printStackTrace(); } } }); shell.setText("server"); shell.setBounds(300,300,200,300); RowLayout row =new RowLayout(); row.type=SWT.VERTICAL; shell.setLayout(row); RowData data=new RowData(200,100); tx=new Text(shell,SWT.BORDER|SWT.MULTI|SWT.V_SCROLL|SWT.READ_ONLY); tf=new Text(shell,SWT.BORDER|SWT.MULTI|SWT.V_SCROLL); tx.setLayoutData(data); tf.setLayoutData(data); tx.setSize(200, 100); tf.setSize(200,100); bf=new Button(shell,SWT.PUSH); bf.setText("发送"); bf.addSelectionListener(new SelectionAdapter(){ public void widgetSelected(SelectionEvent e){ try { out.writeUTF(tf.getText()); out.flush(); } catch (IOException e1) { // TODO 自动生成 catch 块 e1.printStackTrace(); } } } ); shell.open(); try { ss=new ServerSocket(7000); s=ss.accept(); } catch (IOException e) { // TODO 自动生成 catch 块 e.printStackTrace(); } try { in=new DataInputStream(s.getInputStream()); out=new DataOutputStream(s.getOutputStream()); } catch (IOException e) { // TODO 自动生成 catch 块 e.printStackTrace(); } new Thread(this).start(); while (!shell.isDisposed()) { if (!display.readAndDispatch()) { display.sleep(); } } try { close(); } catch (IOException e1) { // TODO 自动生成 catch 块 e1.printStackTrace(); } display.dispose(); } /** * @param args */ public static void main(String arg[]){ new server(); } public void run() { while(true){ try { String data=in.readUTF(); setdata(data); } catch (IOException e) { // TODO 自动生成 catch 块 e.printStackTrace(); } } } private void setdata(final String data) { display.asyncExec(new Runnable(){ public void run() { // TODO 自动生成方法存根 tx.append(data); } // TODO 自动生成方法存根 }); } public void close() throws IOException{ in.close(); out.close(); s.close(); ss.close(); } }