Java 服务器推送聊天：需要在 java 服务器和 android 上进行一对一聊天的推送架构

Question

我需要 Pusher android 和 Java 一对一聊天的服务器端实现的架构。

下面是 android 代码，它工作正常，我也得到了 auth。

  {"event":"pusher:subscribe","data":{"auth":"9272f25541ab7b04fc60:e146b0b663fdfe276af5e4d45de6db7db272bd103414cc9525b998c5eff35268","channel_data":"{\"user_id\":\"12345\",\"user_info\":{\"name\":\"Phil Leggetter\",\"twitterId\":\"@leggetter\"}}","channel":"presence-channel"}}

和Android代码在这里：

final HttpAuthorizer authorizer = new HttpAuthorizer(Constant.BASE_URL_BHARTI + "initial/pusher/auth");
    //authorizer.setHeaders(getMapAuthorizationHeaders());
    PusherOptions options = new PusherOptions().setAuthorizer(authorizer);
    final Pusher pusher = new Pusher("9272f25541ab7b04fc60", options);

    pusher.connect(new com.pusher.client.connection.ConnectionEventListener() {


        @Override
        public void onConnectionStateChange(ConnectionStateChange connectionStateChange) {

            Log.e("connectionStateChange", connectionStateChange.getCurrentState().toString());

            if (connectionStateChange.getCurrentState() == ConnectionState.CONNECTED) {

                SOCKET_ID = pusher.getConnection().getSocketId();
                Log.e("SOCKET_ID", "" + SOCKET_ID);

                channel = pusher.subscribePresence("presence-channel", new PresenceChannelEventListener() {
                    @Override
                    public void onUsersInformationReceived(String channelName, Set<User> users) {
                        Log.e("PUSHER", "" + channelName + "  " + new Gson().toJsonTree(users));
                    }

                    @Override
                    public void userSubscribed(String channelName, User user) {
                        Log.e("PUSHER", "Channel userSubscribed authorization succeeded  " + channelName);
                    }

                    @Override
                    public void userUnsubscribed(String channelName, User user) {
                        Log.e("PUSHER", "Channel userUnsubscribed authorization err  " + channelName);
                    }

                    @Override
                    public void onAuthenticationFailure(String message, Exception e) {
                        Log.e("PUSHER", "Channel subscription authorization failed  " + e);
                    }

                    @Override
                    public void onSubscriptionSucceeded(String channelName) {
                        Log.e("PUSHER", "Channel subscription authorization succeeded  " + channelName);
                        CHANELNAME = channelName;
                    }

                    @Override
                    public void onEvent(String channelName, String eventName, String data) {
                        Log.e("PUSHER", "An event with name " + eventName + " was delivered!!" + "  " + data + "  " + channelName);
                        Gson gson = new Gson();
                        Message message = gson.fromJson(data, Message.class);
                        try {
                            messageAdapter.add(message);
                            messagesView.setSelection(messageAdapter.getCount() - 1);
                        } catch (Exception e) {
                            Log.e("Exception", "" + e);
                        }
                    }
                },"my-event");

现在我需要java一对一聊天的服务器端代码实现。

Answer 1

可以参考这里Pusher one to one chat structure

java 服务器端实现的第一个要求，您必须在 pom.xml.

中添加依赖项

      <dependency>
           <groupId>com.pusher</groupId>
           <artifactId>pusher-http-java</artifactId>
          <version>1.0.0</version>
      </dependency>

和

       <dependency>
             <groupId>org.apache.httpcomponents</groupId>
             <artifactId>httpclient</artifactId>
             <version>4.3.5</version>
       </dependency>

否则你会得到500 error

如果您使用 JAX-RS Web 服务和 Presence Channel，那么您的 /pusher/auth 服务可以写成：

@POST
@Consumes(MediaType.APPLICATION_FORM_URLENCODED)
@Produces(MediaType.TEXT_PLAIN)
@Path("/pusher/auth")
public String processMessagesAndAuthentication( MultivaluedMap<String, String> input){
    Pusher pusher = new Pusher("APP-ID", "PUSHER-KEY", "PUSHER-SECRET-KEY");
    String userId = "12345"; //any unique id
    Map<String, String> userInfo = new HashMap<>();
    userInfo.put("name", "Bharti Rawat");
    userInfo.put("twitterId", "@leggetter");
    String socket_id = input.getFirst("socket_id");
    String channel_name = input.getFirst("channel_name");
    String auth = pusher.authenticate(socket_id, channel_name, new PresenceUser(userId, userInfo));
    return auth;
}

Java 服务器推送聊天：需要在 java 服务器和 android 上进行一对一聊天的推送架构

Java Server Pusher Chat: needs Architecture for Pusher one to one chat on java server as well as android

java

android

web-services

jax-rs

pusher