学步园

首先看一下运行效果图

关于mina在这里就不多说,google一搜很多对其介绍.

本文主要就是想在swt中采用mina来实现聊天.

首先我把源代码贴出来

MinaServerUI类是服务端界面类

package com.cayden.swtmina;</p> <p>import java.net.InetSocketAddress;<br /> import java.nio.charset.Charset;<br /> import java.util.Set;</p> <p>import org.apache.mina.common.IoAcceptor;<br /> import org.apache.mina.common.IoSession;<br /> import org.apache.mina.filter.codec.ProtocolCodecFilter;<br /> import org.apache.mina.filter.codec.textline.TextLineCodecFactory;<br /> import org.apache.mina.filter.logging.LoggingFilter;<br /> import org.apache.mina.transport.socket.nio.NioSocketAcceptor;<br /> import org.eclipse.swt.SWT;<br /> import org.eclipse.swt.events.SelectionAdapter;<br /> import org.eclipse.swt.events.SelectionEvent;<br /> import org.eclipse.swt.events.ShellAdapter;<br /> import org.eclipse.swt.events.ShellEvent;<br /> import org.eclipse.swt.widgets.Button;<br /> import org.eclipse.swt.widgets.Display;<br /> import org.eclipse.swt.widgets.List;<br /> import org.eclipse.swt.widgets.Shell;<br /> import org.eclipse.swt.widgets.Text;</p> <p>import com.cayden.mina.TimeServerHandler;</p> <p>public class MinaServerUI {<br /> private static final int PORT = 9123;//定义监听端口<br /> private Text text;<br /> private List list;<br /> private TimeServerHandler timeServerHandler=new TimeServerHandler(this);<br /> /**<br /> * Launch the application<br /> * @param args<br /> */<br /> public static void main(String[] args) {<br /> try {<br /> MinaServerUI window = new MinaServerUI();<br /> window.open();<br /> } catch (Exception e) {<br /> e.printStackTrace();<br /> }<br /> }</p> <p> /**<br /> * Open the window<br /> */<br /> public void open() {<br /> final Display display = Display.getDefault();<br /> final Shell shell = new Shell();<br /> shell.addShellListener(new ShellAdapter() {<br /> public void shellClosed(final ShellEvent e) {<br /> System.exit(1);<br /> }<br /> });<br /> shell.setSize(518, 410);<br /> shell.setText("MINA服务端");<br /> //</p> <p> shell.open();</p> <p> list = new List(shell, SWT.BORDER);<br /> list.setBounds(10, 10, 399, 246);</p> <p> text = new Text(shell, SWT.BORDER);<br /> text.setBounds(10, 295, 399, 62);</p> <p> final Button button = new Button(shell, SWT.NONE);<br /> button.addSelectionListener(new SelectionAdapter() {<br /> public void widgetSelected(final SelectionEvent e) {<br /> String str=text.getText();<br /> timeServerHandler.setMessages(str);<br /> list.add("服务端:"+str);<br /> text.setText("");<br /> }<br /> });<br /> button.setText("发送");<br /> button.setBounds(440, 335, 48, 22);</p> <p> final Button button_1 = new Button(shell, SWT.NONE);<br /> button_1.addSelectionListener(new SelectionAdapter() {<br /> public void widgetSelected(final SelectionEvent e) {<br /> /**<br /> * 为开启服务重新开线程<br /> */<br /> new Thread(){<br /> public void run(){<br /> try{<br /> IoAcceptor acceptor = new NioSocketAcceptor();<br /> acceptor.getFilterChain().addLast( "logger", new LoggingFilter() );<br /> acceptor.getFilterChain().addLast( "codec", new ProtocolCodecFilter( new TextLineCodecFactory( Charset.forName( "UTF-8" ))));//指定编码过滤器<br /> acceptor.setHandler(timeServerHandler);//指定业务逻辑处理器<br /> acceptor.setDefaultLocalAddress( new InetSocketAddress(PORT) );//设置端口号<br /> acceptor.bind();//启动监听 </p> <p> }catch (Exception e1) {<br /> // TODO: handle exception<br /> System.out.println(e1.getMessage());<br /> }<br /> }<br /> }.start();</p> <p> }<br /> });<br /> button_1.setText("开启");<br /> button_1.setBounds(440, 9, 48, 22);<br /> shell.layout();<br /> while (!shell.isDisposed()) {<br /> if (!display.readAndDispatch())<br /> display.sleep();<br /> }<br /> }</p> <p> public Text getText() {<br /> return text;<br /> }</p> <p> public List getList() {<br /> return list;<br /> }</p> <p>}<br />

TimeServerHandler是服务端的处理类

/**<br /> *<br /> * 类IoHandlerAdapter用于定义业务逻辑<br /> * sessionCreated() 当会话创建时被触发<br /> * sessionOpened() 当会话开始时被触发<br /> sessionClosed() 当会话关闭时被触发<br /> sessionIdle() 当会话空闲时被触发<br /> exceptionCaught() 当接口中其他方法抛出异常未被捕获时触发此方法<br /> messageRecieved() 当接收到消息后被触发<br /> messageSent() 当发送消息后被触发<br /> */<br /> package com.cayden.mina;</p> <p>import java.net.InetSocketAddress;<br /> import java.nio.charset.Charset;<br /> import java.util.ArrayList;<br /> import java.util.Date;<br /> import java.util.Iterator;<br /> import java.util.List;</p> <p>import org.apache.mina.common.IdleStatus;<br /> import org.apache.mina.common.IoAcceptor;<br /> import org.apache.mina.common.IoHandlerAdapter;<br /> import org.apache.mina.common.IoSession;<br /> import org.apache.mina.filter.codec.ProtocolCodecFilter;<br /> import org.apache.mina.filter.codec.textline.TextLineCodecFactory;<br /> import org.apache.mina.filter.logging.LoggingFilter;<br /> import org.apache.mina.transport.socket.nio.NioSocketAcceptor;<br /> import org.eclipse.swt.widgets.Display;</p> <p>import com.cayden.swtmina.MinaServerUI;</p> <p>public class TimeServerHandler extends IoHandlerAdapter {</p> <p> private MinaServerUI minaServerUI;</p> <p> private String messages="";</p> <p> public TimeServerHandler(MinaServerUI minaServerUI){<br /> this.minaServerUI=minaServerUI;<br /> }<br /> @Override<br /> public void exceptionCaught(IoSession session, Throwable cause)<br /> throws Exception {<br /> // TODO Auto-generated method stub<br /> super.exceptionCaught(session, cause);<br /> }</p> <p> @Override<br /> public void messageSent(IoSession session, Object message) throws Exception {<br /> // TODO Auto-generated method stub<br /> super.messageSent(session, message);</p> <p> System.out.println("Message written..."); </p> <p> }<br /> /**<br /> * 当会话关闭时被触发<br /> */<br /> @Override<br /> public void sessionClosed(IoSession session) throws Exception {<br /> // TODO Auto-generated method stub<br /> super.sessionClosed(session);<br /> System.out.println("会话关闭");<br /> }</p> <p> @Override<br /> public void sessionIdle(IoSession session, IdleStatus status)<br /> throws Exception {<br /> // TODO Auto-generated method stub<br /> super.sessionIdle(session, status);<br /> }<br /> /**<br /> * 当会话开始时被触发<br /> */<br /> @Override<br /> public void sessionOpened(final IoSession session) throws Exception {<br /> // TODO Auto-generated method stub<br /> super.sessionOpened(session);<br /> this.setServerList("服务开启...");<br /> session.write("Hello ,you are success...");</p> <p> /**<br /> * 开启线程进行发送控制<br /> */<br /> new Thread(){<br /> public void run(){</p> <p> while(true){<br /> if(!"".equals(messages)&&null!=messages){<br /> session.write(messages);<br /> setMessages(null);<br /> }<br /> }<br /> }<br /> }.start();</p> <p> }</p> <p> /**<br /> * 当会话创建时被触发<br /> */<br /> @Override<br /> public void sessionCreated(IoSession session) {<br /> //显示客户端的ip和端口<br /> System.out.println(session.getRemoteAddress().toString());<br /> } </p> <p> /**<br /> * 当接收到消息后被触发<br /> */<br /> @Override<br /> public void messageReceived(final IoSession session, Object message ) throws Exception<br /> {<br /> String str = message.toString();<br /> System.out.println("收到客户信息:"+str);<br /> if( str.trim().equalsIgnoreCase("quit") ) {<br /> this.setServerList("客户端:/n"+"客户关闭...");<br /> session.close();//结束会话<br /> return;<br /> }<br /> else{<br /> this.setServerList("客户端:/n"+str);<br /> }</p> <p>// new Thread(){<br /> // public void run(){<br /> // while(true){<br /> //// if(!"".equals(messages)&&null!=messages){<br /> //// session.write(messages);<br /> //// messages=null;<br /> //// }<br /> // if(list.size()>0){<br /> // System.out.println("list.size()="+list.size());<br /> // session.write(list.get(0));<br /> // list.remove(0);<br /> // }<br /> // }<br /> // }<br /> // }.start();</p> <p> }<br /> @SuppressWarnings("unused")<br /> private void setDealChatServer(){<br /> Display.getDefault().syncExec(new Runnable(){<br /> public void run(){<br /> minaServerUI.getText().setText("");<br /> }<br /> });<br /> }<br /> /**<br /> * 设置服务端的显示信息<br /> * @param str<br /> */<br /> @SuppressWarnings("unused")<br /> private void setServerList(final String str){<br /> Display.getDefault().syncExec(new Runnable(){<br /> public void run(){<br /> minaServerUI.getList().add(str);<br /> }<br /> });<br /> }</p> <p> public void setMessages(String messages) {<br /> this.messages = messages;<br /> }</p> <p>}<br />

MinaClientUT是客户端的界面类

package com.cayden.swtmina;</p> <p>import java.net.InetSocketAddress;<br /> import java.nio.charset.Charset;</p> <p>import org.apache.mina.common.ConnectFuture;<br /> import org.apache.mina.filter.codec.ProtocolCodecFilter;<br /> import org.apache.mina.filter.codec.textline.TextLineCodecFactory;<br /> import org.apache.mina.filter.logging.LoggingFilter;<br /> import org.apache.mina.transport.socket.nio.NioSocketConnector;<br /> import org.eclipse.swt.SWT;<br /> import org.eclipse.swt.events.SelectionAdapter;<br /> import org.eclipse.swt.events.SelectionEvent;<br /> import org.eclipse.swt.events.ShellAdapter;<br /> import org.eclipse.swt.events.ShellEvent;<br /> import org.eclipse.swt.widgets.Button;<br /> import org.eclipse.swt.widgets.Display;<br /> import org.eclipse.swt.widgets.List;<br /> import org.eclipse.swt.widgets.Shell;<br /> import org.eclipse.swt.widgets.Text;</p> <p>import com.cayden.mina.TimeClientHandler;</p> <p>public class MinaClientUT {</p> <p> private Text text=null;<br /> private List list;<br /> private TimeClientHandler timeClientHandler=new TimeClientHandler(this);<br /> ConnectFuture cf=null;<br /> /**<br /> * Launch the application<br /> * @param args<br /> */<br /> public static void main(String[] args) {<br /> try {<br /> MinaClientUT window = new MinaClientUT();<br /> window.open();<br /> } catch (Exception e) {<br /> e.printStackTrace();<br /> }<br /> }</p> <p> /**<br /> * Open the window<br /> */<br /> public void open() {<br /> final Display display = Display.getDefault();<br /> final Shell shell = new Shell();<br /> shell.addShellListener(new ShellAdapter() {<br /> public void shellClosed(final ShellEvent e) {<br /> cf.getSession().write("quit");<br /> }<br /> });<br /> shell.setSize(518, 410);<br /> shell.setText("MINA客户端");<br /> //</p> <p> shell.open();</p> <p> list = new List(shell, SWT.BORDER);<br /> list.setBounds(10, 10, 399, 246);</p> <p> text = new Text(shell, SWT.BORDER);<br /> text.setBounds(10, 295, 399, 62);</p> <p> final Button button = new Button(shell, SWT.NONE);<br /> button.addSelectionListener(new SelectionAdapter() {<br /> public void widgetSelected(final SelectionEvent e) {<br /> String str=text.getText();<br /> cf.getSession().write(str);<br /> list.add("客户端:/n"+str);<br /> text.setText("");<br /> }</p> <p> });<br /> button.setText("发送");<br /> button.setBounds(440, 335, 48, 22);</p> <p> final Button button_1 = new Button(shell, SWT.NONE);<br /> button_1.addSelectionListener(new SelectionAdapter() {<br /> public void widgetSelected(final SelectionEvent e) {<br /> new Thread(){<br /> public void run(){<br /> NioSocketConnector connector = new NioSocketConnector();<br /> connector.getFilterChain().addLast( "logger", new LoggingFilter() );<br /> connector.getFilterChain().addLast( "codec", new ProtocolCodecFilter( new TextLineCodecFactory( Charset.forName( "UTF-8" )))); //设置编码过滤器<br /> connector.setConnectTimeout(30);<br /> connector.setHandler(timeClientHandler);//设置事件处理器<br /> cf = connector.connect(<br /> new InetSocketAddress("127.0.0.1", 9123));//建立连接<br /> cf.awaitUninterruptibly();//等待连接创建完成<br /> cf.getSession().write("hello");//发送消息<br /> // cf.getSession().write("quit");//发送消息<br /> cf.getSession().getCloseFuture().awaitUninterruptibly();//等待连接断开<br /> connector.dispose();<br /> }<br /> }.start();</p> <p> }<br /> });<br /> button_1.setText("连接");<br /> button_1.setBounds(440, 9, 48, 22);<br /> shell.layout();<br /> while (!shell.isDisposed()) {<br /> if (!display.readAndDispatch())<br /> display.sleep();<br /> }<br /> }</p> <p> public Text getText() {<br /> return text;<br /> }</p> <p> public List getList() {<br /> return list;<br /> }</p> <p>}<br />

TimeClientHandler是客户端的处理类

package com.cayden.mina;</p> <p>import org.apache.mina.common.IdleStatus;<br /> import org.apache.mina.common.IoHandlerAdapter;<br /> import org.apache.mina.common.IoSession;<br /> import org.eclipse.swt.widgets.Display;</p> <p>import com.cayden.swtmina.MinaClientUT;</p> <p>public class TimeClientHandler extends IoHandlerAdapter {<br /> private MinaClientUT minaClientUT;</p> <p> public TimeClientHandler(MinaClientUT minaClientUT){<br /> this.minaClientUT=minaClientUT;<br /> }<br /> @Override<br /> public void exceptionCaught(IoSession session, Throwable cause)<br /> throws Exception {<br /> // TODO Auto-generated method stub<br /> super.exceptionCaught(session, cause);<br /> }<br /> @Override<br /> public void messageSent(IoSession session, Object message) throws Exception {<br /> // TODO Auto-generated method stub<br /> super.messageSent(session, message);<br /> }<br /> @Override<br /> public void sessionClosed(IoSession session) throws Exception {<br /> // TODO Auto-generated method stub<br /> super.sessionClosed(session);<br /> }<br /> @Override<br /> public void sessionCreated(IoSession session) throws Exception {<br /> // TODO Auto-generated method stub<br /> super.sessionCreated(session);<br /> }<br /> @Override<br /> public void sessionIdle(IoSession session, IdleStatus status)<br /> throws Exception {<br /> // TODO Auto-generated method stub<br /> super.sessionIdle(session, status);<br /> }<br /> @Override<br /> public void sessionOpened(IoSession session) throws Exception {<br /> // TODO Auto-generated method stub<br /> super.sessionOpened(session);<br /> }<br /> public TimeClientHandler() {<br /> }<br /> @Override<br /> public void messageReceived(IoSession session, Object message) throws Exception {<br /> System.out.println(message);//显示接收到的消息<br /> this.setServerList(message.toString());<br /> }<br /> @SuppressWarnings("unused")<br /> private void setDealChatServer(){<br /> Display.getDefault().syncExec(new Runnable(){<br /> public void run(){<br /> minaClientUT.getText().setText("");<br /> }<br /> });<br /> }<br /> /**<br /> * 设置服务端的显示信息<br /> * @param str<br /> */<br /> @SuppressWarnings("unused")<br /> private void setServerList(final String str){<br /> Display.getDefault().syncExec(new Runnable(){<br /> public void run(){<br /> minaClientUT.getList().add("服务端:/n"+str);<br /> }<br /> });<br /> }</p> <p>} </p> <p>

以上四个类就包含整个程序.

需要注意的是,我在由服务端发送消息给客户端的时候是在服务端的处理类里面的 sessionOpened方法里面写了个线程

然后用死循环,我是这样处理服务端发送消息,大家看了后,若有更好方法可以直接留言.谢谢.

下载地址： http://vdisk.weibo.com/s/bVYy-