lizongbo at 618119.com

接上一篇: http://618119.com/archives/2007/11/29/34.html
针对每个SMPPPacket的处理,将其以接口方式进行处理,接口定义如下:

[code]
package com.lizongbo.smpp.server;

import org.apache.mina.common.IoSession;
import ie.omk.smpp.message.SMPPPacket;
import ie.omk.smpp.BadCommandIDException;

public interface SMPPPacketHandler {
void process(IoSession session, SMPPPacket packet) throws
BadCommandIDException;
}

[/code]

SMPPServerSessionHandler中通过commandid来找到相应的handler,然后进行处理.

[code]

package com.lizongbo.smpp.server;

import java.util.*;

import org.apache.mina.common.*;
import ie.omk.smpp.*;
import ie.omk.smpp.message.*;
import ie.omk.smpp.version.*;

public class SMPPServerSessionHandler
extends IoHandlerAdapter {
private Map<Long,
SMPPPacketHandler> handles = null;
private int readerIdleTimeout = 120;
public void sessionOpened(IoSession session) throws Exception {
session.setIdleTime(IdleStatus.READER_IDLE, readerIdleTimeout);
}

public void messageReceived(IoSession session, Object message) throws
Exception {
SMPPPacket packet = (SMPPPacket) message;
// System.out.println(”收到消息” + packet);
int id = packet.getCommandId();
if (!SMPPVersion.getDefaultVersion().isSupported(id)) {
StringBuffer err = new StringBuffer(120)
.append(SMPPVersion.getDefaultVersion().toString())
.append(” does not support command ID 0x”)
.append(Integer.toHexString(id));
throw new VersionException(err.toString());
}
long l = id & 0×00000000FFFFFFFFl;
// Integer.decode(”0×80000005″)要出错,被迫用Long类型,
//因此在这里需要将整数的id通过高位补0来实现,而不能直接进行强类型转换
SMPPPacketHandler handler = handles.get(Long.valueOf(l));
if (handler != null) {
handler.process(session, packet);
}
else {
//System.out.println(”丢弃的消息为:” +  id + packet);
//throw new BadCommandIDException();
}

}

public Map getHandles() {
return handles;
}

public int getReaderIdleTimeout() {
return readerIdleTimeout;
}

public void setHandles(Map handles) {
this.handles = handles;
}

public void setReaderIdleTimeout(int readerIdleTimeout) {
this.readerIdleTimeout = readerIdleTimeout;
}

}

[/code]

Related posts

• 慎用ByteBuffer.allocateDirect (0)
• hessian 3.1.5的bug及相关例子 (1)
• Apache MINA 2.0.0-M2 正式发布了 (0)
• Apache MINA 2.0.0-M1 发布了 (0)
• 在mina的ProtocolDecoder合并 未完整发送的数据包 (0)

接上一篇: http://618119.com/archives/2007/11/27/31.html

对smpp 数据包进行编码和解码的相关代码如下:

ProtocolCodecFactory的代码为:

[code]
package com.lizongbo.smpp.server.codec;
import org.apache.mina.filter.codec.ProtocolCodecFactory;
import org.apache.mina.filter.codec.ProtocolEncoder;
import org.apache.mina.filter.codec.ProtocolDecoder;
public class SMPPProtocolCodecFactory
implements ProtocolCodecFactory {
ProtocolDecoder decoder = new SMPPProtocolDecoder();
ProtocolEncoder encoder = new SMPPProtocolEncoder();
public ProtocolEncoder getEncoder() throws Exception {
return encoder;
}
public ProtocolDecoder getDecoder() throws Exception {
return decoder;
}
}

[/code]

数据包解码的ProtocolDecoder为

[code]

package com.lizongbo.smpp.server.codec;

import org.apache.mina.filter.codec.ProtocolDecoder;
import org.apache.mina.common.IoSession;
import org.apache.mina.common.ByteBuffer;
import org.apache.mina.filter.codec.ProtocolDecoderOutput;
import ie.omk.smpp.message.SMPPProtocolException;
import ie.omk.smpp.BadCommandIDException;
import ie.omk.smpp.util.PacketFactory;
import org.apache.log4j.Logger;
import ie.omk.smpp.message.SMPPPacket;
import java.io.IOException;

