Freeswitch代码

1.引入依赖

Freeswitch依赖版本

<dependency><groupId>org.freeswitch.esl.client</groupId><artifactId>esl-client</artifactId><version>0.10.1</version>
</dependency>

2.代码

import org.freeswitch.esl.client.inbound.Client;
import org.freeswitch.esl.client.inbound.IEslEventListener;
import org.freeswitch.esl.client.internal.Context;
import org.freeswitch.esl.client.internal.IModEslApi;
import org.freeswitch.esl.client.transport.event.EslEvent;
import org.freeswitch.esl.client.transport.message.EslMessage;
import sun.management.resources.agent;import java.net.InetSocketAddress;
import java.net.SocketAddress;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.ScheduledThreadPoolExecutor;
import java.util.concurrent.TimeUnit;public class ClientTest {private static class DemoEventListener implements IEslEventListener {// @Overridepublic void eventReceived(EslEvent event) {System.out.println("eventReceived:" + event.getEventName());}// @Overridepublic void backgroundJobResultReceived(EslEvent event) {System.out.println("backgroundJobResultReceived:" + event.getEventName());}@Overridepublic void onEslEvent(Context ctx, EslEvent eslEvent) {System.out.println("eventReceived:" + eslEvent.getEventName());System.out.println("EventBody********:" + eslEvent.getEventHeaders().toString());String eventName = eslEvent.getEventName();//这里仅演示了CHANNEL_开头的几个常用事件if (eventName.startsWith("CHANNEL_")) {String calleeNumber = eslEvent.getEventHeaders().get("Caller-Callee-ID-Number");String callerNumber = eslEvent.getEventHeaders().get("Caller-Caller-ID-Number");switch (eventName) {case "CHANNEL_CREATE":System.out.println("发起呼叫, 主叫：" + callerNumber + " , 被叫：" + calleeNumber);break;case "CHANNEL_BRIDGE":System.out.println("用户转接, 主叫：" + callerNumber + " , 被叫：" + calleeNumber);break;case "CHANNEL_ANSWER":System.out.println("用户应答, 主叫：" + callerNumber + " , 被叫：" + calleeNumber);break;case "CHANNEL_HANGUP":String response = eslEvent.getEventHeaders().get("variable_current_application_response");String hangupCause = eslEvent.getEventHeaders().get("Hangup-Cause");System.out.println("用户挂断, 主叫：" + callerNumber + " , 被叫：" + calleeNumber + " , response:" + response + " ,hangup cause:" + hangupCause);break;default:break;}}}}public static void main(String[] args) throws InterruptedException {SocketAddress host = new InetSocketAddress("192.168.5.97", 8021);String password = "ClueCon";int timeoutSeconds = 10;Client inboundClient = new Client();try {inboundClient.connect(host, password, timeoutSeconds);inboundClient.addEventListener(new DemoEventListener());inboundClient.setEventSubscriptions(IModEslApi.EventFormat.PLAIN, "all");/*<--注册分机-->*/EslMessage eslMessage1 =inboundClient.sendApiCommand("callcenter_config agent set contact", "21009@default user/1000");System.out.println("#####dial eslMessage: "+eslMessage1.getHeaders().toString());System.out.println("#####dial eslMessage: "+eslMessage1.getBodyLines().toString()+"=&&="+eslMessage1.getBodyLines().get(0));/*<--查询分机状态-->*/// EslMessage eslMessage=inboundClient.sendApiCommand("list_users", "group default user 1000");//System.out.println("#####eslMessage: "+eslMessage.getHeaders().toString());//System.out.println("#####eslMessage: "+eslMessage.getBodyLines().get(0));/*<--播放欢迎语-->*///inboundClient.sendBackgroundApiCommand("originate", "user/1000 &playback(/usr/local/freeswitch/sounds/huanying.wav)");//inboundClient.sendBackgroundApiCommand("callcenter_config agent set status", "21009@default 'Available'");/*<--就绪-->*///inboundClient.sendBackgroundApiCommand("callcenter_config agent set status", "21009@default 'Available'");/*<--登出-->*///inboundClient.sendBackgroundApiCommand("callcenter_config agent set status", "21009@default 'Logged Out'");/*<--拨打电话异步(没有事件消息)-->*///inboundClient.sendBackgroundApiCommand("originate", "user/1000 1001");/*<--拨打电话同步-->*///EslMessage eslMessage1=inboundClient.sendApiCommand("originate", "user/1000 1001");//System.out.println("#####dial eslMessage: "+eslMessage1.getHeaders().toString());//System.out.println("#####dial eslMessage: "+eslMessage1.getBodyLines().toString()+"&&"+eslMessage1.getBodyLines().get(0));/*<--登录到queue-->*///inboundClient.sendBackgroundApiCommand("callcenter_config tier add", "support@default 21009@default 1 1");//callcenter_config tier set [key(state|level|position)] [queue name] [agent name] [value] //*<--登录到queue-->*/// inboundClient.sendBackgroundApiCommand("callcenter_config tier add", "support@default 21009@default 1 1");//EslMessage eslMessage1=inboundClient.sendApiCommand("callcenter_config tier add", "support@default 21009@default 1 1");;//#####dial eslMessage: [-ERR Tier already exist!]&&-ERR Tier already exist!//System.out.println("#####dial eslMessage: "+eslMessage1.getHeaders().toString());//System.out.println("#####dial eslMessage: "+eslMessage1.getBodyLines().toString()+"&&"+eslMessage1.getBodyLines().get(0));/*<--这个queue未就绪-->*/// support@default 21009@default on break//inboundClient.sendBackgroundApiCommand("callcenter_config tier set state", "support@default 21009@default on break");System.out.println("###################Fs excuted start############");} catch (Exception e) {System.out.println("connect fail error: "+e);}//health-checkScheduledExecutorService service = new ScheduledThreadPoolExecutor(1);service.scheduleAtFixedRate(() -> {System.out.println(System.currentTimeMillis() + " " + inboundClient.canSend());if (!inboundClient.canSend()) {try {//重连inboundClient.connect(host, password, timeoutSeconds);inboundClient.cancelEventSubscriptions();inboundClient.setEventSubscriptions(IModEslApi.EventFormat.PLAIN, "all");} catch (Exception e) {System.out.println("connect fail");}}}, 1, 500000000, TimeUnit.MILLISECONDS);System.out.println("other process ...");}
}