def retrofitVersion = '2.0.0-beta1'dependencies {compile fileTree(dir: 'libs', include: ['*.jar'])testCompile 'junit:junit:4.12'compile 'com.android.support:appcompat-v7:22.2.1'compile 'com.android.support:design:22.2.1'//Retrofitcompile "com.squareup.retrofit:retrofit:$retrofitVersion"compile "com.squareup.retrofit:converter-gson:$retrofitVersion"//RxJavacompile 'io.reactivex:rxjava:1.0.14'compile 'io.reactivex:rxandroid:1.0.1'
}

public class MainActivity extends Activity implements View.OnClickListener {/*** 自定义的观察者*/public MyObserver observer;@Overrideprotected void onCreate(Bundle savedInstanceState) {super.onCreate(savedInstanceState);setContentView(R.layout.activity_main);Button btn = (Button) findViewById(R.id.btn);btn.setOnClickListener(this);observer = new MyObserver();//创建一个观察者
}//点击按钮就请求网络
    @Overridepublic void onClick(View view) {if (view.getId() == R.id.btn) {//点击获取好友动态Control control = new Control(this);control.getFriendsShareFromServer();//访问网络并且解析Json}}/*** 自定义的观察者*/class MyObserver implements rx.Observer<Resquest_friends_info> {@Overridepublic void onCompleted() {Log.d("msg", "观察的事件结束了---");}@Overridepublic void onError(Throwable e) {Log.d("msg", "观察的事件出错了");}//订阅观察者后，被观察者会把数据传回来@Overridepublic void onNext(Resquest_friends_info resquest_friends_info) {Log.d("msg", "观察者OnNext");ArrayList<Resquest_friends_info.EveryShareInfo> results = resquest_friends_info.getResult();Toast.makeText(MainActivity.this,"观察者收到了数据",Toast.LENGTH_SHORT).show();for (Resquest_friends_info.EveryShareInfo info : results) {//每条分享的信息Log.d("msg", "分享信息++++" + info.getPub_context() + "--->" + info.getPub_datetime() + "----->" + info.getPub_frd_name());Log.d("msg", "-----------------------------------------------------");for (Resquest_friends_info.EveryShareInfo.Reply reply : info.pub_com) {//每条回复Log.d("msg", "评论+++++" + reply.getPc_name() + "--->" + reply.getPc_txt() + "--->");Log.d("msg", "----------------------------------------------------------------");}for (Resquest_friends_info.EveryShareInfo.Thumb thumb : info.pub_thumup) {//每个点赞Log.d("msg", "点赞++++" + thumb.getPt_name());Log.d("msg", "---------------------------------------");}}}}
}

//访问网络的接口
public interface GitHubService {
//    ================================================  =   =   ==  ==========//　　//表示Get请求，里面是地址这是写死的地址，但是地址中的参数要动态改变，就不能这样写//  @GET("/index.php?m=home&c=message&a=resquest_friends_info&uid=1234567&p=1")　　　　

//参数要动态传进去，所以要这样写//@GET(value = "/index.php")，  或者@GET("/index.php")也可以

@GET("/index.php")

//用这个方法去访问网络

Call<Resquest_friends_info> getFriendsShareInfo(@Query("m") String m,@Query("c") String c,@Query("a") String a,@Query("uid") String uid,@Query("p") String p);　

}

这里的路径可以自己修改，比如，写成这样也是可以的：

//@GET("/index.php?m=home")//Call<Resquest_friends_info> getFriendsShareInfo(@Query("c") String c,@Query("a") String a,@Query("uid") String uid,@Query("p") String p);

/**此类是访问网络的Control* Created by xhj on 15-12-18.*/
public class Control {public static final String TAG="msg";　　//URL根路径，一般就是域名public static final String APITrack="http://192.168.1.102";private MainActivity activity;/**构造方法时把观察者所在的类传进来*/public Control(MainActivity activity){this.activity=activity;}/**从服务器获取好友动态*/public void getFriendsShareFromServer(){Retrofit retrofit = new Retrofit.Builder().baseUrl(APITrack).addConverterFactory(GsonConverterFactory.create())//用Gson去解析数据.build();GitHubService git = retrofit.create(GitHubService.class);Call<Resquest_friends_info> call = git.getFriendsShareInfo();call.enqueue(new Callback<Resquest_friends_info>() {　　　　　　　　//访问网络回来，并且成功拿到数据就调用这个方法@Overridepublic void onResponse(Response<Resquest_friends_info> response) {final Resquest_friends_info resquest_friends_info = response.body();Observable<Resquest_friends_info> observable = Observable.create(new Observable.OnSubscribe<Resquest_friends_info>() {@Overridepublic void call(Subscriber<? super Resquest_friends_info> subscriber) {subscriber.onNext(resquest_friends_info);subscriber.onCompleted();//事件结束
                    }});observable.subscribe(activity.observer);//订阅观察者
}@Overridepublic void onFailure(Throwable t) {Log.d("msg","失败了");}});}
}