public class SMPPProtocolDecoder
implements ProtocolDecoder {
protected Logger log = Logger.getLogger(getClass());
public void decode(IoSession session, ByteBuffer in,
ProtocolDecoderOutput out) throws Exception {

try {
if (in.remaining() >= 4 && (in.remaining() >= in.getInt(in.position()))) {
byte[] byteLen = new byte[4];
in.get(byteLen);
int len = readInt(byteLen);
//System.out.println(”消息长度为:” + len);
if (in.remaining() >= (len - 4)) {
byte[] cmds = new byte[len - 4];
in.get(cmds);
SMPPPacket pak = null;
int id = -1;
id = readInt(cmds);
pak = PacketFactory.newInstance(id);
if (pak != null) {
byte[] reqb = new byte[4 + len];
System.arraycopy(byteLen, 0, reqb, 0, 4);
System.arraycopy(cmds, 0, reqb, 4, cmds.length);
pak.readFrom(reqb, 0);
if (log.isDebugEnabled()) {
StringBuilder sb = new StringBuilder(”收到的包为: “);
int l = pak.getLength();
int s = pak.getCommandStatus();
int n = pak.getSequenceNum();
sb.append(”commandId:”).append(Integer.toHexString(id))
.append(” len:”).append(Integer.toString(l))
.append(” commandStatus:”).append(Integer.toString(s))
.append(” sequenceNum:”).append(Integer.toString(n));
log.debug(sb);
}
out.write(pak);
}
}
}
}
catch (BadCommandIDException x) {
throw new SMPPProtocolException(”Unrecognised command received”, x);
}

}

public void finishDecode(IoSession session, ProtocolDecoderOutput out) throws
Exception {
}

public void dispose(IoSession session) throws Exception {
}

public final int readInt(byte[] b) throws IOException {
int ch1 = b[0];
int ch2 = b[1];
int ch3 = b[2];
int ch4 = b[3];
// if ( (ch1 | ch2 | ch3 | ch4) < 0) {
// throw new EOFException();
// }
// see: http://618119.com/archives/2007/10/27/18.html
return ( ( (ch1 & 0xff) << 24) + ( (ch2 & 0xff) << 16) +
( (ch3 & 0xff) << 8) + (ch4 << 0));
}
}
[/code]

数据包的ProtocolEncoder非常简单了:

[code]

package com.lizongbo.smpp.server.codec;

import org.apache.mina.filter.codec.ProtocolEncoder;
import org.apache.mina.common.IoSession;
import org.apache.mina.filter.codec.ProtocolEncoderOutput;
import org.apache.mina.common.ByteBuffer;
import ie.omk.smpp.message.SMPPPacket;
import java.io.ByteArrayOutputStream;

public class SMPPProtocolEncoder
implements ProtocolEncoder {
public void encode(IoSession session, Object message,
ProtocolEncoderOutput out) throws Exception {
if (message == null) {
return;
}
SMPPPacket packet = (SMPPPacket) message;
ByteArrayOutputStream outb = new ByteArrayOutputStream(packet.getLength());
packet.writeTo(outb);
byte[] b = outb.toByteArray();
ByteBuffer buf = ByteBuffer.allocate(b.length, true);
buf.setAutoExpand(true);
buf.put(b);
buf.flip();
session.write(buf);
}

public void dispose(IoSession session) throws Exception {
}

}
[/code]

Related posts

• 慎用ByteBuffer.allocateDirect (0)
• hessian 3.1.5的bug及相关例子 (1)
• Apache MINA 2.0.0-M2 正式发布了 (0)
• Apache MINA 2.0.0-M1 发布了 (0)
• 在mina的ProtocolDecoder合并 未完整发送的数据包 (0)

需要用到的java库有:

Apache mina : http://mina.apache.org

Spring: http://www.springframework.org/

smppapi http://smppapi.sourceforge.net/

commons ssl: http://juliusdavies.ca/commons-ssl/

smpp smsc Server的服务端启动代码:
[code]
package com.lizongbo.smpp.server;

import org.apache.mina.filter.LoggingFilter;
import com.lizongbo.smpp.server.codec.SMPPProtocolCodecFactory;
import org.apache.mina.filter.codec.ProtocolCodecFilter;
import org.apache.mina.common.DefaultIoFilterChainBuilder;
import java.net.InetSocketAddress;
import org.apache.mina.common.IoAcceptorConfig;
import org.apache.mina.transport.socket.nio.SocketAcceptor;
import org.apache.mina.common.IoAcceptor;
import org.apache.mina.transport.socket.nio.SocketAcceptorConfig;
import java.io.IOException;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import java.util.Set;
import org.apache.mina.common.IoSession;
import ie.omk.smpp.*;
import ie.omk.smpp.message.*;
import ie.omk.smpp.util.PacketFactory;
import java.util.*;
import com.lizongbo.smpp.server.handlers.*;
/**
*
*Title: java smpp smsc server
*
*Description: smpp短消息中心
*
*Copyright: Copyright (c) 2007
*
*Company: http://618119.com
*
* @author lizongbo
* @version 1.0
*/

public class Main {
public static void main(String[] args) {
//以 spring配置方式启动
ApplicationContext context = new ClassPathXmlApplicationContext(
“classpath*:/springmina.xml”);
IoAcceptor acceptor = (IoAcceptor) context.getBean(”ioAcceptor”);
test(acceptor);
}
//普通方式启动
public static void commonmain(String[] args) throws IOException {
IoAcceptor acceptor = new SocketAcceptor();
IoAcceptorConfig config = new SocketAcceptorConfig();
DefaultIoFilterChainBuilder chain = config.getFilterChain();
chain.addLast(”logger”, new LoggingFilter());
chain.addLast(”codec”,
new ProtocolCodecFilter(new SMPPProtocolCodecFactory()));
chain.addLast(”threadpool”,
new org.apache.mina.filter.executor.ExecutorFilter());
InetSocketAddress serverAddr = new InetSocketAddress(5432);
SMPPServerSessionHandler handler = new SMPPServerSessionHandler();
Map<long> handles = new HashMap</long><long> ();
handles.put(Long.valueOf(0×00000002), new BindTransmitterHandler());
handles.put(Long.valueOf(0×00000001), new BindReceiverHandler());
handles.put(Long.valueOf(0×00000004), new SubmitSMHandler());
handles.put(Long.valueOf(0×00000006), new UnbindHandler());
handles.put(Long.valueOf(0×80000005), new DeliverSMRespHandler());
acceptor.bind(serverAddr, handler, config);
System.out.println(”Listening on port ” + 5432);
test(acceptor);
}</long>

private static void test(IoAcceptor acceptor) throws
InvalidParameterValueException {
try {
Thread.sleep(20000);
}
catch (InterruptedException ex) {
}
Set<iosession> ss = acceptor.getManagedSessions(new InetSocketAddress(5432));
System.out.println(”ss.size() == ” + ss.size());
if (ss.size() > 0) {
//模拟主动下发一条消息状态报告
DeliverSM rs = null;
try {
rs = (DeliverSM) PacketFactory.newInstance(SMPPPacket.DELIVER_SM);
}
catch (BadCommandIDException ex1) {
}
//这里还有很多字段没填,需要补上
rs.setSequenceNum(9999);
rs.setMessageId(”618119″);
rs.setServiceType(”aaa”);
rs.setSource(new Address(0, 0, “618119″));
rs.setDestination(new Address(0, 0, “10086″));
rs.setEsmClass(0);
rs.setProtocolID(0);
rs.setPriority(0);
rs.setRegistered(0);
rs.setReplaceIfPresent(0);
rs.setDataCoding(15);
rs.setDefaultMsg(1);
rs.setMessage(”succ”.getBytes());
System.out.println(”主动发回一个消息应答”);
ss.iterator().next().write(rs);
}
}</iosession>
}
[/code]
spring 的xml配置文件:

[code]

<?xml version=”1.0″ encoding=”UTF-8″?>
<beans xmlns=”http://www.springframework.org/schema/beans” xmlns:xsi=”http://www.w3.org/2001/XMLSchema-instance” xmlns:aop=”http://www.springframework.org/schema/aop” xmlns:util=”http://www.springframework.org/schema/util” xsi:schemaLocation=”http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/--escaped_anchor:e3d7b21df466d13b15e011f977f36957---beans-2.0.xsd
http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/--escaped_anchor:e3d7b21df466d13b15e011f977f36957---aop-2.0.xsd
http://www.springframework.org/schema/util http://www.springframework.org/schema/util/--escaped_anchor:e3d7b21df466d13b15e011f977f36957---util-2.0.xsd “>
<util:constant id=”ie.omk.smpp.message.BIND_TRANSMITTER” static-field=”ie.omk.smpp.message.SMPPPacket.BIND_TRANSMITTER”/>
<bean id=”com.lizongbo.smpp.server.handlers.BindTransmitterHandler” class=”com.lizongbo.smpp.server.handlers.BindTransmitterHandler”/>
<bean id=”com.lizongbo.smpp.server.handlers.BindReceiverHandler” class=”com.lizongbo.smpp.server.handlers.BindReceiverHandler”/>
<bean id=”com.lizongbo.smpp.server.handlers.SubmitSMHandler” class=”com.lizongbo.smpp.server.handlers.SubmitSMHandler”/>
<bean id=”com.lizongbo.smpp.server.handlers.UnbindHandler” class=”com.lizongbo.smpp.server.handlers.UnbindHandler”/>
<bean id=”com.lizongbo.smpp.server.handlers.DeliverSMRespHandler” class=”com.lizongbo.smpp.server.handlers.DeliverSMRespHandler”/>
<util:map id=”handlers” key-type=”java.lang.Long”>
<!– Integer.decode(”0×80000005″)要出错,被迫用Long类型 –>
<entry key=”0×00000002″>
<ref local=”com.lizongbo.smpp.server.handlers.BindTransmitterHandler”/>
</entry>
<entry key=”0×00000001″>
<ref local=”com.lizongbo.smpp.server.handlers.BindReceiverHandler”/>
</entry>
<entry key=”0×00000004″>
<ref local=”com.lizongbo.smpp.server.handlers.SubmitSMHandler”/>
</entry>
<entry key=”0×00000006″>
<ref local=”com.lizongbo.smpp.server.handlers.UnbindHandler”/>
</entry>
<entry key=”0×80000005″>
<ref local=”com.lizongbo.smpp.server.handlers.DeliverSMRespHandler”/>
</entry>
</util:map>
<bean class=”org.springframework.beans.factory.config.CustomEditorConfigurer”>
<property name=”customEditors”>
<map>
<entry key=”java.net.SocketAddress”>
<bean class=”org.apache.mina.integration.spring.InetSocketAddressEditor”/>
</entry>
</map>
</property>
</bean>
<!– The IoHandler delegate implementation –>
<bean id=”smppHandler” class=”com.lizongbo.smpp.server.SMPPServerSessionHandler”>
<property name=”handles”>
<ref local=”handlers”/>
</property>
<property name=”readerIdleTimeout”>
<value>600</value>
</property>
</bean>
<!– The protocol codec factory for smpp –>
<bean id=”smppProtocolCodecFactory” class=”com.lizongbo.smpp.server.codec.SMPPProtocolCodecFactory”> </bean>
<bean id=”smppFilterThreadPoolFactory” class=”org.apache.mina.integration.spring.ThreadPoolExecutorFactoryBean”>
<property name=”corePoolSize” value=”10″/>
<property name=”maxPoolSize” value=”100″/>
<property name=”keepAliveSeconds” value=”30″/>
</bean>
<bean id=”smppFilterChainBuilder” class=”org.apache.mina.integration.spring.DefaultIoFilterChainBuilderFactoryBean”>
<property name=”filters”>
<list>
<bean class=”org.apache.mina.filter.executor.ExecutorFilter”>
<constructor-arg>
<ref bean=”smppFilterThreadPoolFactory”/>
</constructor-arg>
</bean>
<bean class=”org.apache.mina.filter.codec.ProtocolCodecFilter”>
<constructor-arg ref=”smppProtocolCodecFactory”/>
</bean>
<bean class=”org.apache.mina.filter.LoggingFilter”/>
</list>
</property>
<property name=”filterNamePrefix” value=”smppFilterPool”/>
</bean>
<bean id=”smppThreadModel” class=”org.apache.mina.integration.spring.ExecutorThreadModelFactoryBean”>
<property name=”serviceName” value=”smppService”/>
<property name=”executor”>
<bean class=”org.apache.mina.integration.spring.ThreadPoolExecutorFactoryBean”>
<property name=”corePoolSize” value=”6″/>
<property name=”maxPoolSize” value=”10″/>
<property name=”keepAliveSeconds” value=”30″/>
</bean>
</property>
</bean>
<bean id=”smppSocketAcceptorConfig” class=”org.apache.mina.transport.socket.nio.SocketAcceptorConfig”>
<property name=”filterChainBuilder” ref=”smppFilterChainBuilder”/>
<property name=”threadModel” ref=”smppThreadModel”/>
<property name=”reuseAddress” value=”true”/>
</bean>
<bean id=”threadExecutor” class=”java.util.concurrent.Executors” factory-method=”newCachedThreadPool”/>
<bean id=”ioAcceptor” class=”org.apache.mina.integration.spring.IoAcceptorFactoryBean”>
<property name=”target”>
<bean class=”org.apache.mina.transport.socket.nio.SocketAcceptor”>
<constructor-arg index=”0″>
<value>3</value>
</constructor-arg>
<constructor-arg index=”1″>
<ref bean=”threadExecutor”/>
</constructor-arg>
</bean>
</property>
<property name=”bindings”>
<list>
<bean class=”org.apache.mina.integration.spring.Binding”>
<property name=”address” value=”:5432″/>
<property name=”handler” ref=”smppHandler”/>
<property name=”serviceConfig” ref=”smppSocketAcceptorConfig”/>
</bean>
</list>
</property>
</bean>
<!– SMSC BEANS –>
<bean id=”smscFilterThreadPoolFactory” class=”org.apache.mina.integration.spring.ThreadPoolExecutorFactoryBean”>
<property name=”corePoolSize” value=”10″/>
<property name=”maxPoolSize” value=”100″/>
<property name=”keepAliveSeconds” value=”30″/>
</bean>
<bean id=”smscFilterChainBuilder” class=”org.apache.mina.integration.spring.DefaultIoFilterChainBuilderFactoryBean”>
<property name=”filters”>
<list>
<bean class=”org.apache.mina.filter.codec.ProtocolCodecFilter”>
<constructor-arg ref=”smppProtocolCodecFactory”/>
</bean>
<bean class=”org.apache.mina.filter.executor.ExecutorFilter”>
<constructor-arg>
<ref bean=”smscFilterThreadPoolFactory”/>
</constructor-arg>
</bean>
<bean class=”org.apache.mina.filter.LoggingFilter”/>
</list>
</property>
<property name=”filterNamePrefix” value=”smscFilterPool”/>
</bean>
<bean id=”smscThreadModel” class=”org.apache.mina.integration.spring.ExecutorThreadModelFactoryBean”>
<property name=”serviceName” value=”smscService”/>
<property name=”executor”>
<bean class=”org.apache.mina.integration.spring.ThreadPoolExecutorFactoryBean”>
<property name=”corePoolSize” value=”6″/>
<property name=”maxPoolSize” value=”10″/>
<property name=”keepAliveSeconds” value=”30″/>
</bean>
</property>
</bean>
<bean id=”smscSocketConnectorConfig” class=”org.apache.mina.transport.socket.nio.SocketConnectorConfig”>
<property name=”filterChainBuilder” ref=”smscFilterChainBuilder”/>
<property name=”threadModel” ref=”smscThreadModel”/>
</bean>
</beans>
[/code]

Related posts

• 慎用ByteBuffer.allocateDirect (0)
• hessian 3.1.5的bug及相关例子 (1)
• Apache MINA 2.0.0-M2 正式发布了 (0)
• Apache MINA 2.0.0-M1 发布了 (0)
• 在mina的ProtocolDecoder合并 未完整发送的数据包 (0)